public class InboundMessageProducerProxy extends Object implements javax.jms.MessageProducer, javax.jms.QueueSender, javax.jms.TopicPublisher
MessageProducer
which uses the ActiveMQ JCA ResourceAdapter's
current thread's JMS Session
to send messages.Constructor and Description |
---|
InboundMessageProducerProxy(javax.jms.MessageProducer messageProducer,
javax.jms.Destination destination) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
getDeliveryMode() |
javax.jms.Destination |
getDestination() |
boolean |
getDisableMessageID() |
boolean |
getDisableMessageTimestamp() |
int |
getPriority() |
javax.jms.Queue |
getQueue() |
long |
getTimeToLive() |
javax.jms.Topic |
getTopic() |
void |
publish(javax.jms.Message arg0) |
void |
publish(javax.jms.Message arg0,
int arg1,
int arg2,
long arg3) |
void |
publish(javax.jms.Topic arg0,
javax.jms.Message arg1) |
void |
publish(javax.jms.Topic arg0,
javax.jms.Message arg1,
int arg2,
int arg3,
long arg4) |
void |
send(javax.jms.Destination destination,
javax.jms.Message message) |
void |
send(javax.jms.Destination destination,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
send(javax.jms.Message message) |
void |
send(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive) |
void |
send(javax.jms.Queue arg0,
javax.jms.Message arg1) |
void |
send(javax.jms.Queue arg0,
javax.jms.Message arg1,
int arg2,
int arg3,
long arg4) |
void |
setDeliveryMode(int i) |
void |
setDisableMessageID(boolean b) |
void |
setDisableMessageTimestamp(boolean b) |
void |
setPriority(int i) |
void |
setTimeToLive(long l) |
public InboundMessageProducerProxy(javax.jms.MessageProducer messageProducer, javax.jms.Destination destination) throws javax.jms.JMSException
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface javax.jms.MessageProducer
javax.jms.JMSException
public javax.jms.Destination getDestination() throws javax.jms.JMSException
getDestination
in interface javax.jms.MessageProducer
javax.jms.JMSException
public int getDeliveryMode() throws javax.jms.JMSException
getDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public boolean getDisableMessageID() throws javax.jms.JMSException
getDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
public boolean getDisableMessageTimestamp() throws javax.jms.JMSException
getDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
public int getPriority() throws javax.jms.JMSException
getPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
public long getTimeToLive() throws javax.jms.JMSException
getTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void send(javax.jms.Message message) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
send
in interface javax.jms.QueueSender
javax.jms.JMSException
public void send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
send
in interface javax.jms.MessageProducer
send
in interface javax.jms.QueueSender
javax.jms.JMSException
public void setDeliveryMode(int i) throws javax.jms.JMSException
setDeliveryMode
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDisableMessageID(boolean b) throws javax.jms.JMSException
setDisableMessageID
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setDisableMessageTimestamp(boolean b) throws javax.jms.JMSException
setDisableMessageTimestamp
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setPriority(int i) throws javax.jms.JMSException
setPriority
in interface javax.jms.MessageProducer
javax.jms.JMSException
public void setTimeToLive(long l) throws javax.jms.JMSException
setTimeToLive
in interface javax.jms.MessageProducer
javax.jms.JMSException
public javax.jms.Queue getQueue() throws javax.jms.JMSException
getQueue
in interface javax.jms.QueueSender
javax.jms.JMSException
public void send(javax.jms.Queue arg0, javax.jms.Message arg1) throws javax.jms.JMSException
send
in interface javax.jms.QueueSender
javax.jms.JMSException
public void send(javax.jms.Queue arg0, javax.jms.Message arg1, int arg2, int arg3, long arg4) throws javax.jms.JMSException
send
in interface javax.jms.QueueSender
javax.jms.JMSException
public javax.jms.Topic getTopic() throws javax.jms.JMSException
getTopic
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Message arg0) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Message arg0, int arg1, int arg2, long arg3) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Topic arg0, javax.jms.Message arg1) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
public void publish(javax.jms.Topic arg0, javax.jms.Message arg1, int arg2, int arg3, long arg4) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
javax.jms.JMSException
Copyright © 2005–2018. All rights reserved.