public abstract class SjmsProducer
extends org.apache.camel.impl.DefaultAsyncProducer
Modifier and Type | Class and Description |
---|---|
protected class |
SjmsProducer.MessageProducerResourcesFactory
The
MessageProducerResources pool for all SjmsProducer
classes. |
Constructor and Description |
---|
SjmsProducer(org.apache.camel.Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
abstract MessageProducerResources |
doCreateProducerModel() |
protected void |
doStart() |
protected void |
doStop() |
int |
getAcknowledgeMode()
Gets the acknowledgment mode for this instance of DestinationProducer.
|
TransactionCommitStrategy |
getCommitStrategy()
Gets commitStrategy for this instance of SjmsProducer.
|
protected ConnectionResource |
getConnectionResource() |
int |
getConsumerCount()
Gets consumerCount for this instance of SjmsProducer.
|
String |
getDestinationName()
Gets the destinationName for this instance of DestinationProducer.
|
SjmsEndpoint |
getEndpoint() |
ExecutorService |
getExecutor()
Gets the executor for this instance of SjmsProducer.
|
String |
getNamedReplyTo()
Returns the named reply to value for this producer
|
int |
getProducerCount()
Gets the producerCount for this instance of SjmsProducer.
|
org.apache.commons.pool.impl.GenericObjectPool<MessageProducerResources> |
getProducers()
Gets the MessageProducerPool value of producers for this instance of
SjmsProducer.
|
String |
getReplyTo()
Gets the replyTo for this instance of DestinationProducer.
|
long |
getResponseTimeOut()
Gets responseTimeOut for this instance of SjmsProducer.
|
long |
getTtl()
Gets the ttl for this instance of SjmsProducer.
|
boolean |
isEndpointTransacted()
Test to determine if this endpoint should use a JMS Transaction.
|
boolean |
isPersistent()
Gets the boolean value of persistent for this instance of SjmsProducer.
|
boolean |
isSynchronous()
Gets the synchronous value for this instance of DestinationProducer.
|
boolean |
isTopic()
Test to verify if this endpoint is a JMS Topic or Queue.
|
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
abstract void |
sendMessage(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback,
MessageProducerResources producer) |
void |
setProducers(org.apache.commons.pool.impl.GenericObjectPool<MessageProducerResources> producers)
Sets the producer pool for this instance of SjmsProducer.
|
createExchange, createExchange, createExchange, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public SjmsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
public abstract MessageProducerResources doCreateProducerModel() throws Exception
Exception
public abstract void sendMessage(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, MessageProducerResources producer) throws Exception
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
protected ConnectionResource getConnectionResource()
public int getAcknowledgeMode()
public boolean isSynchronous()
public String getReplyTo()
public String getDestinationName()
public void setProducers(org.apache.commons.pool.impl.GenericObjectPool<MessageProducerResources> producers)
producers
- A MessageProducerPoolpublic org.apache.commons.pool.impl.GenericObjectPool<MessageProducerResources> getProducers()
public boolean isTopic()
public boolean isEndpointTransacted()
public String getNamedReplyTo()
public int getProducerCount()
public int getConsumerCount()
public ExecutorService getExecutor()
public long getTtl()
public boolean isPersistent()
public long getResponseTimeOut()
public TransactionCommitStrategy getCommitStrategy()
Apache Camel