MessageManager
- Enqueue messages for send-q and receive-q respectively
This commit is contained in:
parent
b698576bce
commit
62c35787e3
|
@ -95,11 +95,17 @@ public class MessageManager
|
||||||
public void sendq(Message message)
|
public void sendq(Message message)
|
||||||
{
|
{
|
||||||
logger.info("Received message for sending: ", message);
|
logger.info("Received message for sending: ", message);
|
||||||
|
|
||||||
|
// Enqueue to send-q
|
||||||
|
this.sendQueue.enqueue(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void recvq(Message message)
|
public void recvq(Message message)
|
||||||
{
|
{
|
||||||
|
logger.info("Received message for reception: ", message);
|
||||||
|
|
||||||
|
// Enqueue to recv-q
|
||||||
|
this.receiveQueue.enqueue(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
public static MessageManager create(MessageDeliveryTransport transport)
|
public static MessageManager create(MessageDeliveryTransport transport)
|
||||||
|
|
Loading…
Reference in New Issue