public class BufferDeliveryHandler extends Object implements MessageDeliveryHandler, Buffered, Cleanable
MessageDeliveryHandler
facilitates the buffering of all inbound message
traffic to a singular ring-buffer.Modifier and Type | Method and Description |
---|---|
void |
clean(MessageQueue queue) |
boolean |
copyFromBuffer(MessageQueue queue,
ByteWriteAdapter toAdapter) |
boolean |
copyFromBuffer(TimeUnit timeUnit,
int timeout,
MessageQueue queue,
ByteWriteAdapter toAdapter) |
boolean |
deliver(MessageQueue queue,
Message message)
This method is responsible for delivering a message into the transport layer.
|
static BufferDeliveryHandler |
getInstance() |
void |
noop(MessageQueue queue)
Sends a NOOP (No-Operation) to the remote connected
|
public static BufferDeliveryHandler getInstance()
public boolean deliver(MessageQueue queue, Message message) throws IOException
MessageDeliveryHandler
deliver
in interface MessageDeliveryHandler
queue
- the MessageQueue
to deliver from.message
- the Message
to deliver.IOException
- an IOException may be thrown if there is a problem interacting with the underlying transport.public void noop(MessageQueue queue) throws IOException
MessageDeliveryHandler
noop
in interface MessageDeliveryHandler
IOException
public void clean(MessageQueue queue)
public boolean copyFromBuffer(MessageQueue queue, ByteWriteAdapter toAdapter) throws IOException
copyFromBuffer
in interface Buffered
IOException
public boolean copyFromBuffer(TimeUnit timeUnit, int timeout, MessageQueue queue, ByteWriteAdapter toAdapter) throws IOException
copyFromBuffer
in interface Buffered
IOException
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.