Repository: qpid-jms Updated Branches: refs/heads/master 512863e23 -> fba50f1c3
QPIDJMS-135 Adds AutoCloseable to the JMS resources. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/fba50f1c Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/fba50f1c Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/fba50f1c Branch: refs/heads/master Commit: fba50f1c3c122a62d0bb96886966f68b1a02e0f1 Parents: 512863e Author: Timothy Bish <tabish...@gmail.com> Authored: Thu Oct 29 12:08:47 2015 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Thu Oct 29 12:08:47 2015 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/qpid/jms/JmsConnection.java | 2 +- .../main/java/org/apache/qpid/jms/JmsDurableTopicSubscriber.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsMessageConsumer.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsMessageProducer.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsQueueConnection.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsQueueReceiver.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsQueueSender.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsQueueSession.java | 2 +- qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsTopicConnection.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsTopicPublisher.java | 2 +- .../src/main/java/org/apache/qpid/jms/JmsTopicSession.java | 2 +- 13 files changed, 13 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java index 7094f58..7a243f1 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java @@ -82,7 +82,7 @@ import org.slf4j.LoggerFactory; /** * Implementation of a JMS Connection */ -public class JmsConnection implements Connection, TopicConnection, QueueConnection, ProviderListener { +public class JmsConnection implements AutoCloseable, Connection, TopicConnection, QueueConnection, ProviderListener { private static final Logger LOG = LoggerFactory.getLogger(JmsConnection.class); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsDurableTopicSubscriber.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsDurableTopicSubscriber.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsDurableTopicSubscriber.java index 3a45736..94d2d56 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsDurableTopicSubscriber.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsDurableTopicSubscriber.java @@ -23,7 +23,7 @@ import org.apache.qpid.jms.meta.JmsConsumerId; /** * Implementation of a TopicSubscriber that is Durable */ -public class JmsDurableTopicSubscriber extends JmsTopicSubscriber { +public class JmsDurableTopicSubscriber extends JmsTopicSubscriber implements AutoCloseable { public JmsDurableTopicSubscriber(JmsConsumerId id, JmsSession s, JmsDestination destination, String name, boolean noLocal, String selector) throws JMSException { super(id, s, destination, name, noLocal, selector); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageConsumer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageConsumer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageConsumer.java index 3e182f8..100b677 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageConsumer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageConsumer.java @@ -46,7 +46,7 @@ import org.slf4j.LoggerFactory; /** * implementation of a JMS Message Consumer */ -public class JmsMessageConsumer implements MessageConsumer, JmsMessageAvailableConsumer, JmsMessageDispatcher { +public class JmsMessageConsumer implements AutoCloseable, MessageConsumer, JmsMessageAvailableConsumer, JmsMessageDispatcher { private static final Logger LOG = LoggerFactory.getLogger(JmsMessageConsumer.class); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java index a830760..09b7e7e 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java @@ -35,7 +35,7 @@ import org.apache.qpid.jms.provider.ProviderFuture; /** * Implementation of a JMS MessageProducer */ -public class JmsMessageProducer implements MessageProducer { +public class JmsMessageProducer implements AutoCloseable, MessageProducer { protected final JmsSession session; protected final JmsConnection connection; http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java index af1096b..71b12c3 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java @@ -54,7 +54,7 @@ import org.slf4j.LoggerFactory; * @see javax.jms.QueueBrowser * @see javax.jms.QueueReceiver */ -public class JmsQueueBrowser implements QueueBrowser, Enumeration<Message> { +public class JmsQueueBrowser implements AutoCloseable, QueueBrowser, Enumeration<Message> { protected static final Logger LOG = LoggerFactory.getLogger(JmsQueueBrowser.class); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueConnection.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueConnection.java index 39eadeb..c44645d 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueConnection.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueConnection.java @@ -25,7 +25,7 @@ import javax.jms.TopicSession; import org.apache.qpid.jms.provider.Provider; import org.apache.qpid.jms.util.IdGenerator; -public class JmsQueueConnection extends JmsConnection { +public class JmsQueueConnection extends JmsConnection implements AutoCloseable { public JmsQueueConnection(String connectionId, Provider provider, IdGenerator clientIdGenerator) throws JMSException { super(connectionId, provider, clientIdGenerator); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueReceiver.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueReceiver.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueReceiver.java index e2b3596..d028fbd 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueReceiver.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueReceiver.java @@ -26,7 +26,7 @@ import org.apache.qpid.jms.meta.JmsConsumerId; /** * Implementation of a JMS QueueReceiver */ -public class JmsQueueReceiver extends JmsMessageConsumer implements QueueReceiver { +public class JmsQueueReceiver extends JmsMessageConsumer implements AutoCloseable, QueueReceiver { /** * Constructor http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSender.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSender.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSender.java index 11b65f0..ae8862a 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSender.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSender.java @@ -27,7 +27,7 @@ import org.apache.qpid.jms.meta.JmsProducerId; /** * Implementation of a Queue Sender */ -public class JmsQueueSender extends JmsMessageProducer implements QueueSender { +public class JmsQueueSender extends JmsMessageProducer implements AutoCloseable, QueueSender { protected JmsQueueSender(JmsProducerId id, JmsSession session, JmsDestination destination) throws JMSException { super(id, session, destination); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSession.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSession.java index c7063a1..e0509f1 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueSession.java @@ -31,7 +31,7 @@ import org.apache.qpid.jms.meta.JmsSessionId; /** * JMS QueueSession implementation */ -public class JmsQueueSession extends JmsSession { +public class JmsQueueSession extends JmsSession implements AutoCloseable { protected JmsQueueSession(JmsConnection connection, JmsSessionId sessionId, int acknowledgementMode) throws JMSException { super(connection, sessionId, acknowledgementMode); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java index 5d54ab1..bc1afcd 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java @@ -81,7 +81,7 @@ import org.slf4j.LoggerFactory; /** * JMS Session implementation */ -public class JmsSession implements Session, QueueSession, TopicSession, JmsMessageDispatcher { +public class JmsSession implements AutoCloseable, Session, QueueSession, TopicSession, JmsMessageDispatcher { private static final Logger LOG = LoggerFactory.getLogger(JmsSession.class); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicConnection.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicConnection.java index c8fcaba..be464c4 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicConnection.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicConnection.java @@ -25,7 +25,7 @@ import javax.jms.ServerSessionPool; import org.apache.qpid.jms.provider.Provider; import org.apache.qpid.jms.util.IdGenerator; -public class JmsTopicConnection extends JmsConnection { +public class JmsTopicConnection extends JmsConnection implements AutoCloseable { public JmsTopicConnection(String connectionId, Provider provider, IdGenerator clientIdGenerator) throws JMSException { super(connectionId, provider, clientIdGenerator); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicPublisher.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicPublisher.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicPublisher.java index 2aba406..b34aa5b 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicPublisher.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicPublisher.java @@ -27,7 +27,7 @@ import org.apache.qpid.jms.meta.JmsProducerId; /** * Implementation of a TopicPublisher */ -public class JmsTopicPublisher extends JmsMessageProducer implements TopicPublisher { +public class JmsTopicPublisher extends JmsMessageProducer implements AutoCloseable, TopicPublisher { protected JmsTopicPublisher(JmsProducerId id, JmsSession session, JmsDestination destination) throws JMSException { super(id, session, destination); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fba50f1c/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicSession.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicSession.java index b9d3505..1c8878d 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsTopicSession.java @@ -32,7 +32,7 @@ import org.apache.qpid.jms.meta.JmsSessionId; /** * Implementation of a TopicSession */ -public class JmsTopicSession extends JmsSession { +public class JmsTopicSession extends JmsSession implements AutoCloseable { protected JmsTopicSession(JmsConnection connection, JmsSessionId sessionId, int acknowledgementMode) throws JMSException { super(connection, sessionId, acknowledgementMode); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
