Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.failover | |
org.apache.qpid.client.protocol | |
org.apache.qpid.client.util |
Modifier and Type | Method and Description |
---|---|
void |
AMQSession_0_8.commitImpl() |
void |
AMQSession_0_10.commitImpl() |
protected abstract void |
AMQSession.commitImpl() |
protected Long |
AMQSession_0_8.requestQueueDepth(AMQDestination amqd,
boolean sync) |
protected abstract Long |
AMQSession.requestQueueDepth(AMQDestination amqd,
boolean sync) |
void |
AMQConnectionDelegate.resubscribeSessions() |
void |
AMQConnectionDelegate_0_10.resubscribeSessions() |
void |
AMQConnection.resubscribeSessions() |
void |
AMQConnectionDelegate_8_0.resubscribeSessions()
For all sessions, and for all consumers in those sessions, resubscribe.
|
void |
AMQSession_0_8.sendClose(long timeout) |
void |
AMQSession_0_10.sendClose(long timeout)
Close this session.
|
abstract void |
AMQSession.sendClose(long timeout) |
void |
AMQSession_0_10.sendConsume(BasicMessageConsumer_0_10 consumer,
String queueName,
boolean nowait,
int tag)
This method is invoked when a consumer is created
Registers the consumer with the broker
|
void |
AMQSession_0_8.sendConsume(BasicMessageConsumer_0_8 consumer,
String queueName,
boolean nowait,
int tag) |
abstract void |
AMQSession.sendConsume(C consumer,
String queueName,
boolean nowait,
int tag) |
void |
AMQSession_0_8.sendCreateQueue(String name,
boolean autoDelete,
boolean durable,
boolean exclusive,
Map<String,Object> arguments) |
void |
AMQSession_0_10.sendCreateQueue(String name,
boolean autoDelete,
boolean durable,
boolean exclusive,
Map<String,Object> arguments)
Create a queue with a given name.
|
abstract void |
AMQSession.sendCreateQueue(String name,
boolean autoDelete,
boolean durable,
boolean exclusive,
Map<String,Object> arguments) |
void |
AMQSession_0_8.sendExchangeDeclare(String name,
String type,
boolean nowait,
boolean durable,
boolean autoDelete,
boolean internal) |
void |
AMQSession_0_10.sendExchangeDeclare(String name,
String type,
boolean nowait,
boolean durable,
boolean autoDelete,
boolean internal)
creates an exchange if it does not already exist
|
abstract void |
AMQSession.sendExchangeDeclare(String name,
String type,
boolean nowait,
boolean durable,
boolean autoDelete,
boolean internal) |
void |
AMQSession_0_8.sendExchangeDeclare(String name,
String type,
boolean nowait,
boolean durable,
boolean autoDelete,
Map<String,Object> arguments,
boolean passive) |
void |
AMQSession_0_10.sendExchangeDeclare(String name,
String type,
boolean nowait,
boolean durable,
boolean autoDelete,
Map<String,Object> arguments,
boolean passive) |
abstract void |
AMQSession.sendExchangeDeclare(String name,
String type,
boolean nowait,
boolean durable,
boolean autoDelete,
Map<String,Object> arguments,
boolean passive) |
void |
AMQSession_0_8.sendExchangeDelete(String name,
boolean nowait) |
void |
AMQSession_0_10.sendExchangeDelete(String name,
boolean nowait)
deletes an exchange
|
void |
AMQSession_0_8.sendQueueBind(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination,
boolean nowait) |
abstract void |
AMQSession.sendQueueBind(String queueName,
String routingKey,
Map<String,Object> arguments,
String exchangeName,
AMQDestination destination,
boolean nowait) |
void |
AMQSession_0_8.sendQueueDelete(String queueName) |
void |
AMQSession_0_10.sendQueueDelete(String queueName)
deletes a queue
|
abstract void |
AMQSession.sendQueueDelete(String queueName) |
void |
AMQSession_0_8.sendRecover() |
void |
AMQSession_0_10.sendRecover()
This method asks the broker to redeliver all unacknowledged messages
|
protected abstract void |
AMQSession.sendRecover() |
void |
AMQSession_0_8.sendRollback() |
void |
AMQSession_0_10.sendRollback() |
abstract void |
AMQSession.sendRollback() |
void |
AMQSession_0_8.sendSuspendChannel(boolean suspend) |
void |
AMQSession_0_10.sendSuspendChannel(boolean suspend)
Activate/deactivate the message flow for all the consumers of this session.
|
abstract void |
AMQSession.sendSuspendChannel(boolean suspend) |
void |
AMQSession_0_8.setPrefetchLimits(int messagePrefetch,
long sizePrefetch) |
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 |
---|---|
T |
FailoverProtectedOperation.execute()
Performs the continuations work.
|
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 |
---|---|
Object |
BlockingWaiter.block(long timeout)
Blocks until an object is received that is handled by process, or the specified timeout
has passed.
|
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.