diff --git a/activemq-ra/src/main/java/org/apache/activemq/ra/ManagedSessionProxy.java b/activemq-ra/src/main/java/org/apache/activemq/ra/ManagedSessionProxy.java
index 9af957976c..72fb1391c2 100755
--- a/activemq-ra/src/main/java/org/apache/activemq/ra/ManagedSessionProxy.java
+++ b/activemq-ra/src/main/java/org/apache/activemq/ra/ManagedSessionProxy.java
@@ -324,7 +324,7 @@ public class ManagedSessionProxy implements Session, QueueSession, TopicSession
      * @throws JMSException
      */
     public void setMessageListener(MessageListener listener) throws JMSException {
-        getSession(); // .setMessageListener(listener);
+        getSession().setMessageListener(listener);
     }
 
     /**