org.axonframework.integration.adapter
Class EventPublishingMessageChannelAdapter

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

All Implemented Interfaces:

org.springframework.integration.core.MessageHandler

public class EventPublishingMessageChannelAdapter
extends Object
implements org.springframework.integration.core.MessageHandler

Adapter class that publishes Events from a Spring Integration 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:

0.4

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.integration.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.integration.Message<?> message)

Handles the given message. The message is expected to contain an object of type EventMessage in its payload. If that is not the case, a MessageRejectedException is thrown.

If the message does contain an EventMessage, but the filter refuses it, a MessageRejectedException is also thrown.

Specified by:

handleMessage in interface org.springframework.integration.core.MessageHandler

Parameters:

message - The message containing the event to publish

Throws:

org.springframework.integration.MessageRejectedException - is the payload could not be published on the event bus.