org.jencks.amqpool
Class PooledTopicPublisher
java.lang.Object
org.jencks.amqpool.PooledProducer
org.jencks.amqpool.PooledTopicPublisher
- All Implemented Interfaces:
- javax.jms.MessageProducer, javax.jms.TopicPublisher
public class PooledTopicPublisher
- extends PooledProducer
- implements javax.jms.TopicPublisher
- Version:
- $Revision: 171 $
Constructor Summary |
PooledTopicPublisher(org.apache.activemq.ActiveMQTopicPublisher messageProducer,
javax.jms.Destination destination)
|
Method Summary |
javax.jms.Topic |
getTopic()
|
protected org.apache.activemq.ActiveMQTopicPublisher |
getTopicPublisher()
|
void |
publish(javax.jms.Message message)
|
void |
publish(javax.jms.Message message,
int i,
int i1,
long l)
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message)
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message,
int i,
int i1,
long l)
|
Methods inherited from class org.jencks.amqpool.PooledProducer |
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getMessageProducer, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface javax.jms.MessageProducer |
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive |
PooledTopicPublisher
public PooledTopicPublisher(org.apache.activemq.ActiveMQTopicPublisher messageProducer,
javax.jms.Destination destination)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getTopic
public javax.jms.Topic getTopic()
throws javax.jms.JMSException
- Specified by:
getTopic
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Message message,
int i,
int i1,
long l)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Topic topic,
javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Topic topic,
javax.jms.Message message,
int i,
int i1,
long l)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
getTopicPublisher
protected org.apache.activemq.ActiveMQTopicPublisher getTopicPublisher()
Copyright © 2009 LogicBlaze, Inc.. All Rights Reserved.