|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use FailoverException | |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.failover | |
org.apache.qpid.client.protocol | |
org.apache.qpid.client.util |
Uses of FailoverException in org.apache.qpid.client |
---|
Methods in org.apache.qpid.client that throw FailoverException | |
---|---|
protected abstract Long |
AMQSession.requestQueueDepth(AMQDestination amqd)
|
protected Long |
AMQSession_0_8.requestQueueDepth(AMQDestination amqd)
|
void |
AMQConnectionDelegate.resubscribeSessions()
|
void |
AMQConnectionDelegate_0_10.resubscribeSessions()
|
void |
AMQConnectionDelegate_8_0.resubscribeSessions()
For all sessions, and for all consumers in those sessions, resubscribe. |
void |
AMQConnection.resubscribeSessions()
|
(package private) abstract void |
BasicMessageConsumer.sendCancel()
|
(package private) void |
BasicMessageConsumer_0_8.sendCancel()
|
abstract void |
AMQSession.sendClose(long timeout)
|
void |
AMQSession_0_10.sendClose(long timeout)
Close this session. |
void |
AMQSession_0_8.sendClose(long timeout)
|
abstract void |
AMQSession.sendCommit()
|
void |
AMQSession_0_10.sendCommit()
Commit the receipt and the delivery of all messages exchanged by this session resources. |
void |
AMQSession_0_8.sendCommit()
|
void |
AMQSession_0_10.sendConsume(BasicMessageConsumer_0_10 consumer,
org.apache.qpid.framing.AMQShortString queueName,
AMQProtocolHandler protocolHandler,
boolean nowait,
String messageSelector,
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,
org.apache.qpid.framing.AMQShortString queueName,
AMQProtocolHandler protocolHandler,
boolean nowait,
String messageSelector,
int tag)
|
abstract void |
AMQSession.sendConsume(C consumer,
org.apache.qpid.framing.AMQShortString queueName,
AMQProtocolHandler protocolHandler,
boolean nowait,
String messageSelector,
int tag)
|
abstract void |
AMQSession.sendCreateQueue(org.apache.qpid.framing.AMQShortString name,
boolean autoDelete,
boolean durable,
boolean exclusive,
Map<String,Object> arguments)
|
void |
AMQSession_0_10.sendCreateQueue(org.apache.qpid.framing.AMQShortString name,
boolean autoDelete,
boolean durable,
boolean exclusive,
Map<String,Object> arguments)
Create a queue with a given name. |
void |
AMQSession_0_8.sendCreateQueue(org.apache.qpid.framing.AMQShortString name,
boolean autoDelete,
boolean durable,
boolean exclusive,
Map<String,Object> arguments)
|
abstract void |
AMQSession.sendExchangeDeclare(org.apache.qpid.framing.AMQShortString name,
org.apache.qpid.framing.AMQShortString type,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
void |
AMQSession_0_10.sendExchangeDeclare(org.apache.qpid.framing.AMQShortString name,
org.apache.qpid.framing.AMQShortString type,
AMQProtocolHandler protocolHandler,
boolean nowait)
creates an exchange if it does not already exist |
void |
AMQSession_0_8.sendExchangeDeclare(org.apache.qpid.framing.AMQShortString name,
org.apache.qpid.framing.AMQShortString type,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
abstract void |
AMQSession.sendQueueBind(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination destination,
boolean nowait)
|
void |
AMQSession_0_10.sendQueueBind(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination destination,
boolean nowait)
Bind a queue with an exchange. |
void |
AMQSession_0_8.sendQueueBind(org.apache.qpid.framing.AMQShortString queueName,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.FieldTable arguments,
org.apache.qpid.framing.AMQShortString exchangeName,
AMQDestination dest,
boolean nowait)
|
abstract void |
AMQSession.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
void |
AMQSession_0_10.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
Declare a queue with the given queueName |
void |
AMQSession_0_8.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
abstract void |
AMQSession.sendQueueDelete(org.apache.qpid.framing.AMQShortString queueName)
|
void |
AMQSession_0_10.sendQueueDelete(org.apache.qpid.framing.AMQShortString queueName)
deletes a queue |
void |
AMQSession_0_8.sendQueueDelete(org.apache.qpid.framing.AMQShortString queueName)
|
protected abstract void |
AMQSession.sendRecover()
|
void |
AMQSession_0_10.sendRecover()
This method asks the broker to redeliver all unacknowledged messages |
void |
AMQSession_0_8.sendRecover()
|
abstract void |
AMQSession.sendRollback()
|
void |
AMQSession_0_10.sendRollback()
|
void |
AMQSession_0_8.sendRollback()
|
abstract void |
AMQSession.sendSuspendChannel(boolean suspend)
|
void |
AMQSession_0_10.sendSuspendChannel(boolean suspend)
Activate/deactivate the message flow for all the consumers of this session. |
void |
AMQSession_0_8.sendSuspendChannel(boolean suspend)
|
Uses of FailoverException in org.apache.qpid.client.failover |
---|
Methods in org.apache.qpid.client.failover that throw FailoverException | |
---|---|
T |
FailoverProtectedOperation.execute()
Performs the continuations work. |
Uses of FailoverException in org.apache.qpid.client.protocol |
---|
Methods in org.apache.qpid.client.protocol that throw FailoverException | |
---|---|
org.apache.qpid.protocol.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. |
org.apache.qpid.protocol.AMQMethodEvent |
AMQProtocolHandler.syncWrite(org.apache.qpid.framing.AMQFrame frame,
Class responseClass)
More convenient method to write a frame and wait for it's response. |
org.apache.qpid.protocol.AMQMethodEvent |
AMQProtocolHandler.syncWrite(org.apache.qpid.framing.AMQFrame frame,
Class responseClass,
long timeout)
More convenient method to write a frame and wait for it's response. |
org.apache.qpid.protocol.AMQMethodEvent |
AMQProtocolHandler.writeCommandFrameAndWaitForReply(org.apache.qpid.framing.AMQFrame frame,
BlockingMethodFrameListener listener)
Convenience method that writes a frame to the protocol session and waits for a particular response. |
org.apache.qpid.protocol.AMQMethodEvent |
AMQProtocolHandler.writeCommandFrameAndWaitForReply(org.apache.qpid.framing.AMQFrame frame,
BlockingMethodFrameListener listener,
long timeout)
Convenience method that writes a frame to the protocol session and waits for a particular response. |
Uses of FailoverException in org.apache.qpid.client.util |
---|
Methods in org.apache.qpid.client.util that throw FailoverException | |
---|---|
Object |
BlockingWaiter.block(long timeout)
Blocks until an object is received that is handled by process, or the specified timeout has passed. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |