@Test public void testGetNoLocal() throws JMSException { JmsPoolConnection connection = (JmsPoolConnection) cf.createTopicConnection(); TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); Topic topic = session.createTemporaryTopic(); TopicSubscriber subscriber = session.createDurableSubscriber(topic, "name", "color = red", true); assertTrue(subscriber.getNoLocal()); subscriber.close(); try { subscriber.getNoLocal(); fail("Cannot read state on closed subscriber"); } catch (IllegalStateException ise) {} }
@Override public boolean getNoLocal() throws JMSException { return getTopicSubscriber().getNoLocal(); }
JmsPoolTopicSubscriber extends JmsPoolMessageConsumer implements TopicSubscriber, AutoCloseable { @Override public boolean getNoLocal() throws JMSException { return getTopicSubscriber().getNoLocal(); } }
JmsPoolTopicSubscriber extends JmsPoolMessageConsumer implements TopicSubscriber, AutoCloseable { @Override public boolean getNoLocal() throws JMSException { return getTopicSubscriber().getNoLocal(); } JmsPoolTopicSubscriber(JmsPoolSession session, TopicSubscriber delegate); }
JmsPoolTopicSubscriber extends JmsPoolMessageConsumer implements TopicSubscriber, AutoCloseable { @Override public boolean getNoLocal() throws JMSException { return getTopicSubscriber().getNoLocal(); } JmsPoolTopicSubscriber(JmsPoolSession session, TopicSubscriber delegate); @Override Topic getTopic(); @Override boolean getNoLocal(); @Override String toString(); TopicSubscriber getTopicSubscriber(); }
JmsPoolTopicSubscriber extends JmsPoolMessageConsumer implements TopicSubscriber, AutoCloseable { @Override public boolean getNoLocal() throws JMSException { return getTopicSubscriber().getNoLocal(); } JmsPoolTopicSubscriber(JmsPoolSession session, TopicSubscriber delegate); @Override Topic getTopic(); @Override boolean getNoLocal(); @Override String toString(); TopicSubscriber getTopicSubscriber();  }