public class DefaultEndpointSubscription extends AbstractSubscription implements EndpointSubscription
EndpointSubscription
interface.Constructor and Description |
---|
DefaultEndpointSubscription(org.apache.camel.Processor processor,
java.lang.String... endpoints)
Constructs an object based on provided Camel processor and an array of one or more endpoints.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String[] |
getEndpointURIs()
Returns all endpoint URIs used by this subscription
|
addPreprocessor, filterEvents, filterEvents, filterEventsOnServerSide, getConfigurations, getPreprocessors, getProcessor, orderEvents, orderEvents, suppressDuplicateEvents, suppressDuplicateEvents, useDurableSubscription, useThreadPool, useThreadPool
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addPreprocessor, filterEvents, filterEvents, filterEventsOnServerSide, getConfigurations, getPreprocessors, getProcessor, orderEvents, orderEvents, suppressDuplicateEvents, suppressDuplicateEvents, useDurableSubscription, useThreadPool, useThreadPool
public DefaultEndpointSubscription(org.apache.camel.Processor processor, java.lang.String... endpoints)
processor
- - A processor provided by the EDA consumer.endpoints
- - A list of endpoints which the provided processor should be subscribed to.public java.lang.String[] getEndpointURIs()
EndpointSubscription
getEndpointURIs
in interface EndpointSubscription