org.apache.qpid.client
Class TopicPublisherAdapter

java.lang.Object
  extended by org.apache.qpid.client.TopicPublisherAdapter
All Implemented Interfaces:
MessageProducer, TopicPublisher

public class TopicPublisherAdapter
extends Object
implements TopicPublisher


Constructor Summary
TopicPublisherAdapter(BasicMessageProducer msgProducer, Topic topic)
           
 
Method Summary
 void close()
           
 int getDeliveryMode()
           
 Destination getDestination()
           
 boolean getDisableMessageID()
           
 boolean getDisableMessageTimestamp()
           
 int getPriority()
           
 long getTimeToLive()
           
 Topic getTopic()
           
 void publish(Message msg)
           
 void publish(Message msg, int deliveryMode, int priority, long timeToLive)
           
 void publish(Topic topic, Message msg)
           
 void publish(Topic topic, Message msg, int deliveryMode, int priority, long timeToLive)
           
 void send(Destination dest, Message msg)
           
 void send(Destination dest, Message msg, int deliveryMode, int priority, long timeToLive)
           
 void send(Message msg)
           
 void send(Message msg, int deliveryMode, int priority, long timeToLive)
           
 void setDeliveryMode(int deliveryMode)
           
 void setDisableMessageID(boolean disableMessageID)
           
 void setDisableMessageTimestamp(boolean disableMessageTimestamp)
           
 void setPriority(int priority)
           
 void setTimeToLive(long timeToLive)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicPublisherAdapter

public TopicPublisherAdapter(BasicMessageProducer msgProducer,
                             Topic topic)
Method Detail

getTopic

public Topic getTopic()
               throws JMSException
Specified by:
getTopic in interface TopicPublisher
Throws:
JMSException

publish

public void publish(Message msg)
             throws JMSException
Specified by:
publish in interface TopicPublisher
Throws:
JMSException

publish

public void publish(Topic topic,
                    Message msg)
             throws JMSException
Specified by:
publish in interface TopicPublisher
Throws:
JMSException

publish

public void publish(Message msg,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws JMSException
Specified by:
publish in interface TopicPublisher
Throws:
JMSException

getDeliveryMode

public int getDeliveryMode()
                    throws JMSException
Specified by:
getDeliveryMode in interface MessageProducer
Throws:
JMSException

publish

public void publish(Topic topic,
                    Message msg,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws JMSException
Specified by:
publish in interface TopicPublisher
Throws:
JMSException

close

public void close()
           throws JMSException
Specified by:
close 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

getDestination

public Destination getDestination()
                           throws JMSException
Specified by:
getDestination 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(Message msg)
          throws JMSException
Specified by:
send in interface MessageProducer
Throws:
JMSException

send

public void send(Destination dest,
                 Message msg)
          throws JMSException
Specified by:
send in interface MessageProducer
Throws:
JMSException

send

public void send(Message msg,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws JMSException
Specified by:
send in interface MessageProducer
Throws:
JMSException

send

public void send(Destination dest,
                 Message msg,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws JMSException
Specified by:
send in interface MessageProducer
Throws:
JMSException

setDeliveryMode

public void setDeliveryMode(int deliveryMode)
                     throws JMSException
Specified by:
setDeliveryMode in interface MessageProducer
Throws:
JMSException

setDisableMessageID

public void setDisableMessageID(boolean disableMessageID)
                         throws JMSException
Specified by:
setDisableMessageID in interface MessageProducer
Throws:
JMSException

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean disableMessageTimestamp)
                                throws JMSException
Specified by:
setDisableMessageTimestamp in interface MessageProducer
Throws:
JMSException

setPriority

public void setPriority(int priority)
                 throws JMSException
Specified by:
setPriority in interface MessageProducer
Throws:
JMSException

setTimeToLive

public void setTimeToLive(long timeToLive)
                   throws JMSException
Specified by:
setTimeToLive in interface MessageProducer
Throws:
JMSException


Licensed to the Apache Software Foundation