com.softwareag.eda.nerv

Interface EventConsumer

public interface EventConsumer

Method Summary

Methods

Modifier and Type	Method and Description
void	subscribe(EndpointSubscription subscription) Subscribes with a specific EndpointSubscription Example code:
void	subscribe(EventTypeSubscription subscription) Subscribes with a specific EventTypeSubscription Example code:
void	subscribe(org.apache.camel.Processor processor, com.softwareag.eda.store.api.EDAEventTypeID eventTypeID) Subscribes a processor to specific Event Type
void	subscribe(org.apache.camel.Processor processor, java.lang.String... endpointURIs) Subscribes a processor to specific Event Type
void	unsubscribe(EndpointSubscription subscription) Unsubscribes the specified EndpointSubscription object
void	unsubscribe(EventTypeSubscription subscription) Unsubscribes the specified EventTypeSubscription object
void	unsubscribe(org.apache.camel.Processor processor, com.softwareag.eda.store.api.EDAEventTypeID eventTypeID) Removes a processor subscription for specific Event Type
void	unsubscribe(org.apache.camel.Processor processor, java.lang.String... endpointURIs) Removes a processor subscription for specific Event Type

Method Detail

subscribe

void subscribe(org.apache.camel.Processor processor,
             com.softwareag.eda.store.api.EDAEventTypeID eventTypeID)
               throws NervException

Subscribes a processor to specific Event Type

Parameters:

processor - - specific callback processor to be invoked on event

eventTypeID - - the Event Type ID to which we subscribe

Throws:

NervException - - An exception is thrown if no default endpoint is found for this Event Type or there is a problem with the Event Bus connection

subscribe

void subscribe(org.apache.camel.Processor processor,
             java.lang.String... endpointURIs)
               throws NervException

Subscribes a processor to specific Event Type

Parameters:

processor - - specific callback processor to be invoked on event

endpointURIs - - One or more endpoint URIs to which we subscribe, it is important that the component used in the URI have to be already defined in NERV or is standard component like "http", "smtp" etc.

Throws:

NervException - - An exception is thrown if there is a problem with the Event Bus connection or the component in some of the URIs is not resolved

unsubscribe

void unsubscribe(org.apache.camel.Processor processor,
               com.softwareag.eda.store.api.EDAEventTypeID eventTypeID)
                 throws NervException

Removes a processor subscription for specific Event Type

Parameters:

processor - - specific callback processor

eventTypeID - - the Event Type ID to which we subscribed

Throws:

NervException - - An exception is thrown if no default endpoint is found for this Event Type or there is a problem with the Event Bus connection

unsubscribe

void unsubscribe(org.apache.camel.Processor processor,
               java.lang.String... endpointURIs)
                 throws NervException

Removes a processor subscription for specific Event Type

Parameters:

processor - - specific callback processor

endpointURIs - - the endpoint URIs to which we subscribed

Throws:

NervException - - An exception is thrown if there is a problem with the Event Bus connection

subscribe

void subscribe(EventTypeSubscription subscription)
               throws NervException

Subscribes with a specific EventTypeSubscription Example code:

 EventSubscription subscription = new DefaultEventSubscription(myEventTypeId, myProcessor);
 eventConsumer.subscribe(subscription);
 

Parameters:

subscription - An EventTypeSubscription object

Throws:

NervException

subscribe

void subscribe(EndpointSubscription subscription)
               throws NervException

Subscribes with a specific EndpointSubscription Example code:

 EndpointSubscription subscription = new DefaultEndpointSubscription(myProcessor, myEndpoint);
 eventConsumer.subscribe(subscription);
 

Parameters:

subscription - An EndpointSubscription object

Throws:

NervException

unsubscribe

void unsubscribe(EventTypeSubscription subscription)
                 throws NervException

Unsubscribes the specified EventTypeSubscription object

Parameters:

subscription - An EventTypeSubscription object

Throws:

NervException

unsubscribe

void unsubscribe(EndpointSubscription subscription)
                 throws NervException

Unsubscribes the specified EndpointSubscription object

Parameters:

subscription - An EndpointSubscription object

Throws:

NervException