Package org.apache.activemq.ra

Class InboundMessageProducerProxy

java.lang.Object

org.apache.activemq.ra.InboundMessageProducerProxy

All Implemented Interfaces:

MessageProducer, QueueSender, TopicPublisher

public class InboundMessageProducerProxy
extends Object
implements MessageProducer, QueueSender, TopicPublisher

An implementation of MessageProducer which uses the ActiveMQ JCA ResourceAdapter's current thread's JMS Session to send messages.

Constructor Summary

Constructors

Constructor	Description
InboundMessageProducerProxy(MessageProducer messageProducer, Destination destination)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

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

Constructor Detail

InboundMessageProducerProxy

public InboundMessageProducerProxy(MessageProducer messageProducer,
                                   Destination destination)
                            throws JMSException

Throws:

JMSException

Method Detail

close

public void close()
           throws JMSException

Specified by:

close in interface MessageProducer

Throws:

JMSException

getDestination

public Destination getDestination()
                           throws JMSException

Specified by:

getDestination in interface MessageProducer

Throws:

JMSException

getDeliveryMode

public int getDeliveryMode()
                    throws JMSException

Specified by:

getDeliveryMode in interface MessageProducer

Throws:

JMSException

getDisableMessageID

public boolean getDisableMessageID()
                            throws JMSException

Specified by:

getDisableMessageID in interface MessageProducer

Throws:

JMSException

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws JMSException

Specified by:

getDisableMessageTimestamp in interface MessageProducer

Throws:

JMSException

getPriority

public int getPriority()
                throws JMSException

Specified by:

getPriority in interface MessageProducer

Throws:

JMSException

getTimeToLive

public long getTimeToLive()
                   throws JMSException

Specified by:

getTimeToLive in interface MessageProducer

Throws:

JMSException

send

public void send(Destination destination,
                 Message message)
          throws JMSException

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

public void send(Destination destination,
                 Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws JMSException

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

public void send(Message message)
          throws JMSException

Specified by:

send in interface MessageProducer

Specified by:

send in interface QueueSender

Throws:

JMSException

send

public void send(Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws JMSException

Specified by:

send in interface MessageProducer

Specified by:

send in interface QueueSender

Throws:

JMSException

setDeliveryMode

public void setDeliveryMode(int i)
                     throws JMSException

Specified by:

setDeliveryMode in interface MessageProducer

Throws:

JMSException

setDisableMessageID

public void setDisableMessageID(boolean b)
                         throws JMSException

Specified by:

setDisableMessageID in interface MessageProducer

Throws:

JMSException

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean b)
                                throws JMSException

Specified by:

setDisableMessageTimestamp in interface MessageProducer

Throws:

JMSException

setPriority

public void setPriority(int i)
                 throws JMSException

Specified by:

setPriority in interface MessageProducer

Throws:

JMSException

setTimeToLive

public void setTimeToLive(long l)
                   throws JMSException

Specified by:

setTimeToLive in interface MessageProducer

Throws:

JMSException

getQueue

public Queue getQueue()
               throws JMSException

Specified by:

getQueue in interface QueueSender

Throws:

JMSException

send

public void send(Queue arg0,
                 Message arg1)
          throws JMSException

Specified by:

send in interface QueueSender

Throws:

JMSException

send

public void send(Queue arg0,
                 Message arg1,
                 int arg2,
                 int arg3,
                 long arg4)
          throws JMSException

Specified by:

send in interface QueueSender

Throws:

JMSException

getTopic

public Topic getTopic()
               throws JMSException

Specified by:

getTopic in interface TopicPublisher

Throws:

JMSException

publish

public void publish(Message arg0)
             throws JMSException

Specified by:

publish in interface TopicPublisher

Throws:

JMSException

publish

public void publish(Message arg0,
                    int arg1,
                    int arg2,
                    long arg3)
             throws JMSException

Specified by:

publish in interface TopicPublisher

Throws:

JMSException

publish

public void publish(Topic arg0,
                    Message arg1)
             throws JMSException

Specified by:

publish in interface TopicPublisher

Throws:

JMSException

publish

public void publish(Topic arg0,
                    Message arg1,
                    int arg2,
                    int arg3,
                    long arg4)
             throws JMSException

Specified by:

publish in interface TopicPublisher

Throws:

JMSException