public class DirectDeliveryHandler extends Object implements MessageDeliveryHandler, Wakeable, DirectChannel
Modifier and Type | Method and Description |
---|---|
static MessageDeliveryHandler |
createFor(QueueChannel channel) |
boolean |
deliver(MessageQueue queue,
Message message)
This method is responsible for delivering a message into the transport layer.
|
boolean |
isConnected() |
void |
noop(MessageQueue queue)
Sends a NOOP (No-Operation) to the remote connected
|
void |
onWake(MessageQueue queue) |
public static MessageDeliveryHandler createFor(QueueChannel channel)
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 onWake(MessageQueue queue) throws IOException
onWake
in interface Wakeable
IOException
public void noop(MessageQueue queue) throws IOException
MessageDeliveryHandler
noop
in interface MessageDeliveryHandler
IOException
public boolean isConnected()
isConnected
in interface DirectChannel
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.