org.codehaus.activemq.ra.jms
Class MessageProducerProxy

java.lang.Object
  extended byorg.codehaus.activemq.ra.jms.MessageProducerProxy
All Implemented Interfaces:
MessageProducer

public class MessageProducerProxy
extends Object
implements MessageProducer

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

Version:
$Revision: 1.1 $

Constructor Summary
MessageProducerProxy(MessageProducer messageProducer, Destination destination)
           
 
Method Summary
 void close()
           
 int getDeliveryMode()
           
 Destination getDestination()
           
 boolean getDisableMessageID()
           
 boolean getDisableMessageTimestamp()
           
 int getPriority()
           
 long getTimeToLive()
           
 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 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

MessageProducerProxy

public MessageProducerProxy(MessageProducer messageProducer,
                            Destination destination)
                     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
Throws:
JMSException

send

public void send(Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws JMSException
Specified by:
send in interface MessageProducer
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


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.