|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.axis2.transport.jms.JMSMessageSender
public class JMSMessageSender
Performs the actual sending of a JMS message, and the subsequent committing of a JTA transaction (if requested) or the local session transaction, if used. An instance of this class is unique to a single message send out operation and will not be shared.
Constructor Summary | |
---|---|
JMSMessageSender(javax.jms.Connection connection,
javax.jms.Session session,
javax.jms.MessageProducer producer,
javax.jms.Destination destination,
int cacheLevel,
boolean jmsSpec11,
java.lang.Boolean isQueue)
This is a low-end method to support the one-time sends using JMS 1.0.2b |
|
JMSMessageSender(JMSConnectionFactory jmsConnectionFactory,
java.lang.String targetAddress)
Create a JMSSender using a JMSConnectionFactory and target EPR |
Method Summary | |
---|---|
void |
close()
Close non-shared producer, session and connection if any |
int |
getCacheLevel()
|
javax.jms.Connection |
getConnection()
|
javax.jms.MessageProducer |
getProducer()
|
javax.jms.Session |
getSession()
|
void |
send(javax.jms.Message message,
org.apache.axis2.context.MessageContext msgCtx)
Perform actual send of JMS message to the Destination selected |
void |
setCacheLevel(int cacheLevel)
|
void |
setConnection(javax.jms.Connection connection)
|
void |
setProducer(javax.jms.MessageProducer producer)
|
void |
setSession(javax.jms.Session session)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JMSMessageSender(javax.jms.Connection connection, javax.jms.Session session, javax.jms.MessageProducer producer, javax.jms.Destination destination, int cacheLevel, boolean jmsSpec11, java.lang.Boolean isQueue)
connection
- the JMS Connectionsession
- JMS Sessionproducer
- the MessageProducerdestination
- the JMS DestinationcacheLevel
- cacheLevel - None | Connection | Session | ProducerjmsSpec11
- true if the JMS 1.1 API should be usedisQueue
- posting to a Queue?public JMSMessageSender(JMSConnectionFactory jmsConnectionFactory, java.lang.String targetAddress)
jmsConnectionFactory
- the JMSConnectionFactorytargetAddress
- target EPRMethod Detail |
---|
public void send(javax.jms.Message message, org.apache.axis2.context.MessageContext msgCtx)
message
- the JMS messagemsgCtx
- the Axis2 MessageContextpublic void close()
public void setConnection(javax.jms.Connection connection)
public void setSession(javax.jms.Session session)
public void setProducer(javax.jms.MessageProducer producer)
public void setCacheLevel(int cacheLevel)
public int getCacheLevel()
public javax.jms.Connection getConnection()
public javax.jms.MessageProducer getProducer()
public javax.jms.Session getSession()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |