1 7 package org.jboss.jms.serverless; 8 9 import org.jboss.logging.Logger; 10 import javax.jms.Topic ; 11 import javax.jms.TopicSubscriber ; 12 import javax.jms.JMSException ; 13 import javax.jms.MessageListener ; 14 15 21 class TopicSubscriberImpl extends MessageConsumerImpl implements TopicSubscriber { 22 23 private static final Logger log = Logger.getLogger(TopicSubscriberImpl.class); 24 25 TopicSubscriberImpl(SessionImpl session, Topic topic) { 26 27 super(session, topic); 28 } 29 30 34 public void close() throws JMSException { 35 throw new NotImplementedException(); 36 } 37 38 39 43 public Topic getTopic() throws JMSException { 44 return (Topic )getDestination(); 45 } 46 47 public boolean getNoLocal() throws JMSException { 48 throw new NotImplementedException(); 49 } 50 } 51 | Popular Tags |