Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> ra >> [ jms overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.ra.jms
Class MessageProducerProxy  

java.lang.Object
  org.activemq.ra.jms.MessageProducerProxy

All Implemented Interfaces:

javax.jms.MessageProducer, javax.jms.QueueSender, javax.jms.TopicPublisher

---

public class MessageProducerProxy

extends java.lang.Object

implements javax.jms.MessageProducer, javax.jms.QueueSender, javax.jms.TopicPublisher

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

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private  int	deliveryMode
private  javax.jms.Destination	destination
private  boolean	disableMessageID
private  boolean	disableMessageTimestamp
private  javax.jms.MessageProducer	messageProducer
private  int	priority
private  long	timeToLive

 

Constructor Summary

MessageProducerProxy(javax.jms.MessageProducer messageProducer, javax.jms.Destination destination)

 

Method Summary
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)

 

Methods inherited from class java.lang.Object

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

 

Field Detail

messageProducer

private javax.jms.MessageProducer messageProducer

---

destination

private javax.jms.Destination destination

---

deliveryMode

private int deliveryMode

---

disableMessageID

private boolean disableMessageID

---

disableMessageTimestamp

private boolean disableMessageTimestamp

---

priority

private int priority

---

timeToLive

private long timeToLive

Constructor Detail

MessageProducerProxy

public MessageProducerProxy(javax.jms.MessageProducer messageProducer,
                            javax.jms.Destination destination)
                     throws javax.jms.JMSException

Method Detail

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageProducer

---

getDestination

public javax.jms.Destination getDestination()
                                     throws javax.jms.JMSException

Specified by:

getDestination in interface javax.jms.MessageProducer

---

getDeliveryMode

public int getDeliveryMode()
                    throws javax.jms.JMSException

Specified by:

getDeliveryMode in interface javax.jms.MessageProducer

---

getDisableMessageID

public boolean getDisableMessageID()
                            throws javax.jms.JMSException

Specified by:

getDisableMessageID in interface javax.jms.MessageProducer

---

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws javax.jms.JMSException

Specified by:

getDisableMessageTimestamp in interface javax.jms.MessageProducer

---

getPriority

public int getPriority()
                throws javax.jms.JMSException

Specified by:

getPriority in interface javax.jms.MessageProducer

---

getTimeToLive

public long getTimeToLive()
                   throws javax.jms.JMSException

Specified by:

getTimeToLive in interface javax.jms.MessageProducer

---

send

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

Specified by:

send in interface javax.jms.MessageProducer

---

send

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

Specified by:

send in interface javax.jms.MessageProducer

---

send

public void send(javax.jms.Message message)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

---

send

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

Specified by:

send in interface javax.jms.MessageProducer

---

setDeliveryMode

public void setDeliveryMode(int i)
                     throws javax.jms.JMSException

Specified by:

setDeliveryMode in interface javax.jms.MessageProducer

---

setDisableMessageID

public void setDisableMessageID(boolean b)
                         throws javax.jms.JMSException

Specified by:

setDisableMessageID in interface javax.jms.MessageProducer

---

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean b)
                                throws javax.jms.JMSException

Specified by:

setDisableMessageTimestamp in interface javax.jms.MessageProducer

---

setPriority

public void setPriority(int i)
                 throws javax.jms.JMSException

Specified by:

setPriority in interface javax.jms.MessageProducer

---

setTimeToLive

public void setTimeToLive(long l)
                   throws javax.jms.JMSException

Specified by:

setTimeToLive in interface javax.jms.MessageProducer

---

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

Specified by:

getQueue in interface javax.jms.QueueSender

---

send

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

Specified by:

send in interface javax.jms.QueueSender

---

send

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

Specified by:

send in interface javax.jms.QueueSender

---

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException

Specified by:

getTopic in interface javax.jms.TopicPublisher

---

publish

public void publish(javax.jms.Message arg0)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

---

publish

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

Specified by:

publish in interface javax.jms.TopicPublisher

---

publish

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

Specified by:

publish in interface javax.jms.TopicPublisher

---

publish

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

Specified by:

publish in interface javax.jms.TopicPublisher

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> ra >> [ jms overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---