1 package net.sourceforge.rpgee.messaging.network;
2
3 import java.util.Queue;
4 import java.util.concurrent.ConcurrentLinkedQueue;
5
6 import net.sourceforge.rpgee.messaging.RpgMessage;
7 import net.sourceforge.rpgee.utility.BaseObservable;
8
9 public class NetworkMessageHub extends BaseObservable<RpgMessage> {
10 private Queue<RpgMessage> messages = new ConcurrentLinkedQueue<RpgMessage>();
11
12
13 public void addMessage(RpgMessage m) {
14 messages.add(m);
15 this.setChanged();
16 }
17
18 }