Uses of Class
org.apache.qpid.client.failover.FailoverException

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.
 



Licensed to the Apache Software Foundation