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