diff --git a/src/main/csharp/MessageConsumer.cs b/src/main/csharp/MessageConsumer.cs
index 708a372..6961298 100644
--- a/src/main/csharp/MessageConsumer.cs
+++ b/src/main/csharp/MessageConsumer.cs
@@ -237,7 +237,7 @@
 
             if(this.ConsumerTransformer != null)
             {
-                IMessage newMessage = ConsumerTransformer(this.session, this, message);
+                IMessage newMessage = ConsumerTransformer(this.session, this, converted);
                 if(newMessage != null)
                 {
                     converted = newMessage;
diff --git a/src/main/csharp/MessageProducer.cs b/src/main/csharp/MessageProducer.cs
index 5912c07..8690fc4 100644
--- a/src/main/csharp/MessageProducer.cs
+++ b/src/main/csharp/MessageProducer.cs
@@ -102,9 +102,8 @@
             Send(destination, message, DeliveryMode, Priority, TimeToLive);
         }
 
-        public void Send(IDestination destination, IMessage imessage, MsgDeliveryMode deliveryMode, MsgPriority priority, TimeSpan timeToLive)
+        public void Send(IDestination destination, IMessage message, MsgDeliveryMode deliveryMode, MsgPriority priority, TimeSpan timeToLive)
         {
-            BaseMessage message = (BaseMessage) imessage;
             MessageQueue mq = null;
 
             try