org.axonframework.spring.messaging.eventbus

Class SpringMessagingTerminal

java.lang.Object

org.axonframework.spring.messaging.eventbus.SpringMessagingTerminal

public class SpringMessagingTerminal
extends Object

EventBus implementation that delegates all subscription and publishing requests to a Spring Messaging channel.

Use setChannel(org.springframework.messaging.SubscribableChannel) to set the channel to delegate all the requests to.

This EventBus will automatically wrap and unwrap events in Messages and EventListeners in MessageHandlers.

This implementation expects the Spring Messaging to be configured to handle messages asynchronously.

Since:

2.3.1

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
SpringMessagingTerminal(org.axonframework.eventhandling.EventBus eventBus)

Method Summary

Modifier and Type	Method and Description
protected void	send(List<? extends org.axonframework.eventhandling.EventMessage<?>> events)
void	setChannel(org.springframework.messaging.SubscribableChannel channel) Sets the Spring Messaging Channel that this event bus should publish events to.
void	shutDown()
void	start()
org.axonframework.common.Registration	subscribe(Consumer<List<? extends org.axonframework.eventhandling.EventMessage<?>>> eventProcessor)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpringMessagingTerminal

public SpringMessagingTerminal(org.axonframework.eventhandling.EventBus eventBus)

Method Detail

start

public void start()

shutDown

public void shutDown()

send

protected void send(List<? extends org.axonframework.eventhandling.EventMessage<?>> events)

subscribe

public org.axonframework.common.Registration subscribe(Consumer<List<? extends org.axonframework.eventhandling.EventMessage<?>>> eventProcessor)

setChannel

public void setChannel(org.springframework.messaging.SubscribableChannel channel)

Sets the Spring Messaging Channel that this event bus should publish events to.

Parameters:

channel - the channel to publish events to