Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger
logger
|
ConcurrentLinkedQueue<ProxyMessage> |
queue |
boolean |
running |
ProxyMessageSender |
sender |
Constructor and Description |
---|
QueueWorker() |
public static org.objectweb.util.monolog.api.Logger logger
public ConcurrentLinkedQueue<ProxyMessage> queue
public boolean running
public ProxyMessageSender sender
private void handleMessage(ProxyMessage msg) throws Exception
Exception
public void send(ProxyMessage msg)
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.