org.apache.camel.component.sjms
Class SjmsProducer

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultProducer
          org.apache.camel.impl.DefaultAsyncProducer
              org.apache.camel.component.sjms.SjmsProducer

All Implemented Interfaces:

org.apache.camel.AsyncProcessor, org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

Direct Known Subclasses:

InOnlyProducer, InOutProducer

public abstract class SjmsProducer
extends org.apache.camel.impl.DefaultAsyncProducer

Base SjmsProducer class.

Nested Class Summary

protected class	SjmsProducer.MessageProducerPool The SjmsProducer.MessageProducerResources pool for all SjmsProducer classes.
protected class	SjmsProducer.MessageProducerResources The MessageProducer resources for all SjmsProducer classes.

Field Summary

Fields inherited from class org.apache.camel.impl.DefaultProducer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

SjmsProducer(org.apache.camel.Endpoint endpoint)

Method Summary

abstract SjmsProducer.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.
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.
SjmsProducer.MessageProducerPool	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.
protected SjmsEndpoint	getSjmsEndpoint()
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)
void	setProducers(SjmsProducer.MessageProducerPool producers) Sets the producer pool for this instance of SjmsProducer.

Methods inherited from class org.apache.camel.impl.DefaultAsyncProducer

process

Methods inherited from class org.apache.camel.impl.DefaultProducer

createExchange, createExchange, createExchange, getEndpoint, isSingleton, 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, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

SjmsProducer

public SjmsProducer(org.apache.camel.Endpoint endpoint)

Method Detail

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.impl.DefaultProducer

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultProducer

Throws:

Exception

doCreateProducerModel

public abstract SjmsProducer.MessageProducerResources doCreateProducerModel()
                                                                     throws Exception

Throws:

Exception

sendMessage

public abstract void sendMessage(org.apache.camel.Exchange exchange,
                                 org.apache.camel.AsyncCallback callback)
                          throws Exception

Throws:

Exception

process

public boolean process(org.apache.camel.Exchange exchange,
                       org.apache.camel.AsyncCallback callback)

getSjmsEndpoint

protected SjmsEndpoint getSjmsEndpoint()

getConnectionResource

protected ConnectionResource getConnectionResource()

getAcknowledgeMode

public int getAcknowledgeMode()

Gets the acknowledgment mode for this instance of DestinationProducer.

Returns:

int

isSynchronous

public boolean isSynchronous()

Gets the synchronous value for this instance of DestinationProducer.

Returns:

true if synchronous, otherwise false

getReplyTo

public String getReplyTo()

Gets the replyTo for this instance of DestinationProducer.

Returns:

String

getDestinationName

public String getDestinationName()

Gets the destinationName for this instance of DestinationProducer.

Returns:

String

setProducers

public void setProducers(SjmsProducer.MessageProducerPool producers)

Sets the producer pool for this instance of SjmsProducer.

Parameters:

producers - A MessageProducerPool

getProducers

public SjmsProducer.MessageProducerPool getProducers()

Gets the MessageProducerPool value of producers for this instance of SjmsProducer.

Returns:

the producers

isTopic

public boolean isTopic()

Test to verify if this endpoint is a JMS Topic or Queue.

Returns:

true if it is a Topic, otherwise it is a Queue

isEndpointTransacted

public boolean isEndpointTransacted()

Test to determine if this endpoint should use a JMS Transaction.

Returns:

true if transacted, otherwise false

getNamedReplyTo

public String getNamedReplyTo()

Returns the named reply to value for this producer

Returns:

true if it is a Topic, otherwise it is a Queue

getProducerCount

public int getProducerCount()

Gets the producerCount for this instance of SjmsProducer.

Returns:

int

getConsumerCount

public int getConsumerCount()

Gets consumerCount for this instance of SjmsProducer.

Returns:

int

getExecutor

public ExecutorService getExecutor()

Gets the executor for this instance of SjmsProducer.

Returns:

ExecutorService

getTtl

public long getTtl()

Gets the ttl for this instance of SjmsProducer.

Returns:

long

isPersistent

public boolean isPersistent()

Gets the boolean value of persistent for this instance of SjmsProducer.

Returns:

true if persistent, otherwise false

getResponseTimeOut

public long getResponseTimeOut()

Gets responseTimeOut for this instance of SjmsProducer.

Returns:

long

getCommitStrategy

public TransactionCommitStrategy getCommitStrategy()

Gets commitStrategy for this instance of SjmsProducer.

Returns:

TransactionCommitStrategy