@UriEndpoint(firstVersion="2.19.0",
scheme="sjms2",
extendsScheme="sjms",
title="Simple JMS2",
syntax="sjms2:destinationType:destinationName",
consumerClass=org.apache.camel.component.sjms.SjmsConsumer.class,
label="messaging")
public class Sjms2Endpoint
extends org.apache.camel.component.sjms.SjmsEndpoint
implements org.apache.camel.AsyncEndpoint
Constructor and Description |
---|
Sjms2Endpoint() |
Sjms2Endpoint(String uri,
org.apache.camel.Component component,
String remaining) |
Modifier and Type | Method and Description |
---|---|
Sjms2Component |
getComponent() |
String |
getSubscriptionId() |
boolean |
isDurable() |
boolean |
isShared() |
void |
setDurable(boolean durable)
Sets topic consumer to durable.
|
void |
setDurableSubscriptionId(String durableSubscriptionId)
Deprecated.
|
void |
setShared(boolean shared)
Sets the consumer to shared.
|
void |
setSubscriptionId(String subscriptionId)
Sets the subscription Id, required for durable or shared topics.
|
createBinding, createConnectionResource, createConsumer, createExchange, createProducer, doStart, doStop, getAcknowledgementMode, getBinding, getConnectionCount, getConnectionFactory, getConnectionResource, getConsumerCount, getDestinationCreationStrategy, getDestinationName, getDurableSubscriptionId, getErrorHandlerLoggingLevel, getExceptionListener, getHeaderFilterStrategy, getJmsKeyFormatStrategy, getJmsObjectFactory, getMessageCreatedStrategy, getMessageSelector, getNamedReplyTo, getProducerCount, getResponseTimeOut, getSessionCount, getTransactionBatchCount, getTransactionBatchTimeout, getTransactionCommitStrategy, getTtl, isAllowNullBody, isAsyncStartListener, isAsyncStopListener, isErrorHandlerLogStackTrace, isIncludeAllJMSXProperties, isMapJmsMessage, isMultipleConsumersSupported, isPersistent, isPrefillPool, isSharedJMSSession, isSingleton, isSynchronous, isTopic, isTransacted, setAcknowledgementMode, setAllowNullBody, setAsyncStartListener, setAsyncStopListener, setBinding, setConnectionCount, setConnectionFactory, setConnectionResource, setConsumerCount, setDestinationCreationStrategy, setDestinationName, setErrorHandlerLoggingLevel, setErrorHandlerLogStackTrace, setExceptionListener, setHeaderFilterStrategy, setIncludeAllJMSXProperties, setJmsKeyFormatStrategy, setJmsObjectFactory, setMapJmsMessage, setMessageCreatedStrategy, setMessageSelector, setNamedReplyTo, setPersistent, setPrefillPool, setProducerCount, setResponseTimeOut, setSessionCount, setSharedJMSSession, setSynchronous, setTransacted, setTransactionBatchCount, setTransactionBatchTimeout, setTransactionCommitStrategy, setTtl
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public Sjms2Component getComponent()
getComponent
in class org.apache.camel.component.sjms.SjmsEndpoint
@Deprecated public void setDurableSubscriptionId(String durableSubscriptionId)
setDurableSubscriptionId
in class org.apache.camel.component.sjms.SjmsEndpoint
public String getSubscriptionId()
public void setSubscriptionId(String subscriptionId)
public boolean isDurable()
public void setDurable(boolean durable)
public boolean isShared()
public void setShared(boolean shared)
Apache Camel