Package | Description |
---|---|
org.springframework.amqp.core |
Provides core classes for the spring AMQP abstraction.
|
org.springframework.amqp.rabbit.core |
Provides core classes for Spring Rabbit.
|
org.springframework.amqp.rabbit.listener |
Provides classes for message listener containers.
|
org.springframework.amqp.rabbit.listener.adapter |
Provides classes for adapting listeners.
|
org.springframework.amqp.rabbit.retry |
Provides classes supporting retries.
|
org.springframework.amqp.remoting.service |
Provides classes for the service side of Spring Remoting over AMQP.
|
org.springframework.amqp.support.converter |
Provides classes for supporting message conversion.
|
Modifier and Type | Method and Description |
---|---|
Message |
MessageBuilder.build() |
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.
|
Modifier and Type | Method and Description |
---|---|
static MessageBuilder |
MessageBuilder.fromClonedMessage(Message message)
The final message will have a copy of the message
body, the MessageProperties will be cloned (top level only).
|
static MessageBuilder |
MessageBuilder.fromMessage(Message message)
The final message body will be a direct reference to the message
body, the MessageProperties will be a shallow copy.
|
Address |
ReplyToAddressCallback.getReplyToAddress(Message request,
T reply) |
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.
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
Message |
ListenerExecutionFailedException.getFailedMessage() |
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
protected Exception |
AbstractMessageListenerContainer.wrapToListenerExecutionFailedExceptionIfNeeded(Exception e,
Message message) |
Constructor and Description |
---|
ListenerExecutionFailedException(String msg,
Throwable cause,
Message failedMessage)
Constructor for ListenerExecutionFailedException.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
protected Object |
MessageListenerAdapter.invokeListenerMethod(String methodName,
Object[] arguments,
Message originalMessage)
Invoke the specified listener method.
|
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 before sending 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.
|
Modifier and Type | Method and Description |
---|---|
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 |
RejectAndDontRequeueRecoverer.recover(Message message,
Throwable cause) |
void |
RepublishMessageRecoverer.recover(Message message,
Throwable cause) |
void |
MessageRecoverer.recover(Message message,
Throwable cause)
Callback for message that was consumed but failed all retry attempts.
|
Modifier and Type | Method and Description |
---|---|
void |
AmqpInvokerServiceExporter.onMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
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 . |
protected Message |
Jackson2JsonMessageConverter.createMessage(Object objectToConvert,
MessageProperties messageProperties) |
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 |
AbstractMessageConverter.toMessage(Object object,
MessageProperties messageProperties) |
Message |
MessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Convert a Java object to a Message.
|
Modifier and Type | Method and Description |
---|---|
Object |
SerializerMessageConverter.fromMessage(Message message)
Converts from a AMQP Message to an Object.
|
Object |
JsonMessageConverter.fromMessage(Message message) |
Object |
MarshallingMessageConverter.fromMessage(Message message)
Unmarshals the given
Message into an object. |
Object |
Jackson2JsonMessageConverter.fromMessage(Message message) |
Object |
SimpleMessageConverter.fromMessage(Message message)
Converts from a AMQP Message to an Object.
|
abstract Object |
AbstractMessageConverter.fromMessage(Message message) |
Object |
MessageConverter.fromMessage(Message message)
Convert from a Message to a Java object.
|
Copyright © 2019. All rights reserved.