Modifier and Type | Field and Description |
---|---|
static Logger |
logger |
ConcurrentLinkedQueue<ProxyMessage> |
queue |
boolean |
running |
ProxyMessageSender |
sender |
Constructor and Description |
---|
QueueWorker() |
Modifier and Type | Method and Description |
---|---|
private void |
handleMessage(ProxyMessage msg) |
void |
run() |
void |
send(ProxyMessage msg) |
public static 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 © 2023 ScalAgent D.T.. All rights reserved.