org.axonframework.springmessaging.adapter
Class EventPublishingMessageChannelAdapter

java.lang.Object
  org.axonframework.springmessaging.adapter.EventPublishingMessageChannelAdapter

All Implemented Interfaces:

org.springframework.messaging.MessageHandler

public class EventPublishingMessageChannelAdapter
extends Object
implements org.springframework.messaging.MessageHandler

Adapter class that publishes Events from a Spring Messaging Message Channel on the Event Bus. All events are expected to be contained in the payload of the Message instances.

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

EventPublishingMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus)
Initialize the adapter to publish all incoming events to the given eventBus.

EventPublishingMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus, EventFilter filter)
Initialize the adapter to publish all incoming events to the given eventBus if they accepted by the given filter.

Method Summary

void	handleMessage(org.springframework.messaging.Message<?> message) Handles the given message.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventPublishingMessageChannelAdapter

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

Initialize the adapter to publish all incoming events to the given eventBus.

Parameters:

eventBus - The event bus to publish events on

EventPublishingMessageChannelAdapter

public EventPublishingMessageChannelAdapter(org.axonframework.eventhandling.EventBus eventBus,
                                            EventFilter filter)

Initialize the adapter to publish all incoming events to the given eventBus if they accepted by the given filter.

Parameters:

eventBus - The event bus to publish events on.

filter - The filter that indicates which events to publish.

Method Detail

handleMessage

public void handleMessage(org.springframework.messaging.Message<?> message)

Handles the given message. If the filter refuses the message, it is ignored.

Specified by:

handleMessage in interface org.springframework.messaging.MessageHandler

Parameters:

message - The message containing the event to publish