org.apache.qpid.client
Class TopicPublisherAdapter
java.lang.Object
org.apache.qpid.client.TopicPublisherAdapter
- All Implemented Interfaces:
- MessageProducer, TopicPublisher
public class TopicPublisherAdapter
- extends Object
- implements TopicPublisher
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 |
TopicPublisherAdapter
public TopicPublisherAdapter(BasicMessageProducer msgProducer,
Topic topic)
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