|
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()
|
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 |
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 |
MarshallingMessageConverter.createMessage(Object object,
MessageProperties messageProperties)
Marshals the given object to a Message . |
protected Message |
JsonMessageConverter.createMessage(Object objectToConvert,
MessageProperties messageProperties)
|
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 |
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 |
MarshallingMessageConverter.fromMessage(Message message)
Unmarshals the given Message into an object. |
Object |
JsonMessageConverter.fromMessage(Message message)
|
abstract Object |
AbstractMessageConverter.fromMessage(Message message)
|
|
Spring AMQP | |||||||||
PREV NEXT | FRAMES NO FRAMES |