org.axonframework.spring.messaging.adapter

Class EventListeningMessageChannelAdapter

java.lang.Object

org.axonframework.spring.messaging.adapter.EventListeningMessageChannelAdapter

All Implemented Interfaces:

org.axonframework.eventhandling.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean

public class EventListeningMessageChannelAdapter
extends Object
implements org.axonframework.eventhandling.EventListener, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanNameAware

Adapter class that sends Events from an event bus to a Spring Messaging Message Channel. All events are wrapped in GenericMessage instances. The adapter automatically subscribes itself to the provided EventBus.

Optionally, this adapter can be configured with a filter, which can block or accept messages based on their type.

Since:

2.3.1

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
EventListeningMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus, org.springframework.messaging.MessageChannel channel) Initialize an adapter to forward messages from the given eventBus to the given channel.
EventListeningMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus, org.springframework.messaging.MessageChannel channel, EventFilter filter) Initialize an adapter to forward messages from the given eventBus to the given channel.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Subscribes this event listener to the event bus.
void	handle(org.axonframework.eventhandling.EventMessage event) If allows by the filter, wraps the given event in a GenericMessage ands sends it to the configured MessageChannel.
void	setBeanName(String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventListeningMessageChannelAdapter

public EventListeningMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus,
                                           org.springframework.messaging.MessageChannel channel)

Initialize an adapter to forward messages from the given eventBus to the given channel. Messages are not filtered; all messages are forwarded to the MessageChannel

Parameters:

eventBus - The event bus to subscribe to.

channel - The channel to send event messages to.

EventListeningMessageChannelAdapter

public EventListeningMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus,
                                           org.springframework.messaging.MessageChannel channel,
                                           EventFilter filter)

Initialize an adapter to forward messages from the given eventBus to the given channel. Messages are filtered using the given filter

Parameters:

eventBus - The event bus to subscribe to.

channel - The channel to send event messages to.

filter - The filter that indicates which messages to forward.

Method Detail

afterPropertiesSet

public void afterPropertiesSet()

Subscribes this event listener to the event bus.

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

handle

public void handle(org.axonframework.eventhandling.EventMessage event)

If allows by the filter, wraps the given event in a GenericMessage ands sends it to the configured MessageChannel.

Specified by:

handle in interface org.axonframework.eventhandling.EventListener

Parameters:

event - the event to handle

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware