Package org.objectweb.joram.mom.proxies
Class QueueWorker
- java.lang.Object
-
- org.objectweb.joram.mom.proxies.QueueWorker
-
-
Field Summary
Fields Modifier and Type Field Description private static booleanDEBUGprivate static Loggerloggerprivate ConcurrentLinkedQueue<ProxyMessage>queueprivate booleanrunningProxyMessageSendersender
-
Constructor Summary
Constructors Constructor Description QueueWorker()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private voidhandleMessage(ProxyMessage msg)intqueueSize()voidrun()voidsend(ProxyMessage msg)voidsetSender(ProxyMessageSender sender)
-
-
-
Field Detail
-
logger
private static final Logger logger
-
DEBUG
private static final boolean DEBUG
-
queue
private ConcurrentLinkedQueue<ProxyMessage> queue
-
running
private boolean running
-
sender
public ProxyMessageSender sender
-
-
Method Detail
-
queueSize
public int queueSize()
-
setSender
public void setSender(ProxyMessageSender sender)
-
handleMessage
private void handleMessage(ProxyMessage msg) throws Exception
- Throws:
Exception
-
send
public void send(ProxyMessage msg)
-
-