@Test(timeout=30000) public void testGetExceptionListener() throws JMSException { connection = new JmsConnection(connectionInfo, provider); assertNull(connection.getExceptionListener()); connection.setExceptionListener(new ExceptionListener() { @Override public void onException(JMSException exception) { } }); assertNotNull(connection.getExceptionListener()); }
@Override public ExceptionListener getExceptionListener() throws JMSException { checkClosedOrFailed(); return this.exceptionListener; }
JmsConnection implements AutoCloseable, Connection, TopicConnection, QueueConnection, ProviderListener { @Override public ExceptionListener getExceptionListener() throws JMSException { checkClosedOrFailed(); return this.exceptionListener; } }
JmsConnection implements AutoCloseable, Connection, TopicConnection, QueueConnection, ProviderListener { @Override public ExceptionListener getExceptionListener() throws JMSException { checkClosedOrFailed(); return this.exceptionListener; } protected  JmsConnection(final JmsConnectionInfo connectionInfo, Provider provider); }
JmsConnection implements AutoCloseable, Connection, TopicConnection, QueueConnection, ProviderListener { @Override public ExceptionListener getExceptionListener() throws JMSException { checkClosedOrFailed(); return this.exceptionListener; } protected  JmsConnection(final JmsConnectionInfo connectionInfo, Provider provider); @Override void close(); @Override Session createSession(); @Override Session createSession(int acknowledgeMode); @Override Session createSession(boolean transacted, int acknowledgeMode); @Override synchronized String getClientID(); @Override ConnectionMetaData getMetaData(); @Override synchronized void setClientID(String clientID); @Override void start(); @Override void stop(); @Override ConnectionConsumer createSharedConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override TopicSession createTopicSession(boolean transacted, int acknowledgeMode); @Override QueueSession createQueueSession(boolean transacted, int acknowledgeMode); void onException(Exception ex); void onException(JMSException ex); @Override ExceptionListener getExceptionListener(); @Override void setExceptionListener(ExceptionListener listener); void addConnectionListener(JmsConnectionListener listener); boolean removeConnectionListener(JmsConnectionListener listener); boolean isForceAsyncSend(); void setForceAsyncSend(boolean forceAsyncSend); boolean isForceSyncSend(); void setForceSyncSend(boolean alwaysSyncSend); String getTopicPrefix(); void setTopicPrefix(String topicPrefix); String getQueuePrefix(); void setQueuePrefix(String queuePrefix); boolean isValidatePropertyNames(); void setValidatePropertyNames(boolean validatePropertyNames); JmsPrefetchPolicy getPrefetchPolicy(); void setPrefetchPolicy(JmsPrefetchPolicy prefetchPolicy); JmsRedeliveryPolicy getRedeliveryPolicy(); void setRedeliveryPolicy(JmsRedeliveryPolicy redeliveryPolicy); JmsPresettlePolicy getPresettlePolicy(); void setPresettlePolicy(JmsPresettlePolicy presettlePolicy); JmsDeserializationPolicy getDeserializationPolicy(); void setDeserializationPolicy(JmsDeserializationPolicy deserializationPolicy); boolean isReceiveLocalOnly(); void setReceiveLocalOnly(boolean receiveLocalOnly); boolean isReceiveNoWaitLocalOnly(); void setReceiveNoWaitLocalOnly(boolean receiveNoWaitLocalOnly); boolean isLocalMessagePriority(); void setLocalMessagePriority(boolean localMessagePriority); long getCloseTimeout(); void setCloseTimeout(long closeTimeout); long getConnectTimeout(); void setConnectTimeout(long connectTimeout); long getSendTimeout(); void setSendTimeout(long sendTimeout); long getRequestTimeout(); void setRequestTimeout(long requestTimeout); URI getConfiguredURI(); URI getConnectedURI(); String getUsername(); String getPassword(); boolean isConnected(); boolean isStarted(); boolean isClosed(); boolean isFailed(); JmsConnectionId getId(); JmsMessageFactory getMessageFactory(); boolean isForceAsyncAcks(); void setForceAsyncAcks(boolean forceAsyncAcks); boolean isLocalMessageExpiry(); void setLocalMessageExpiry(boolean localMessageExpiry); JmsMessageIDPolicy getMessageIDPolicy(); void setMessageIDPolicy(JmsMessageIDPolicy messageIDPolicy); boolean isPopulateJMSXUserID(); void setPopulateJMSXUserID(boolean populateJMSXUserID); boolean isUseDaemonThread(); boolean isCloseLinksThatFailOnReconnect(); void setCloseLinksThatFailOnReconnect(boolean closeLinksThatFailOnReconnect); @Override void onInboundMessage(final JmsInboundMessageDispatch envelope); @Override void onCompletedMessageSend(JmsOutboundMessageDispatch envelope); @Override void onFailedMessageSend(JmsOutboundMessageDispatch envelope, ProviderException cause); @Override void onConnectionInterrupted(final URI remoteURI); @Override void onConnectionRecovery(Provider provider); @Override void onConnectionRecovered(Provider provider); @Override void onConnectionRestored(final URI remoteURI); @Override void onConnectionEstablished(final URI remoteURI); @Override void onConnectionFailure(final ProviderException ex); @Override void onResourceClosed(final JmsResource resource, final ProviderException cause); @Override void onProviderException(final ProviderException cause); void onAsyncException(Throwable error); }
JmsConnection implements AutoCloseable, Connection, TopicConnection, QueueConnection, ProviderListener { @Override public ExceptionListener getExceptionListener() throws JMSException { checkClosedOrFailed(); return this.exceptionListener; } protected  JmsConnection(final JmsConnectionInfo connectionInfo, Provider provider); @Override void close(); @Override Session createSession(); @Override Session createSession(int acknowledgeMode); @Override Session createSession(boolean transacted, int acknowledgeMode); @Override synchronized String getClientID(); @Override ConnectionMetaData getMetaData(); @Override synchronized void setClientID(String clientID); @Override void start(); @Override void stop(); @Override ConnectionConsumer createSharedConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createSharedDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages); @Override TopicSession createTopicSession(boolean transacted, int acknowledgeMode); @Override QueueSession createQueueSession(boolean transacted, int acknowledgeMode); void onException(Exception ex); void onException(JMSException ex); @Override ExceptionListener getExceptionListener(); @Override void setExceptionListener(ExceptionListener listener); void addConnectionListener(JmsConnectionListener listener); boolean removeConnectionListener(JmsConnectionListener listener); boolean isForceAsyncSend(); void setForceAsyncSend(boolean forceAsyncSend); boolean isForceSyncSend(); void setForceSyncSend(boolean alwaysSyncSend); String getTopicPrefix(); void setTopicPrefix(String topicPrefix); String getQueuePrefix(); void setQueuePrefix(String queuePrefix); boolean isValidatePropertyNames(); void setValidatePropertyNames(boolean validatePropertyNames); JmsPrefetchPolicy getPrefetchPolicy(); void setPrefetchPolicy(JmsPrefetchPolicy prefetchPolicy); JmsRedeliveryPolicy getRedeliveryPolicy(); void setRedeliveryPolicy(JmsRedeliveryPolicy redeliveryPolicy); JmsPresettlePolicy getPresettlePolicy(); void setPresettlePolicy(JmsPresettlePolicy presettlePolicy); JmsDeserializationPolicy getDeserializationPolicy(); void setDeserializationPolicy(JmsDeserializationPolicy deserializationPolicy); boolean isReceiveLocalOnly(); void setReceiveLocalOnly(boolean receiveLocalOnly); boolean isReceiveNoWaitLocalOnly(); void setReceiveNoWaitLocalOnly(boolean receiveNoWaitLocalOnly); boolean isLocalMessagePriority(); void setLocalMessagePriority(boolean localMessagePriority); long getCloseTimeout(); void setCloseTimeout(long closeTimeout); long getConnectTimeout(); void setConnectTimeout(long connectTimeout); long getSendTimeout(); void setSendTimeout(long sendTimeout); long getRequestTimeout(); void setRequestTimeout(long requestTimeout); URI getConfiguredURI(); URI getConnectedURI(); String getUsername(); String getPassword(); boolean isConnected(); boolean isStarted(); boolean isClosed(); boolean isFailed(); JmsConnectionId getId(); JmsMessageFactory getMessageFactory(); boolean isForceAsyncAcks(); void setForceAsyncAcks(boolean forceAsyncAcks); boolean isLocalMessageExpiry(); void setLocalMessageExpiry(boolean localMessageExpiry); JmsMessageIDPolicy getMessageIDPolicy(); void setMessageIDPolicy(JmsMessageIDPolicy messageIDPolicy); boolean isPopulateJMSXUserID(); void setPopulateJMSXUserID(boolean populateJMSXUserID); boolean isUseDaemonThread(); boolean isCloseLinksThatFailOnReconnect(); void setCloseLinksThatFailOnReconnect(boolean closeLinksThatFailOnReconnect); @Override void onInboundMessage(final JmsInboundMessageDispatch envelope); @Override void onCompletedMessageSend(JmsOutboundMessageDispatch envelope); @Override void onFailedMessageSend(JmsOutboundMessageDispatch envelope, ProviderException cause); @Override void onConnectionInterrupted(final URI remoteURI); @Override void onConnectionRecovery(Provider provider); @Override void onConnectionRecovered(Provider provider); @Override void onConnectionRestored(final URI remoteURI); @Override void onConnectionEstablished(final URI remoteURI); @Override void onConnectionFailure(final ProviderException ex); @Override void onResourceClosed(final JmsResource resource, final ProviderException cause); @Override void onProviderException(final ProviderException cause); void onAsyncException(Throwable error);  }