KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > snipsnap > notification > MessageService


1 /*
2  * This file is part of "SnipSnap Wiki/Weblog".
3  *
4  * Copyright (c) 2002 Stephan J. Schmidt, Matthias L. Jugel
5  * All Rights Reserved.
6  *
7  * Please visit http://snipsnap.org/ for updates and contact.
8  *
9  * --LICENSE NOTICE--
10  * This program is free software; you can redistribute it and/or
11  * modify it under the terms of the GNU General Public License
12  * as published by the Free Software Foundation; either version 2
13  * of the License, or (at your option) any later version.
14  *
15  * This program is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18  * GNU General Public License for more details.
19  *
20  * You should have received a copy of the GNU General Public License
21  * along with this program; if not, write to the Free Software
22  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
23  * --LICENSE NOTICE--
24  */
25
26 package org.snipsnap.notification;
27
28 import org.snipsnap.app.Application;
29 import org.snipsnap.config.Configuration;
30 import org.snipsnap.notification.jabber.JabberNotifier;
31 import org.snipsnap.snip.Snip;
32 import org.snipsnap.user.User;
33
34 import java.util.ArrayList JavaDoc;
35 import java.util.Iterator JavaDoc;
36 import java.util.List JavaDoc;
37
38 /**
39  * Central Message Queue
40  * Could be moved to a mor IoC Style with SignalSlot. Could
41  * be extended to provide easier intra-container communication
42  *
43  * @author Stephan J. Schmidt
44  * @version $Id: MessageService.java 1257 2003-12-11 13:36:55Z leo $
45  */
46
47 public class MessageService {
48   private List JavaDoc consumers;
49
50   public MessageService() {
51     consumers = new ArrayList JavaDoc();
52   }
53
54   public synchronized void send(Message message) {
55     Iterator JavaDoc iterator = consumers.iterator();
56     while (iterator.hasNext()) {
57       Consumer consumer = (Consumer) iterator.next();
58       consumer.consume(message);
59     }
60   }
61
62   public synchronized void register(Consumer consumer) {
63     if (! consumers.contains(consumer)) {
64       consumers.add(consumer);
65     }
66   }
67
68   public synchronized void deregister(Consumer consumer) {
69     if (consumers.contains(consumer)) {
70       consumers.add(consumer);
71     }
72   }
73 }
74
Popular Tags