Spring AMQP

Uses of Class
org.springframework.amqp.AmqpException

Packages that use AmqpException
org.springframework.amqp   
org.springframework.amqp.core   
org.springframework.amqp.rabbit.connection   
org.springframework.amqp.rabbit.core   
org.springframework.amqp.rabbit.listener   
 

Uses of AmqpException in org.springframework.amqp
 

Subclasses of AmqpException in org.springframework.amqp
 class AmqpConnectException
          RuntimeException wrapper for an ConnectException which can be commonly thrown from AMQP operations if the remote process dies or there is a network issue.
 class AmqpIllegalStateException
          Equivalent of an IllegalStateException but within the AmqpException hierarchy.
 class AmqpIOException
          RuntimeException wrapper for an IOException which can be commonly thrown from AMQP operations.
 class AmqpRejectAndDontRequeueException
          Exception for listener implementations used to indicate the basic.reject will be sent with requeue=false in order to enable features such as DLQ.
 class AmqpUnsupportedEncodingException
          RuntimeException for unsupported encoding in an AMQP operation.
 class ImmediateAcknowledgeAmqpException
          Special exception for listener implementations that want to signal that the current batch of messages should be acknowledged immediately (i.e. as soon as possible) without rollback, and without consuming any more messages.
 class UncategorizedAmqpException
          A "catch-all" exception type within the AmqpException hierarchy when no more specific cause is known.
 

Uses of AmqpException in org.springframework.amqp.core
 

Methods in org.springframework.amqp.core that throw AmqpException
 void AmqpTemplate.convertAndSend(Object message)
          Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
 void AmqpTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)
          Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.
 void AmqpTemplate.convertAndSend(String routingKey, Object message)
          Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
 void AmqpTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
          Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.
 void AmqpTemplate.convertAndSend(String exchange, String routingKey, Object message)
          Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
 void AmqpTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
          Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.
 Object AmqpTemplate.convertSendAndReceive(Object message)
          Basic RPC pattern with conversion.
 Object AmqpTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)
          Basic RPC pattern with conversion.
 Object AmqpTemplate.convertSendAndReceive(String routingKey, Object message)
          Basic RPC pattern with conversion.
 Object AmqpTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
          Basic RPC pattern with conversion.
 Object AmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message)
          Basic RPC pattern with conversion.
 Object AmqpTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
          Basic RPC pattern with conversion.
 Message MessagePostProcessor.postProcessMessage(Message message)
           
 Message AmqpTemplate.receive()
          Receive a message if there is one from a default queue.
 Message AmqpTemplate.receive(String queueName)
          Receive a message if there is one from a specific queue.
 Object AmqpTemplate.receiveAndConvert()
          Receive a message if there is one from a default queue and convert it to a Java object.
 Object AmqpTemplate.receiveAndConvert(String queueName)
          Receive a message if there is one from a specific queue and convert it to a Java object.
 void AmqpTemplate.send(Message message)
          Send a message to a default exchange with a default routing key.
 void AmqpTemplate.send(String routingKey, Message message)
          Send a message to a default exchange with a specific routing key.
 void AmqpTemplate.send(String exchange, String routingKey, Message message)
          Send a message to a specific exchange with a specific routing key.
 Message AmqpTemplate.sendAndReceive(Message message)
          Basic RPC pattern.
 Message AmqpTemplate.sendAndReceive(String routingKey, Message message)
          Basic RPC pattern.
 Message AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)
          Basic RPC pattern.
 

Uses of AmqpException in org.springframework.amqp.rabbit.connection
 

Methods in org.springframework.amqp.rabbit.connection that throw AmqpException
 void Connection.close()
          Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'.
 void RabbitResourceHolder.commitAll()
           
 com.rabbitmq.client.Channel Connection.createChannel(boolean transactional)
          Create a new channel, using an internally allocated channel number.
 Connection CachingConnectionFactory.createConnection()
           
 Connection ConnectionFactory.createConnection()
           
 

Uses of AmqpException in org.springframework.amqp.rabbit.core
 

Methods in org.springframework.amqp.rabbit.core that throw AmqpException
 void RabbitTemplate.convertAndSend(Object object)
           
 void RabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor)
           
 void RabbitTemplate.convertAndSend(String routingKey, Object object)
           
 void RabbitTemplate.convertAndSend(String routingKey, Object object, CorrelationData correlationData)
           
 void RabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
           
 void RabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
           
 void RabbitTemplate.convertAndSend(String exchange, String routingKey, Object object)
           
 void RabbitTemplate.convertAndSend(String exchange, String routingKey, Object object, CorrelationData corrationData)
           
 void RabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
           
 void RabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)
           
 Object RabbitTemplate.convertSendAndReceive(Object message)
           
 Object RabbitTemplate.convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)
           
 Object RabbitTemplate.convertSendAndReceive(String routingKey, Object message)
           
 Object RabbitTemplate.convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
           
 Object RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message)
           
 Object RabbitTemplate.convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
           
 void RabbitTemplate.correlationconvertAndSend(Object object, CorrelationData correlationData)
           
<T> T
RabbitOperations.execute(ChannelCallback<T> action)
           
 Message RabbitTemplate.receive()
           
 Object RabbitTemplate.receiveAndConvert()
           
 Object RabbitTemplate.receiveAndConvert(String queueName)
           
 void RabbitTemplate.send(Message message)
           
 void RabbitTemplate.send(String routingKey, Message message)
           
 void RabbitTemplate.send(String exchange, String routingKey, Message message)
           
 void RabbitTemplate.send(String exchange, String routingKey, Message message, CorrelationData correlationData)
           
 Message RabbitTemplate.sendAndReceive(Message message)
           
 Message RabbitTemplate.sendAndReceive(String routingKey, Message message)
           
 Message RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
           
 

Uses of AmqpException in org.springframework.amqp.rabbit.listener
 

Subclasses of AmqpException in org.springframework.amqp.rabbit.listener
 class FatalListenerExecutionException
          Exception to be thrown when the execution of a listener method failed unrecoverably.
 class FatalListenerStartupException
          Exception to be thrown when the execution of a listener method failed on startup.
 class ListenerExecutionFailedException
          Exception to be thrown when the execution of a listener method failed.
 class MessageRejectedWhileStoppingException
          Exception class that indicates a rejected message on shutdown.
 

Methods in org.springframework.amqp.rabbit.listener that throw AmqpException
 void BlockingQueueConsumer.start()
           
 


Spring AMQP

Copyright © 2012. All Rights Reserved.