axon-amqpmodule is available on the classpath.
SpringAMQPPublisherforwards events to an AMQP exchange. It is initialized with a
SubscribableMessageSource, which is generally the
EventStore. Theoretically, this could be any source of events that the publisher can subscribe to.
application.propertiesconfiguration is sufficient:
axon.amqp.transaction-modeproperty, and setting it to
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.
SpringAMQPMessageSourceallows 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
SubscribableMessageSourceneeded by these processors.