diff --git a/akka-docs/rst/java/code/docs/camel/MyEndpoint.java b/akka-docs/rst/java/code/docs/camel/MyEndpoint.java
index 1259cc06ce..0c31f200ed 100644
--- a/akka-docs/rst/java/code/docs/camel/MyEndpoint.java
+++ b/akka-docs/rst/java/code/docs/camel/MyEndpoint.java
@@ -25,7 +25,7 @@ public class MyEndpoint extends UntypedConsumerActor{
   }
 
   public MyEndpoint() {
-    this.uri = "mina:tcp://localhost:6200?textline=true";
+    this.uri = "mina2:tcp://localhost:6200?textline=true";
   }
 }
 //#Consumer-mina
\ No newline at end of file
diff --git a/akka-docs/rst/scala/code/docs/camel/Introduction.scala b/akka-docs/rst/scala/code/docs/camel/Introduction.scala
index e1b5f17a17..2adc7a3863 100644
--- a/akka-docs/rst/scala/code/docs/camel/Introduction.scala
+++ b/akka-docs/rst/scala/code/docs/camel/Introduction.scala
@@ -12,7 +12,7 @@ object Introduction {
     import akka.camel.{ CamelMessage, Consumer }
 
     class MyEndpoint extends Consumer {
-      def endpointUri = "mina:tcp://localhost:6200?textline=true"
+      def endpointUri = "mina2:tcp://localhost:6200?textline=true"
 
       def receive = {
         case msg: CamelMessage ⇒ { /* ... */ }
@@ -82,7 +82,7 @@ object Introduction {
     import scala.concurrent.duration._
 
     class MyEndpoint extends Consumer {
-      def endpointUri = "mina:tcp://localhost:6200?textline=true"
+      def endpointUri = "mina2:tcp://localhost:6200?textline=true"
 
       def receive = {
         case msg: CamelMessage ⇒ { /* ... */ }