|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.DefaultEndpoint org.apache.camel.component.sjms.SjmsEndpoint
@UriEndpoint(scheme="sjms", consumerClass=SjmsConsumer.class) public class SjmsEndpoint
A JMS Endpoint
Field Summary | |
---|---|
protected org.slf4j.Logger |
logger
|
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
SjmsEndpoint()
|
|
SjmsEndpoint(String uri,
org.apache.camel.Component component)
|
Method Summary | |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor)
|
org.apache.camel.Producer |
createProducer()
|
protected void |
doStart()
|
protected void |
doStop()
|
SessionAcknowledgementType |
getAcknowledgementMode()
Returns the configured acknowledgementMode. |
SjmsComponent |
getComponent()
|
ConnectionResource |
getConnectionResource()
|
int |
getConsumerCount()
Returns the number of consumer listeners for this endpoint. |
String |
getDestinationName()
|
String |
getDurableSubscriptionId()
Gets the durable subscription Id. |
KeyFormatStrategy |
getJmsKeyFormatStrategy()
|
String |
getMessageSelector()
Returns the JMS Message selector syntax used to refine the messages being consumed. |
String |
getNamedReplyTo()
Returns the reply to destination name used for InOut producer endpoints. |
int |
getProducerCount()
Returns the number of consumer listeners for this endpoint. |
long |
getResponseTimeOut()
Returns the InOut response timeout. |
int |
getSessionCount()
Deprecated. |
org.apache.camel.spi.HeaderFilterStrategy |
getSjmsHeaderFilterStrategy()
|
int |
getTransactionBatchCount()
If transacted, returns the nubmer of messages to be processed before committing the transaction. |
long |
getTransactionBatchTimeout()
Returns the timeout value for batch transactions. |
TransactionCommitStrategy |
getTransactionCommitStrategy()
Gets the commit strategy. |
long |
getTtl()
Returns the Time To Live set on this endpoint. |
boolean |
isMultipleConsumersSupported()
|
boolean |
isPersistent()
Use to determine if the enpoint has message persistence enabled or disabled. |
boolean |
isSingleton()
|
boolean |
isSynchronous()
Use to determine whether or not to process exchanges synchronously. |
boolean |
isTopic()
Flag set by the endpoint used by consumers and producers to determine if the endpoint is a JMS Topic. |
boolean |
isTransacted()
Use to determine if transactions are enabled or disabled. |
void |
setAcknowledgementMode(SessionAcknowledgementType acknowledgementMode)
Sets the acknowledgementMode configured on this endpoint. |
void |
setConsumerCount(int consumerCount)
Sets the number of consumer listeners used for this endpoint. |
void |
setDurableSubscriptionId(String durableSubscriptionId)
Sets the durable subscription Id required for durable topics. |
void |
setMessageSelector(String messageSelector)
Sets the JMS Message selector syntax. |
void |
setNamedReplyTo(String namedReplyTo)
Sets the reply to destination name used for InOut producer endpoints. |
void |
setPersistent(boolean persistent)
Flag used to enable/disable message persistence. |
void |
setProducerCount(int producerCount)
Sets the number of producers used for this endpoint. |
void |
setResponseTimeOut(long responseTimeOut)
Sets the amount of time we should wait before timing out a InOut response. |
void |
setSessionCount(int sessionCount)
Deprecated. |
void |
setSynchronous(boolean synchronous)
Flag can be set to enable/disable synchronous exchange processing. |
void |
setTransacted(boolean transacted)
Enable/disable flag for transactions |
void |
setTransactionBatchCount(int transactionBatchCount)
If transacted sets the number of messages to process before committing a transaction. |
void |
setTransactionBatchTimeout(long transactionBatchTimeout)
Sets timeout value for batch transactions. |
void |
setTransactionCommitStrategy(TransactionCommitStrategy transactionCommitStrategy)
Sets the commit strategy. |
void |
setTtl(long ttl)
Flag used to adjust the Time To Live value of produced messages. |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
---|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Field Detail |
---|
protected final org.slf4j.Logger logger
Constructor Detail |
---|
public SjmsEndpoint()
public SjmsEndpoint(String uri, org.apache.camel.Component component)
Method Detail |
---|
public SjmsComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
public String getDestinationName()
public ConnectionResource getConnectionResource()
public org.apache.camel.spi.HeaderFilterStrategy getSjmsHeaderFilterStrategy()
public KeyFormatStrategy getJmsKeyFormatStrategy()
public boolean isSynchronous()
isSynchronous
in class org.apache.camel.impl.DefaultEndpoint
public void setSynchronous(boolean synchronous)
setSynchronous
in class org.apache.camel.impl.DefaultEndpoint
synchronous
- true to process synchronously, default is truepublic SessionAcknowledgementType getAcknowledgementMode()
public void setAcknowledgementMode(SessionAcknowledgementType acknowledgementMode)
acknowledgementMode
- default is
SessionAcknowledgementType.AUTO_ACKNOWLEDGEpublic boolean isTopic()
@Deprecated public int getSessionCount()
@Deprecated public void setSessionCount(int sessionCount)
sessionCount
- the number of Session instances, default is 1public int getProducerCount()
public void setProducerCount(int producerCount)
producerCount
- the number of producers for this endpoint, default
is 1public int getConsumerCount()
public void setConsumerCount(int consumerCount)
consumerCount
- the number of consumers for this endpoint, default
is 1public long getTtl()
public void setTtl(long ttl)
ttl
- a new TTL, default is -1 (disabled)public boolean isPersistent()
public void setPersistent(boolean persistent)
persistent
- true if persistent, default is truepublic String getDurableSubscriptionId()
public void setDurableSubscriptionId(String durableSubscriptionId)
durableSubscriptionId
- durable subscription Id or nullpublic long getResponseTimeOut()
public void setResponseTimeOut(long responseTimeOut)
responseTimeOut
- response timeoutpublic String getMessageSelector()
public void setMessageSelector(String messageSelector)
messageSelector
- Message selector syntax or nullpublic int getTransactionBatchCount()
public void setTransactionBatchCount(int transactionBatchCount)
transactionBatchCount
- number of messages to process before
committing, default is 1public long getTransactionBatchTimeout()
public void setTransactionBatchTimeout(long transactionBatchTimeout)
transactionBatchTimeout
- public TransactionCommitStrategy getTransactionCommitStrategy()
public void setTransactionCommitStrategy(TransactionCommitStrategy transactionCommitStrategy)
transactionCommitStrategy
- commit strategy to use when processing
transacted messagespublic boolean isTransacted()
public void setTransacted(boolean transacted)
transacted
- true if transacted, otherwise falsepublic String getNamedReplyTo()
public void setNamedReplyTo(String namedReplyTo)
the
- namedReplyTo the JMS reply to destination name
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |