org.axonframework.amqp.eventhandling.spring

Class SpringAMQPMessageSource

java.lang.Object

org.axonframework.amqp.eventhandling.spring.SpringAMQPMessageSource

All Implemented Interfaces:

SubscribableMessageSource<EventMessage<?>>, org.springframework.amqp.rabbit.core.ChannelAwareMessageListener

public class SpringAMQPMessageSource
extends Object
implements org.springframework.amqp.rabbit.core.ChannelAwareMessageListener, SubscribableMessageSource<EventMessage<?>>

MessageListener implementation that deserializes incoming messages and forwards them to one or more event processors.

The SpringAMQPMessageSource must be registered with a Spring MessageListenerContainer and forwards each message to all subscribed processors.

Note that the Processors must be subscribed before the MessageListenerContainer is started. Otherwise, messages will be consumed from the AMQP Queue without any processor processing them.

Since:

3.0

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
SpringAMQPMessageSource(AMQPMessageConverter messageConverter) Initializes an SpringAMQPMessageSource with given messageConverter to convert the incoming AMQP message into an EventMessage.
SpringAMQPMessageSource(Serializer serializer) Initializes an SpringAMQPMessageSource with DefaultAMQPMessageConverter using given serializer.

Method Summary

Modifier and Type	Method and Description
void	onMessage(org.springframework.amqp.core.Message message, com.rabbitmq.client.Channel channel)
Registration	subscribe(Consumer<List<? extends EventMessage<?>>> messageProcessor) Subscribe the given messageProcessor to this message source.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpringAMQPMessageSource

public SpringAMQPMessageSource(Serializer serializer)

Initializes an SpringAMQPMessageSource with DefaultAMQPMessageConverter using given serializer.

Parameters:

serializer - The serializer to serialize payload and metadata of events

SpringAMQPMessageSource

public SpringAMQPMessageSource(AMQPMessageConverter messageConverter)

Initializes an SpringAMQPMessageSource with given messageConverter to convert the incoming AMQP message into an EventMessage.

Parameters:

messageConverter - The message converter to use to convert AMQP Messages to Event Messages

Method Detail

subscribe

public Registration subscribe(Consumer<List<? extends EventMessage<?>>> messageProcessor)

Description copied from interface: SubscribableMessageSource

Subscribe the given messageProcessor to this message source. When subscribed, it will receive all messages published to this source.

If the given messageProcessor is already subscribed, nothing happens.

Specified by:

subscribe in interface SubscribableMessageSource<EventMessage<?>>

Parameters:

messageProcessor - The message processor to subscribe

Returns:

a handle to unsubscribe the messageProcessor. When unsubscribed it will no longer receive messages.

onMessage

public void onMessage(org.springframework.amqp.core.Message message,
                      com.rabbitmq.client.Channel channel)
               throws Exception

Specified by:

onMessage in interface org.springframework.amqp.rabbit.core.ChannelAwareMessageListener

Throws:

Exception