log execption and fire to exception listener if exception thrown

in run() method

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

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

@@ -665,6 +665,8 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
                 messageListener.onMessage(message);
             } catch ( Throwable e ) {  
                 // TODO: figure out proper way to handle error.
+                log.error("error dispatching message: ",e);
+                connection.onAsyncException(e);
             }
 
             try {