diff --git a/activemq-ra/src/main/java/org/activemq/ra/InboundSessionProxy.java b/activemq-ra/src/main/java/org/activemq/ra/InboundSessionProxy.java index e98dd619db..0594e66113 100755 --- a/activemq-ra/src/main/java/org/activemq/ra/InboundSessionProxy.java +++ b/activemq-ra/src/main/java/org/activemq/ra/InboundSessionProxy.java @@ -20,6 +20,7 @@ package org.activemq.ra; import javax.jms.*; + import java.io.Serializable; /** @@ -219,4 +220,13 @@ public class InboundSessionProxy implements Session, QueueSession, TopicSession public TopicPublisher createPublisher(Topic topic) throws JMSException { return getTopicSession().createPublisher(topic); } + + public String toString() { + try { + return "InboundSessionProxy { "+getSession()+" }"; + } catch (JMSException e) { + return "InboundSessionProxy { null }"; + } + } + } diff --git a/activemq-ra/src/main/java/org/activemq/ra/ManagedSessionProxy.java b/activemq-ra/src/main/java/org/activemq/ra/ManagedSessionProxy.java index d45d2d1b18..85c1f36cbf 100755 --- a/activemq-ra/src/main/java/org/activemq/ra/ManagedSessionProxy.java +++ b/activemq-ra/src/main/java/org/activemq/ra/ManagedSessionProxy.java @@ -403,4 +403,8 @@ public class ManagedSessionProxy implements Session, QueueSession, TopicSession throw new RuntimeException("Operation not supported."); } + public String toString() { + return "ManagedSessionProxy { "+session+" }"; + } + }