@Test(timeout = 30000, expected=IllegalStateException.class) public void testCreateTopicSessionOnTopicConnection() throws JMSException{ queueConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); }
@Override public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException { throw new javax.jms.IllegalStateException("Operation not supported by a QueueConnection"); }
JmsQueueConnection extends JmsConnection implements AutoCloseable { @Override public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException { throw new javax.jms.IllegalStateException("Operation not supported by a QueueConnection"); } }
JmsQueueConnection extends JmsConnection implements AutoCloseable { @Override public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException { throw new javax.jms.IllegalStateException("Operation not supported by a QueueConnection"); } JmsQueueConnection(JmsConnectionInfo connectionInfo, Provider provider); }
JmsQueueConnection extends JmsConnection implements AutoCloseable { @Override public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException { throw new javax.jms.IllegalStateException("Operation not supported by a QueueConnection"); } JmsQueueConnection(JmsConnectionInfo connectionInfo, Provider provider); @Override TopicSession createTopicSession(boolean transacted, int acknowledgeMode); @Override ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages); }
JmsQueueConnection extends JmsConnection implements AutoCloseable { @Override public TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws JMSException { throw new javax.jms.IllegalStateException("Operation not supported by a QueueConnection"); } JmsQueueConnection(JmsConnectionInfo connectionInfo, Provider provider); @Override TopicSession createTopicSession(boolean transacted, int acknowledgeMode); @Override ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages);  }