org.axonframework.integration.eventbus
Class SpringIntegrationEventBus

java.lang.Object
  org.axonframework.integration.eventbus.SpringIntegrationEventBus

All Implemented Interfaces:

org.axonframework.eventhandling.EventBus

public class SpringIntegrationEventBus
extends Object
implements org.axonframework.eventhandling.EventBus

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

Use setChannel(org.springframework.integration.core.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 Integration to be configured to handle messages asynchronously.

Since:

0.1

Author:

Allard Buijze

Constructor Summary

SpringIntegrationEventBus()

Method Summary

void	publish(org.axonframework.domain.EventMessage... events)
void	setChannel(org.springframework.integration.core.SubscribableChannel channel) Sets the Spring Integration Channel that this event bus should publish events to.
void	subscribe(org.axonframework.eventhandling.EventListener eventListener)
void	unsubscribe(org.axonframework.eventhandling.EventListener eventListener)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpringIntegrationEventBus

public SpringIntegrationEventBus()

Method Detail

publish

public void publish(org.axonframework.domain.EventMessage... events)

Specified by:

publish in interface org.axonframework.eventhandling.EventBus

unsubscribe

public void unsubscribe(org.axonframework.eventhandling.EventListener eventListener)

Specified by:

unsubscribe in interface org.axonframework.eventhandling.EventBus

subscribe

public void subscribe(org.axonframework.eventhandling.EventListener eventListener)

Specified by:

subscribe in interface org.axonframework.eventhandling.EventBus

setChannel

public void setChannel(org.springframework.integration.core.SubscribableChannel channel)

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

Parameters:

channel - the channel to publish events to