diff --git a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedMessageProducer.cs b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedMessageProducer.cs
index 704572e4..89db8b6b 100644
--- a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedMessageProducer.cs
+++ b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedMessageProducer.cs
@@ -218,11 +218,9 @@ namespace Spring.Messaging.Ems.Connections
             }
         }
 
-
-
         public MessageProducer NativeMessageProducer
         {
-            get { throw new System.NotImplementedException(); }
+            get { return target.NativeMessageProducer; }
         }
 
         /// <summary>
diff --git a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedSession.cs b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedSession.cs
index 0d05a6ad..b9f48fd4 100644
--- a/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedSession.cs
+++ b/src/Spring/Spring.Messaging.Ems/Messaging/Ems/Connections/CachedSession.cs
@@ -283,27 +283,6 @@ namespace Spring.Messaging.Ems.Connections
             return CreateDurableSubscriber(destination, subscription, null, false);
         }
 
-
-
-        /// <summary>
-        /// Deletes the durable consumer.
-        /// </summary>
-        /// <param name="name">The name.</param>
-        public void DeleteDurableConsumer(string name)
-        {
-            throw new NotImplementedException();
-        }
-
-        /// <summary>
-        /// Deletes the durable consumer.
-        /// </summary>
-        /// <param name="name">The name.</param>
-        /// <param name="requestTimeout">The request timeout.</param>
-        public void DeleteDurableConsumer(string name, TimeSpan requestTimeout)
-        {
-            throw new NotImplementedException();
-        }
-
         /// <summary>
         /// Creates the consumer.
         /// </summary>
@@ -615,8 +594,15 @@ namespace Spring.Messaging.Ems.Connections
 
         public IMessageListener MessageListener
         {
-            get { throw new System.NotImplementedException(); }
-            set { throw new System.NotImplementedException(); }
+            get { 
+                this.transactionOpen = true;
+                return target.MessageListener;
+            }
+            set
+            {
+                this.transactionOpen = true;
+                target.MessageListener = value;
+            }
         }
 
         #endregion