org.axonframework.spring.messaging

Class OutboundEventMessageChannelAdapter

java.lang.Object

org.axonframework.spring.messaging.OutboundEventMessageChannelAdapter

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

public class OutboundEventMessageChannelAdapter
extends Object
implements org.springframework.beans.factory.InitializingBean

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
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel) Initialize an adapter to forward messages from the given messageSource to the given channel.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage<?>> filter) Initialize an adapter to forward messages from the given messageSource to the given channel.
OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource, org.springframework.messaging.MessageChannel channel, Predicate<? super EventMessage<?>> filter, EventMessageConverter eventMessageConverter) Initialize an adapter to forward messages from the given messageSource to the given channel.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet() Subscribes this event listener to the event bus.
protected void	handle(List<? extends EventMessage<?>> events) If allows by the filter, wraps the given event in a GenericMessage ands sends it to the configured MessageChannel.
protected org.springframework.messaging.Message<?>	transform(EventMessage<?> event) Transforms the given Axon event into a Spring Messaging Message.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutboundEventMessageChannelAdapter

public OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                          org.springframework.messaging.MessageChannel channel)

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

Parameters:

messageSource - The event bus to subscribe to.

channel - The channel to send event messages to.

OutboundEventMessageChannelAdapter

public OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                          org.springframework.messaging.MessageChannel channel,
                                          Predicate<? super EventMessage<?>> filter)

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

Parameters:

messageSource - The source of messages to subscribe to.

channel - The channel to send event messages to.

filter - The filter that indicates which messages to forward.

OutboundEventMessageChannelAdapter

public OutboundEventMessageChannelAdapter(SubscribableMessageSource<EventMessage<?>> messageSource,
                                          org.springframework.messaging.MessageChannel channel,
                                          Predicate<? super EventMessage<?>> filter,
                                          EventMessageConverter eventMessageConverter)

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

Parameters:

messageSource - The source of messages to subscribe to.

channel - The channel to send event messages to.

filter - The filter that indicates which messages to forward.

eventMessageConverter - The converter to use to convert event message into Spring message

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

protected void handle(List<? extends EventMessage<?>> events)

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

Parameters:

events - the events to handle

transform

protected org.springframework.messaging.Message<?> transform(EventMessage<?> event)

Transforms the given Axon event into a Spring Messaging Message. This method may be overridden to change how this transformation should occur.

Parameters:

event - The Axon EventMessage to transform

Returns:

The Spring Messaging Message representing the Event Message