Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.message | |
org.apache.qpid.client.protocol |
Modifier and Type | Method and Description |
---|---|
void |
AMQSession.dispatch(UnprocessedMessage message) |
void |
AMQSession_0_8.messageReceived(UnprocessedMessage message) |
void |
AMQSession.messageReceived(UnprocessedMessage message)
Invoked by the MINA IO thread (indirectly) when a message is received from the transport.
|
void |
AMQSession.rejectMessage(UnprocessedMessage message,
boolean requeue) |
Modifier and Type | Class and Description |
---|---|
class |
CloseConsumerMessage |
class |
ReturnMessage |
class |
UnprocessedMessage_0_10
This class contains everything needed to process a JMS message.
|
class |
UnprocessedMessage_0_8
This class contains everything needed to process a JMS message.
|
Modifier and Type | Method and Description |
---|---|
void |
AMQProtocolSession.unprocessedMessageReceived(int channelId,
UnprocessedMessage message)
Callback invoked from the BasicDeliverMethodHandler when a message has been received.
|
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.