01: package org.mockejb.jms;
02:
03: import javax.jms.JMSException;
04: import javax.jms.Topic;
05: import javax.jms.TopicSubscriber;
06:
07: /**
08: * @author Dimitar Gospodinov
09: */
10: public class TopicSubscriberImpl extends MockConsumer implements
11: TopicSubscriber {
12:
13: /**
14: * Creates topic subscriber for the specified session and topic.
15: * @param sess session
16: * @param topic topic
17: */
18: public TopicSubscriberImpl(MockSession sess, MockTopic topic) {
19: super (sess, topic);
20: }
21:
22: /**
23: * @see javax.jms.TopicSubscriber#getTopic()
24: */
25: public Topic getTopic() throws JMSException {
26: return (Topic) getDestination();
27: }
28:
29: /**
30: * @see javax.jms.TopicSubscriber#getNoLocal()
31: */
32: public boolean getNoLocal() throws JMSException {
33: return false;
34: }
35:
36: }
|