org.fusesource.stompjms
Class StompJmsTopicPublisher

java.lang.Object
  org.fusesource.stompjms.StompJmsMessageProducer
      org.fusesource.stompjms.StompJmsTopicPublisher

All Implemented Interfaces:

javax.jms.MessageProducer, javax.jms.TopicPublisher

public class StompJmsTopicPublisher
extends StompJmsMessageProducer
implements javax.jms.TopicPublisher

Implementation of a TopicPublisher

Field Summary

Fields inherited from class org.fusesource.stompjms.StompJmsMessageProducer

closed, deliveryMode, destination, disableMessageId, disableTimestamp, flexibleDestination, priority, session, timeToLive

Constructor Summary

protected

StompJmsTopicPublisher(StompJmsSession s, StompJmsDestination destination) Constructor

Method Summary

javax.jms.Topic	getTopic()
void	publish(javax.jms.Message message)
void	publish(javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
void	publish(javax.jms.Topic topic, javax.jms.Message message)
void	publish(javax.jms.Topic topic, javax.jms.Message message, int deliveryMode, int priority, long timeToLive)

Methods inherited from class org.fusesource.stompjms.StompJmsMessageProducer

checkClosed, close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDestination, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

StompJmsTopicPublisher

protected StompJmsTopicPublisher(StompJmsSession s,
                                 StompJmsDestination destination)

Constructor

Parameters:

s -

destination -

Method Detail

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.IllegalStateException

Specified by:

getTopic in interface javax.jms.TopicPublisher

Returns:

the Topic

Throws:

javax.jms.IllegalStateException

See Also:

TopicPublisher.getTopic()

publish

public void publish(javax.jms.Message message)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

Parameters:

message -

Throws:

javax.jms.JMSException

See Also:

TopicPublisher.publish(javax.jms.Message)

publish

public void publish(javax.jms.Topic topic,
                    javax.jms.Message message)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

Parameters:

topic -

message -

Throws:

javax.jms.JMSException

See Also:

TopicPublisher.publish(javax.jms.Topic, javax.jms.Message)

publish

public void publish(javax.jms.Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

Parameters:

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

See Also:

TopicPublisher.publish(javax.jms.Message, int, int, long)

publish

public void publish(javax.jms.Topic topic,
                    javax.jms.Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws javax.jms.JMSException

Specified by:

publish in interface javax.jms.TopicPublisher

Parameters:

topic -

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

See Also:

TopicPublisher.publish(javax.jms.Topic, javax.jms.Message, int, int, long)