Package org.apache.camel.component.sjms

Class SjmsTemplate

java.lang.Object

org.apache.camel.component.sjms.SjmsTemplate

public class SjmsTemplate
extends Object

Constructor Summary

Constructors

Constructor	Description
SjmsTemplate(javax.jms.ConnectionFactory connectionFactory, boolean transacted, int acknowledgeMode)

Method Summary

Modifier and Type	Method	Description
javax.jms.Connection	createConnection()
javax.jms.Session	createSession(javax.jms.Connection connection)
void	execute(javax.jms.Session session, SessionCallback sessionCallback)
Object	execute(SessionCallback sessionCallback, boolean startConnection)
javax.jms.ConnectionFactory	getConnectionFactory()
javax.jms.Message	receive(String destinationName, String messageSelector, boolean isTopic, long timeout)
void	send(javax.jms.MessageProducer producer, javax.jms.Message message)
void	send(org.apache.camel.Exchange exchange, String destinationName, MessageCreator messageCreator, boolean isTopic)
void	setDestinationCreationStrategy(DestinationCreationStrategy destinationCreationStrategy)
void	setExplicitQosEnabled(boolean explicitQosEnabled)
void	setPreserveMessageQos(boolean preserveMessageQos)
void	setQoSSettings(int deliveryMode, int priority, long timeToLive)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SjmsTemplate

public SjmsTemplate(javax.jms.ConnectionFactory connectionFactory,
                    boolean transacted,
                    int acknowledgeMode)

Method Detail

getConnectionFactory

public javax.jms.ConnectionFactory getConnectionFactory()

setDestinationCreationStrategy

public void setDestinationCreationStrategy(DestinationCreationStrategy destinationCreationStrategy)

setQoSSettings

public void setQoSSettings(int deliveryMode,
                           int priority,
                           long timeToLive)

setExplicitQosEnabled

public void setExplicitQosEnabled(boolean explicitQosEnabled)

setPreserveMessageQos

public void setPreserveMessageQos(boolean preserveMessageQos)

execute

public Object execute(SessionCallback sessionCallback,
                      boolean startConnection)
               throws Exception

Throws:

Exception

execute

public void execute(javax.jms.Session session,
                    SessionCallback sessionCallback)
             throws Exception

Throws:

Exception

send

public void send(org.apache.camel.Exchange exchange,
                 String destinationName,
                 MessageCreator messageCreator,
                 boolean isTopic)
          throws Exception

Throws:

Exception

send

public void send(javax.jms.MessageProducer producer,
                 javax.jms.Message message)
          throws Exception

Throws:

Exception

receive

public javax.jms.Message receive(String destinationName,
                                 String messageSelector,
                                 boolean isTopic,
                                 long timeout)
                          throws Exception

Throws:

Exception

createConnection

public javax.jms.Connection createConnection()
                                      throws Exception

Throws:

Exception

createSession

public javax.jms.Session createSession(javax.jms.Connection connection)
                                throws Exception

Throws:

Exception