|
Spring AMQP | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of Message in org.springframework.amqp.core |
|---|
| Methods in org.springframework.amqp.core that return Message | |
|---|---|
Message |
MessageCreator.createMessage()
Create a Message to be sent. |
Message |
MessagePostProcessor.postProcessMessage(Message message)
|
Message |
AmqpTemplate.receive()
|
Message |
AmqpTemplate.receive(String queueName)
|
| Methods in org.springframework.amqp.core with parameters of type Message | |
|---|---|
void |
MessageListener.onMessage(Message message)
|
Message |
MessagePostProcessor.postProcessMessage(Message message)
|
| Uses of Message in org.springframework.amqp.rabbit.core |
|---|
| Classes in org.springframework.amqp.rabbit.core with type parameters of type Message | |
|---|---|
interface |
ChannelAwareMessageListener<M extends Message>
A message listener that is aware of the Channel on which the message was received. |
| Methods in org.springframework.amqp.rabbit.core that return Message | |
|---|---|
Message |
RabbitTemplate.receive()
|
Message |
RabbitTemplate.receive(String queueName)
|
| Uses of Message in org.springframework.amqp.rabbit.listener |
|---|
| Methods in org.springframework.amqp.rabbit.listener with parameters of type Message | |
|---|---|
protected void |
AbstractMessageListenerContainer.commitIfNecessary(com.rabbitmq.client.Channel channel,
Message message)
Perform a commit or message acknowledgement, as appropriate. |
protected void |
AbstractMessageListenerContainer.doExecuteListener(com.rabbitmq.client.Channel channel,
Message message)
Execute the specified listener, committing or rolling back the transaction afterwards (if necessary). |
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 |
AbstractMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel,
Message message)
Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener. |
protected void |
SimpleMessageListenerContainer.processMessage(Message message,
com.rabbitmq.client.Channel channel)
|
| 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 String |
MessageListenerAdapter.getResponseReplyTo(Message request,
Message response,
com.rabbitmq.client.Channel channel)
Determine a response destination 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 SessionAwareMessageListener 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,
String receivedExchange,
String replyTo,
Message message)
Send the given response message to the given destination. |
| Uses of Message in org.springframework.amqp.rabbit.support |
|---|
| Methods in org.springframework.amqp.rabbit.support with parameters of type Message | |
|---|---|
static com.rabbitmq.client.AMQP.BasicProperties |
RabbitUtils.extractBasicProperties(Message message,
String encoding)
|
| Uses of Message in org.springframework.amqp.support.converter |
|---|
| Methods in org.springframework.amqp.support.converter that return Message | |
|---|---|
Message |
JsonMessageConverter.toMessage(Object objectToConvert,
MessageProperties messageProperties)
|
Message |
SimpleMessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Creates a Rabbit Mesasge from the provided Object. |
Message |
MessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Convert a Java object to a Rabbit Message. |
Message |
MarshallingMessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Marshals the given object to a Message. |
| Methods in org.springframework.amqp.support.converter with parameters of type Message | |
|---|---|
Object |
JsonMessageConverter.fromMessage(Message message)
|
Object |
SimpleMessageConverter.fromMessage(Message message)
Converts from a Rabbit Message to an Object. |
Object |
MessageConverter.fromMessage(Message message)
Convert from a Rabbit GetResponse to a Java object. |
Object |
MarshallingMessageConverter.fromMessage(Message message)
Unmarshals the given Message into an object. |
|
Spring AMQP | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||