Spring AMQP

Uses of Class
org.springframework.amqp.core.Message

Packages that use Message
org.springframework.amqp.core   
org.springframework.amqp.rabbit.core   
org.springframework.amqp.rabbit.listener   
org.springframework.amqp.rabbit.listener.adapter   
org.springframework.amqp.rabbit.retry   
org.springframework.amqp.support.converter   
 

Uses of Message in org.springframework.amqp.core
 

Methods in org.springframework.amqp.core that return Message
 Message MessagePostProcessor.postProcessMessage(Message message)
           
 Message AmqpTemplate.receive()
           
 Message AmqpTemplate.receive(String queueName)
           
 Message AmqpTemplate.sendAndReceive(Message message)
           
 Message AmqpTemplate.sendAndReceive(String routingKey, Message message)
           
 Message AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)
           
 

Methods in org.springframework.amqp.core with parameters of type Message
 void MessageListener.onMessage(Message message)
           
 Message MessagePostProcessor.postProcessMessage(Message message)
           
 void AmqpTemplate.send(Message message)
           
 void AmqpTemplate.send(String routingKey, Message message)
           
 void AmqpTemplate.send(String exchange, String routingKey, Message message)
           
 Message AmqpTemplate.sendAndReceive(Message message)
           
 Message AmqpTemplate.sendAndReceive(String routingKey, Message message)
           
 Message AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)
           
 

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

Methods in org.springframework.amqp.rabbit.core that return Message
protected  Message RabbitTemplate.doSendAndReceive(String exchange, String routingKey, Message message)
          Send a message and wait for a reply.
 Message RabbitTemplate.receive()
           
 Message RabbitTemplate.receive(String queueName)
           
 Message RabbitTemplate.sendAndReceive(Message message)
           
 Message RabbitTemplate.sendAndReceive(String routingKey, Message message)
           
 Message RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
           
 

Methods in org.springframework.amqp.rabbit.core with parameters of type Message
protected  void RabbitTemplate.doSend(com.rabbitmq.client.Channel channel, String exchange, String routingKey, Message message)
          Send the given message to the specified exchange.
protected  Message RabbitTemplate.doSendAndReceive(String exchange, String routingKey, Message message)
          Send a message and wait for a reply.
 void ChannelAwareMessageListener.onMessage(Message message, com.rabbitmq.client.Channel channel)
          Callback for processing a received Rabbit message.
 void RabbitTemplate.send(Message message)
           
 void RabbitTemplate.send(String routingKey, Message message)
           
 void RabbitTemplate.send(String exchange, String routingKey, Message message)
           
 Message RabbitTemplate.sendAndReceive(Message message)
           
 Message RabbitTemplate.sendAndReceive(String routingKey, Message message)
           
 Message RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
           
 

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

Methods in org.springframework.amqp.rabbit.listener that return Message
 Message BlockingQueueConsumer.nextMessage()
          Main application-side API: wait for the next message delivery and return it.
 Message BlockingQueueConsumer.nextMessage(long timeout)
          Main application-side API: wait for the next message delivery and return it.
 

Methods in org.springframework.amqp.rabbit.listener with parameters of type Message
protected  void AbstractMessageListenerContainer.doInvokeListener(ChannelAwareMessageListener listener, com.rabbitmq.client.Channel channel, Message message)
          Invoke the specified listener as Spring ChannelAwareMessageListener, exposing a new Rabbit Session (potentially with its own transaction) to the listener if demanded.
protected  void AbstractMessageListenerContainer.doInvokeListener(MessageListener listener, Message message)
          Invoke the specified listener as Spring Rabbit MessageListener.
protected  void AbstractMessageListenerContainer.executeListener(com.rabbitmq.client.Channel channel, Message message)
          Execute the specified listener, committing or rolling back the transaction afterwards (if necessary).
protected  void SimpleMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel, Message message)
           
 void SimpleMessageListenerContainer.ContainerDelegate.invokeListener(com.rabbitmq.client.Channel channel, Message message)
           
protected  void AbstractMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel, Message message)
          Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener.
 

Uses of Message in org.springframework.amqp.rabbit.listener.adapter
 

Methods in org.springframework.amqp.rabbit.listener.adapter that return Message
protected  Message MessageListenerAdapter.buildMessage(com.rabbitmq.client.Channel session, Object result)
          Build a Rabbit message to be sent as response based on the given result object.
 

Methods in org.springframework.amqp.rabbit.listener.adapter with parameters of type Message
protected  Object MessageListenerAdapter.extractMessage(Message message)
          Extract the message body from the given Rabbit message.
protected  String MessageListenerAdapter.getListenerMethodName(Message originalMessage, Object extractedMessage)
          Determine the name of the listener method that is supposed to handle the given message.
protected  String MessageListenerAdapter.getReceivedExchange(Message request)
           
protected  Address MessageListenerAdapter.getReplyToAddress(Message request)
          Determine a reply-to Address for the given message.
protected  void MessageListenerAdapter.handleResult(Object result, Message request, com.rabbitmq.client.Channel channel)
          Handle the given result object returned from the listener method, sending a response message back.
 void MessageListenerAdapter.onMessage(Message message)
          Rabbit MessageListener entry point.
 void MessageListenerAdapter.onMessage(Message message, com.rabbitmq.client.Channel channel)
          Spring ChannelAwareMessageListener entry point.
protected  void MessageListenerAdapter.postProcessChannel(com.rabbitmq.client.Channel channel, Message response)
          Post-process the given message producer before using it to send the response.
protected  void MessageListenerAdapter.postProcessResponse(Message request, Message response)
          Post-process the given response message before it will be sent.
protected  void MessageListenerAdapter.sendResponse(com.rabbitmq.client.Channel channel, Address replyTo, Message message)
          Send the given response message to the given destination.
 

Uses of Message in org.springframework.amqp.rabbit.retry
 

Methods in org.springframework.amqp.rabbit.retry with parameters of type Message
 Object MessageKeyGenerator.getKey(Message message)
          Generate a unique key for the message that is repeatable on redelivery.
 boolean NewMessageIdentifier.isNew(Message message)
          Query a message to see if it has been seen before.
 void MessageRecoverer.recover(Message message, Throwable cause)
          Callback for message that was consumed but failed all retry attempts.
 

Uses of Message in org.springframework.amqp.support.converter
 

Methods in org.springframework.amqp.support.converter that return Message
protected  Message JsonMessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties)
           
protected  Message SerializerMessageConverter.createMessage(Object object, MessageProperties messageProperties)
          Creates an AMQP Message from the provided Object.
protected  Message MarshallingMessageConverter.createMessage(Object object, MessageProperties messageProperties)
          Marshals the given object to a Message.
protected  Message SimpleMessageConverter.createMessage(Object object, MessageProperties messageProperties)
          Creates an AMQP Message from the provided Object.
protected abstract  Message AbstractMessageConverter.createMessage(Object object, MessageProperties messageProperties)
          Crate a message from the payload object and message properties provided.
 Message MessageConverter.toMessage(Object object, MessageProperties messageProperties)
          Convert a Java object to a Message.
 Message AbstractMessageConverter.toMessage(Object object, MessageProperties messageProperties)
           
 

Methods in org.springframework.amqp.support.converter with parameters of type Message
 Object JsonMessageConverter.fromMessage(Message message)
           
 Object MessageConverter.fromMessage(Message message)
          Convert from a Message to a Java object.
 Object SerializerMessageConverter.fromMessage(Message message)
          Converts from a AMQP Message to an Object.
 Object MarshallingMessageConverter.fromMessage(Message message)
          Unmarshals the given Message into an object.
 Object SimpleMessageConverter.fromMessage(Message message)
          Converts from a AMQP Message to an Object.
abstract  Object AbstractMessageConverter.fromMessage(Message message)
           
 


Spring AMQP

Copyright © 2011. All Rights Reserved.