Repository: tomee Updated Branches: refs/heads/tomee-1.7.x 43dd894b0 -> 8937e538c
PMD Project: http://git-wip-us.apache.org/repos/asf/tomee/repo Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/8937e538 Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/8937e538 Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/8937e538 Branch: refs/heads/tomee-1.7.x Commit: 8937e538ccc7f9560a23800283c664960452f957 Parents: 43dd894 Author: AndyGee <andy...@gmx.de> Authored: Wed Nov 18 20:30:34 2015 +0100 Committer: AndyGee <andy...@gmx.de> Committed: Wed Nov 18 20:30:34 2015 +0100 ---------------------------------------------------------------------- .../resource/activemq/ConnectionWrapper.java | 18 ++++++++++-- .../resource/activemq/SessionWrapper.java | 31 ++++++++++++++++---- 2 files changed, 41 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tomee/blob/8937e538/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ConnectionWrapper.java ---------------------------------------------------------------------- diff --git a/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ConnectionWrapper.java b/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ConnectionWrapper.java index 6dd90ef..a4a7018 100644 --- a/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ConnectionWrapper.java +++ b/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ConnectionWrapper.java @@ -10,7 +10,15 @@ */ package org.apache.openejb.resource.activemq; -import javax.jms.*; +import javax.jms.Connection; +import javax.jms.ConnectionConsumer; +import javax.jms.ConnectionMetaData; +import javax.jms.Destination; +import javax.jms.ExceptionListener; +import javax.jms.JMSException; +import javax.jms.ServerSessionPool; +import javax.jms.Session; +import javax.jms.Topic; import java.util.ArrayList; import java.util.Iterator; @@ -108,8 +116,12 @@ public class ConnectionWrapper implements Connection { @Override public boolean equals(final Object o) { - if (this == o) return true; - if (o == null || getClass() != o.getClass()) return false; + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } final ConnectionWrapper that = (ConnectionWrapper) o; http://git-wip-us.apache.org/repos/asf/tomee/blob/8937e538/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/SessionWrapper.java ---------------------------------------------------------------------- diff --git a/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/SessionWrapper.java b/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/SessionWrapper.java index f7f5ef8..8d45658 100644 --- a/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/SessionWrapper.java +++ b/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/SessionWrapper.java @@ -10,7 +10,24 @@ */ package org.apache.openejb.resource.activemq; -import javax.jms.*; +import javax.jms.BytesMessage; +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.MapMessage; +import javax.jms.Message; +import javax.jms.MessageConsumer; +import javax.jms.MessageListener; +import javax.jms.MessageProducer; +import javax.jms.ObjectMessage; +import javax.jms.Queue; +import javax.jms.QueueBrowser; +import javax.jms.Session; +import javax.jms.StreamMessage; +import javax.jms.TemporaryQueue; +import javax.jms.TemporaryTopic; +import javax.jms.TextMessage; +import javax.jms.Topic; +import javax.jms.TopicSubscriber; import java.io.Serializable; public class SessionWrapper implements Session { @@ -49,8 +66,8 @@ public class SessionWrapper implements Session { } @Override - public MessageConsumer createConsumer(final Destination destination, final String messageSelector, final boolean NoLocal) throws JMSException { - return session.createConsumer(destination, messageSelector, NoLocal); + public MessageConsumer createConsumer(final Destination destination, final String messageSelector, final boolean noLocal) throws JMSException { + return session.createConsumer(destination, messageSelector, noLocal); } @Override @@ -179,8 +196,12 @@ public class SessionWrapper implements Session { @Override public boolean equals(final Object o) { - if (this == o) return true; - if (o == null || getClass() != o.getClass()) return false; + if (this == o) { + return true; + } + if (o == null || getClass() != o.getClass()) { + return false; + } final SessionWrapper that = (SessionWrapper) o;
