com.softwareag.eda.nerv.subscription

Class AbstractSubscription

java.lang.Object

com.softwareag.eda.nerv.subscription.AbstractSubscription

All Implemented Interfaces:

Subscription

Direct Known Subclasses:

DefaultEndpointSubscription, DefaultEventTypeSubscription

public abstract class AbstractSubscription
extends java.lang.Object
implements Subscription

Constructor Summary

Constructors

Constructor and Description
AbstractSubscription(org.apache.camel.Processor processor)

Method Summary

Methods

Modifier and Type	Method and Description
Subscription	addPreprocessor(org.apache.camel.Processor preprocessor) Adds a preprocessor to the subscription route.
Subscription	filterEvents(java.lang.String simpleFilter) Filters events out on the EDA client side so consumers don't have to do this themselves.
Subscription	filterEvents(java.lang.String header, java.lang.String value) Filters events out on the EDA client side so consumers don't have to do this themselves.
Subscription	filterEventsOnServerSide(java.lang.String serverSideFilter) Filters events out on the Event Bus (server side filtering).
java.util.List<Configuration>	getConfigurations() Returns an unmodifiable ordered list containing the different configurations used by this subscription.
java.util.List<org.apache.camel.Processor>	getPreprocessors() Returns an unmodifiable ordered list of all the preprocessors added by EDA clients to this subscription.
org.apache.camel.Processor	getProcessor() Provides a reference to the last processor of the processing chain which will receive the events once all other operations have been completed.
Subscription	orderEvents() Enables reordering of events by the time-stamp in $Event$Start header for consumers using this subscription.
Subscription	orderEvents(OrderEventsConfiguration config) Configures this subscription to reorder events as specified by custom configuration.
Subscription	suppressDuplicateEvents()
Subscription	suppressDuplicateEvents(DuplicateEventsConfiguration config)
Subscription	useDurableSubscription(java.lang.String clientId, java.lang.String subscriptionName) Creates a durable subscription which receive messages while the subscriber is not active. For more detailed information please see Session.createDurableSubscriber(javax.jms.Topic, String) and Connection.setClientID(String)
Subscription	useThreadPool(int poolSize) Configures the subscription to use a thread pool with the specified size.
Subscription	useThreadPool(ThreadPoolConfiguration config) Configures the subscription to use a thread pool with the specified configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSubscription

public AbstractSubscription(org.apache.camel.Processor processor)

Method Detail

getProcessor

public org.apache.camel.Processor getProcessor()

Description copied from interface: Subscription

Provides a reference to the last processor of the processing chain which will receive the events once all other operations have been completed. It is usually an instance of a class provided by EDA consumers that does the actual work.

Specified by:

getProcessor in interface Subscription

Returns:

A reference to the last route processor.

See Also:

#getPreprocessors()} - Returns a list of all previously added preprocessors.

getConfigurations

public java.util.List<Configuration> getConfigurations()

Description copied from interface: Subscription

Returns an unmodifiable ordered list containing the different configurations used by this subscription. The list increases with every change EDA clients make to this object. For example if you suppress duplicate events using Subscription.suppressDuplicateEvents() a new configuration will be added to the list.

Specified by:

getConfigurations in interface Subscription

Returns:

An ordered list containing the different configurations used by this subscription.

getPreprocessors

public java.util.List<org.apache.camel.Processor> getPreprocessors()

Description copied from interface: Subscription

Returns an unmodifiable ordered list of all the preprocessors added by EDA clients to this subscription.

Specified by:

getPreprocessors in interface Subscription

Returns:

An ordered list of all the preprocessors of this subscription.

See Also:

#addPreprocessor(Processor)} - Used for adding preprocessors.

addPreprocessor

public Subscription addPreprocessor(org.apache.camel.Processor preprocessor)

Description copied from interface: Subscription

Adds a preprocessor to the subscription route. Usually this is an object that does some preliminary processing of all incoming events before they reach the EDA client. For example users can add a transformer which converts events from the old EDA format to the new one and vice versa.

Specified by:

addPreprocessor in interface Subscription

Parameters:

preprocessor - - The preprocessor that has to be added to the subscription route.

Returns:

A reference to this object. Can be used by clients for rapidly building subscription configurations.

useDurableSubscription

public Subscription useDurableSubscription(java.lang.String clientId,
                                  java.lang.String subscriptionName)

Description copied from interface: Subscription

Creates a durable subscription which receive messages while the subscriber is not active.
For more detailed information please see Session.createDurableSubscriber(javax.jms.Topic, String) and Connection.setClientID(String)

Specified by:

useDurableSubscription in interface Subscription

Parameters:

clientId - an unique client ID which can only be used by a single JMS connection instance.

subscriptionName - durable subscriber name for specifying durable topic subscriptions.

Returns:

A reference to this object. Can be used by clients for rapidly building subscription configurations.

suppressDuplicateEvents

public Subscription suppressDuplicateEvents()

Specified by:

suppressDuplicateEvents in interface Subscription

suppressDuplicateEvents

public Subscription suppressDuplicateEvents(DuplicateEventsConfiguration config)

Specified by:

suppressDuplicateEvents in interface Subscription

filterEvents

public Subscription filterEvents(java.lang.String header,
                        java.lang.String value)

Description copied from interface: Subscription

Filters events out on the EDA client side so consumers don't have to do this themselves. It's not as performant as filtering the events on the server side but nevertheless provides convenient functionality to clients. This method uses Camel's Simple Language and is equivalent to filterEvents("${header.<name>} == '<value>'"). For example the following code filterEvents("$Event$Kind", "Event") is equivalent to filterEvents("${header.$Event$Kind} == 'Event'"). The later one uses Camel's Simple Language directly. Both will only allow events of kind "Event" to pass through, all "Heartbeat" events will be filtered out.

Specified by:

filterEvents in interface Subscription

Parameters:

header - - The name of the header you want your filter to be based on.

value - - The value of the header you want your filter to be based on.

Returns:

A reference to this object. Can be used by clients for rapidly building subscription configurations.

See Also:

#filterEvents(String)} - Provides more powerful client side filter capabilities based on Camel's Simple language., #filterEventsOnServerSide(String)} - Filters events out on the server side using a JMS message selector.

filterEvents

public Subscription filterEvents(java.lang.String simpleFilter)

Description copied from interface: Subscription

Filters events out on the EDA client side so consumers don't have to do this themselves. It's not as performant as filtering the events on the server side but nevertheless provides convenient functionality to clients. This method uses Camel's Simple Language. For more information check Apache Camel online documentation. Example: filterEvents("${header.$Event$Kind} == 'Event'"). This code will only allow events of kind "Event" to pass through, all "Heartbeat" events will be filtered out.

Specified by:

filterEvents in interface Subscription

Parameters:

simpleFilter - - A Camel simple language filter. For more information check Apache Camel online documentation.

Returns:

A reference to this object. Can be used by clients for rapidly building subscription configurations.

See Also:

#filterEventsOnServerSide(String)} - Filters events out on the server side using a JMS message selector., Camel's Simple Language

filterEventsOnServerSide

public Subscription filterEventsOnServerSide(java.lang.String serverSideFilter)

Description copied from interface: Subscription

Filters events out on the Event Bus (server side filtering). This is much more performant than filtering the events on the client side but currently only the JMS protocol is supported, i.e. this would only work if the underlying transport protocol is JMS. The method accepts a valid JMS message selector filter which is based on SQL 92. For more information on the syntax of this filter please check Java's online documentation on JMS message selectors. Example: filterEventsOnServerSide("$Event$Kind == 'Event'"). This code will only allow events of kind "Event" to pass through, all "Heartbeat" events will be filtered out, all events will be filtered on the JMS provider side.

Specified by:

filterEventsOnServerSide in interface Subscription

Parameters:

serverSideFilter - - A JMS message selector filter.

Returns:

A reference to this object. Can be used by clients for rapidly building subscription configurations.

See Also:

JMS Message, The JMS API Programming Model

orderEvents

public Subscription orderEvents()

Description copied from interface: Subscription

Enables reordering of events by the time-stamp in $Event$Start header for consumers using this subscription.

Specified by:

orderEvents in interface Subscription

Returns:

- A subscription configured for reordering of events by date.

See Also:

OrderEventsConfiguration, Resequencer EIP

orderEvents

public Subscription orderEvents(OrderEventsConfiguration config)

Description copied from interface: Subscription

Configures this subscription to reorder events as specified by custom configuration. For available configuration parameters see OrderEventsConfiguration.

Specified by:

orderEvents in interface Subscription

Parameters:

config - - A set of parameters used for reordering. For example, a header name by which the events are compared.

Returns:

- A a subscription configured for reordering of events with custom parameters.

useThreadPool

public Subscription useThreadPool(int poolSize)

Description copied from interface: Subscription

Configures the subscription to use a thread pool with the specified size.

Specified by:

useThreadPool in interface Subscription

Parameters:

poolSize - The size of the pool. In this case it's also equal to the maximum pool size.

Returns:

A reference to this object. Can be used by clients for rapidly building subscription configurations. The returned subscription is configured to use thread pools.

useThreadPool

public Subscription useThreadPool(ThreadPoolConfiguration config)

Description copied from interface: Subscription

Configures the subscription to use a thread pool with the specified configuration.

Specified by:

useThreadPool in interface Subscription

Parameters:

config - - The configuration which should be used for configuring the thread pool parameters such as default size, maximum pool size, and thread name template to be used.