|
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 | |
---|---|
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 | |
---|---|
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.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 |
AbstractMessageListenerContainer.rollbackOnExceptionIfNecessary(com.rabbitmq.client.Channel channel,
Message message,
Throwable ex)
Perform a rollback, handling rollback exceptions properly. |
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.support |
---|
Methods in org.springframework.amqp.rabbit.support with parameters of type Message | |
---|---|
static com.rabbitmq.client.AMQP.BasicProperties |
RabbitUtils.extractBasicProperties(Message message,
String charset)
|
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 |
MessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Convert a Java object to a Rabbit Message. |
Message |
SerializerMessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Creates an AMQP Message from the provided Object. |
Message |
MarshallingMessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Marshals the given object to a Message . |
Message |
SimpleMessageConverter.toMessage(Object object,
MessageProperties messageProperties)
Creates an AMQP Message from the provided Object. |
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 Rabbit GetResponse 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. |
|
Spring AMQP | |||||||||
PREV NEXT | FRAMES NO FRAMES |