Fixed: https://jira.logicblaze.com/jira/browse/AMQ-426

JMS api object now implement a toString() that can be used to correlate back to log messages on the message broker.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@358371 13f79535-47bb-0310-9956-ffa450edef68

activemq-core/src/main/java/org/activemq/ActiveMQConnection.java

@@ -1542,4 +1542,8 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
     public void setCopyMessageOnSend(boolean copyMessageOnSend) {
         this.copyMessageOnSend = copyMessageOnSend;
     }
+    
+    public String toString() {
+        return "ActiveMQConnection {id="+info.getConnectionId()+",clientId"+info.getClientId()+",started="+started.get()+"}";
+    }
 }

activemq-core/src/main/java/org/activemq/ActiveMQConnectionConsumer.java

@@ -148,4 +148,8 @@ public class ActiveMQConnectionConsumer implements ConnectionConsumer, ActiveMQD
             connection.onAsyncException(e);
         }
     }
+    
+    public String toString() {
+        return "ActiveMQConnectionConsumer { consumerId=" +consumerInfo.getConsumerId()+" }";
+    }
 }

activemq-core/src/main/java/org/activemq/ActiveMQInputStream.java

@@ -227,4 +227,8 @@ public class ActiveMQInputStream extends InputStream implements ActiveMQDispatch
         unconsumedMessages.enqueue(md);
     }
 
+    public String toString() {
+        return "ActiveMQInputStream { consumerId="+info.getConsumerId()+", producerId=" +producerId+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/ActiveMQMessageConsumer.java

@@ -728,4 +728,8 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
         unconsumedMessages.stop();
     }
     
+    public String toString() {
+        return "ActiveMQMessageConsumer { consumerId=" +info.getConsumerId()+", started=" +started.get()+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/ActiveMQMessageProducer.java

@@ -500,4 +500,8 @@ public class ActiveMQMessageProducer implements MessageProducer, StatsCapable, C
         this.info = info;
     }
 
+    public String toString() {
+        return "ActiveMQMessageProducer { consumerId=" +info.getProducerId()+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/ActiveMQOutputStream.java

@@ -155,4 +155,8 @@ public class ActiveMQOutputStream extends OutputStream implements Disposable {
         connection.send(info.getDestination(), msg, id, deliveryMode, priority, timeToLive, !eosMessage);
     }
     
+    public String toString() {
+        return "ActiveMQOutputStream { producerId=" +info.getProducerId()+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/ActiveMQQueueBrowser.java

@@ -242,4 +242,9 @@ public class ActiveMQQueueBrowser implements
             semaphore.notifyAll();
         }
     }
+    
+    public String toString() {
+        return "ActiveMQQueueBrowser { consumerId=" +consumerId+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/ActiveMQQueueReceiver.java

@@ -86,4 +86,5 @@ public class ActiveMQQueueReceiver extends ActiveMQMessageConsumer implements
         checkClosed();
         return (Queue) super.getDestination();
     }
+    
 }

activemq-core/src/main/java/org/activemq/ActiveMQSession.java

@@ -1664,4 +1664,9 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
 		return executor.getUnconsumedMessages();
 	}
     
+    public String toString() {
+        return "ActiveMQSession {id="+info.getSessionId()+",started="+started.get()+"}";
+    }
+
+
 }

activemq-core/src/main/java/org/activemq/pool/PooledConnection.java

@@ -143,4 +143,8 @@ public class PooledConnection implements TopicConnection, QueueConnection {
         return (ActiveMQSession) getConnection().createSession(key.isTransacted(), key.getAckMode());
     }
     
+    public String toString() {
+        return "PooledConnection { "+pool+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/pool/PooledProducer.java

@@ -126,4 +126,9 @@ public class PooledProducer implements MessageProducer {
     protected ActiveMQMessageProducer getMessageProducer() {
         return messageProducer;
     }
+    
+    public String toString() {
+        return "PooledProducer { "+messageProducer+" }";
+    }
+
 }

activemq-core/src/main/java/org/activemq/pool/PooledSession.java

@@ -280,4 +280,7 @@ public class PooledSession implements TopicSession, QueueSession {
         return topicPublisher;
     }
 
+    public String toString() {
+        return "PooledSession { "+session+" }";
+    }
 }