1 21 package com.presumo.jms.client; 22 23 import javax.jms.IllegalStateException ; 24 import javax.jms.JMSException ; 25 import javax.jms.Message ; 26 import javax.jms.Topic ; 27 import javax.jms.TopicPublisher ; 28 29 35 public final class JmsTopicPublisher extends JmsMessageProducer 36 implements TopicPublisher 37 { 38 39 private final JmsTopic topic; 40 41 45 JmsTopicPublisher(JmsTopicSession session, JmsTopic topic) 46 { 47 super(session); 48 this.topic = topic; 49 } 50 51 52 56 57 public Topic getTopic() throws JMSException 58 { 59 return topic; 60 } 61 62 63 public final void publish(Message message) throws JMSException 64 { 65 prepareAndSend(this.topic, message, this.deliveryMode, 66 this.priority, this.timeToLive); 67 } 68 69 70 public final void publish(Message message, 71 int deliveryMode, 72 int priority, 73 long timeToLive) throws JMSException 74 { 75 prepareAndSend(this.topic, message, deliveryMode, priority, timeToLive); 76 } 77 78 79 80 public final void publish(Topic topic, Message message) throws JMSException 81 { 82 prepareAndSend(topic, message, this.deliveryMode, 83 this.priority, this.timeToLive); 84 } 85 86 87 88 public final void publish(Topic topic, 89 Message message, 90 int deliveryMode, 91 int priority, 92 long timeToLive) throws JMSException 93 { 94 prepareAndSend(topic, message, deliveryMode, priority, timeToLive); 95 } 96 97 } | Popular Tags |