axon-amqp
module is available on the classpath.SpringAMQPPublisher
forwards events to an AMQP exchange. It is initialized with a SubscribableMessageSource
, which is generally the EventBus
or EventStore
. Theoretically, this could be any source of events that the publisher can subscribe to.application.properties
configuration is sufficient:axon.amqp.transaction-mode
property, and setting it to transactional
or publisher-ack
.NoteNote that exchanges are not automatically created. You must still declare the Queues, Exchanges and Bindings you wish to use. Check the Spring documentation for more information.
SpringAMQPMessageSource
allows event processors to read messages from a queue instead of the event store or event bus. It acts as an adapter between Spring AMQP and the SubscribableMessageSource
needed by these processors.SpringAMQPMessageSource
:SpringAMQPMessageSource
.