|
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 |
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. |
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. |
| 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)
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 Message in org.springframework.amqp.rabbit.core |
|---|
| Methods in org.springframework.amqp.rabbit.core that return Message | |
|---|---|
protected Message |
RabbitTemplate.convertMessageIfNecessary(Object object)
|
protected Message |
RabbitTemplate.doSendAndReceive(String exchange,
String routingKey,
Message message)
Send a message and wait for a reply. |
protected Message |
RabbitTemplate.doSendAndReceiveWithFixed(String exchange,
String routingKey,
Message message)
|
protected Message |
RabbitTemplate.doSendAndReceiveWithTemporary(String exchange,
String routingKey,
Message message)
|
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,
CorrelationData correlationData)
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. |
protected Message |
RabbitTemplate.doSendAndReceiveWithFixed(String exchange,
String routingKey,
Message message)
|
protected Message |
RabbitTemplate.doSendAndReceiveWithTemporary(String exchange,
String routingKey,
Message message)
|
void |
RabbitTemplate.onMessage(Message message)
|
void |
ChannelAwareMessageListener.onMessage(Message message,
com.rabbitmq.client.Channel channel)
Callback for processing a received Rabbit message. |
void |
RabbitTemplate.ReturnCallback.returnedMessage(Message message,
int replyCode,
String replyText,
String exchange,
String routingKey)
|
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 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 |
AbstractMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel,
Message message)
Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener. |
protected void |
SimpleMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel,
Message message)
|
void |
SimpleMessageListenerContainer.ContainerDelegate.invokeListener(com.rabbitmq.client.Channel channel,
Message message)
|
| 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 abstract Message |
AbstractMessageConverter.createMessage(Object object,
MessageProperties messageProperties)
Crate a message from the payload object and message properties provided. |
protected Message |
SimpleMessageConverter.createMessage(Object object,
MessageProperties messageProperties)
Creates an AMQP Message from the provided Object. |
protected Message |
SerializerMessageConverter.createMessage(Object object,
MessageProperties messageProperties)
Creates an AMQP Message from the provided Object. |
protected Message |
JsonMessageConverter.createMessage(Object objectToConvert,
MessageProperties messageProperties)
|
protected Message |
MarshallingMessageConverter.createMessage(Object object,
MessageProperties messageProperties)
Marshals the given object to a Message. |
Message |
AbstractMessageConverter.toMessage(Object object,
MessageProperties messageProperties)
|
Message |
MessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Convert a Java object to a Message. |
| Methods in org.springframework.amqp.support.converter with parameters of type Message | |
|---|---|
abstract Object |
AbstractMessageConverter.fromMessage(Message message)
|
Object |
SimpleMessageConverter.fromMessage(Message message)
Converts from a AMQP Message to an Object. |
Object |
SerializerMessageConverter.fromMessage(Message message)
Converts from a AMQP Message to an Object. |
Object |
MessageConverter.fromMessage(Message message)
Convert from a Message to a Java object. |
Object |
JsonMessageConverter.fromMessage(Message message)
|
Object |
MarshallingMessageConverter.fromMessage(Message message)
Unmarshals the given Message into an object. |
|
Spring AMQP | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||