org.jencks.amqpool
Class PooledTopicPublisher

java.lang.Object
  extended by org.jencks.amqpool.PooledProducer
      extended by 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
 

Constructor Detail

PooledTopicPublisher

public PooledTopicPublisher(org.apache.activemq.ActiveMQTopicPublisher messageProducer,
                            javax.jms.Destination destination)
                     throws javax.jms.JMSException
Throws:
javax.jms.JMSException
Method Detail

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.