1 22 package org.jboss.mq; 23 24 import javax.jms.JMSException ; 25 import javax.jms.Message ; 26 import javax.jms.Topic ; 27 import javax.jms.TopicPublisher ; 28 29 42 public class SpyTopicPublisher extends SpyMessageProducer implements TopicPublisher 43 { 44 50 SpyTopicPublisher(SpySession s, Topic t) 51 { 52 super(s, t); 53 } 54 55 public Topic getTopic() throws JMSException 56 { 57 return (Topic ) getDestination(); 58 } 59 60 public void publish(Message message) throws JMSException 61 { 62 send(message); 63 } 64 65 public void publish(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException 66 { 67 send(message, deliveryMode, priority, timeToLive); 68 } 69 70 public void publish(Topic topic, Message message) throws JMSException 71 { 72 send(topic, message); 73 } 74 75 public void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive) 76 throws JMSException 77 { 78 send(topic, message, deliveryMode, priority, timeToLive); 79 } 80 } | Popular Tags |