1 22 package org.jboss.mq; 23 24 import javax.jms.InvalidSelectorException ; 25 import javax.jms.JMSException ; 26 import javax.jms.Topic ; 27 import javax.jms.TopicSubscriber ; 28 29 37 public class SpyTopicSubscriber extends SpyMessageConsumer implements TopicSubscriber 38 { 39 48 SpyTopicSubscriber(SpySession session, SpyTopic topic, boolean noLocal, String selector) 49 throws InvalidSelectorException 50 { 51 super(session, false, topic, selector, noLocal); 52 } 53 54 public Topic getTopic() throws JMSException 55 { 56 return (Topic ) getDestination(); 57 } 58 59 public boolean getNoLocal() throws JMSException 60 { 61 return super.getNoLocal(); 62 } 63 } | Popular Tags |