Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.protocol | |
org.apache.qpid.client.state | |
org.apache.qpid.protocol | |
org.apache.qpid.server.protocol.v0_8 |
Modifier and Type | Method and Description |
---|---|
AMQMethodEvent |
AMQProtocolHandler.syncWrite(AMQFrame frame,
Class responseClass)
More convenient method to write a frame and wait for it's response.
|
AMQMethodEvent |
AMQProtocolHandler.syncWrite(AMQFrame frame,
Class responseClass,
long timeout)
More convenient method to write a frame and wait for it's response.
|
AMQMethodEvent |
AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQDataBlock frame,
BlockingMethodFrameListener listener)
Convenience method that writes a frame to the protocol session and waits for a particular response.
|
AMQMethodEvent |
AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQDataBlock frame,
BlockingMethodFrameListener listener,
long timeout)
Convenience method that writes a frame to the protocol session and waits for a particular response.
|
Modifier and Type | Method and Description |
---|---|
AMQMethodEvent |
BlockingMethodFrameListener.blockForFrame(long timeout)
Blocks until a method is received that is handled by the delegated to method listener, or the specified timeout
has passed.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BlockingMethodFrameListener.methodReceived(AMQMethodEvent evt)
Informs this listener that an AMQP method has been received.
|
boolean |
BlockingMethodFrameListener.process(AMQMethodEvent evt) |
Modifier and Type | Method and Description |
---|---|
<B extends AMQMethodBody> |
AMQStateManager.methodReceived(AMQMethodEvent<B> evt) |
Modifier and Type | Method and Description |
---|---|
<B extends AMQMethodBody> |
AMQMethodListener.methodReceived(AMQMethodEvent<B> evt)
Notifies the listener that an AMQP method event has occurred.
|
Constructor and Description |
---|
AMQNoMethodHandlerException(AMQMethodEvent<AMQMethodBody> evt) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.