#2989 - Switching to mina2 for Camel examples
This commit is contained in:
parent
392b1ebef3
commit
334c9c6671
2 changed files with 3 additions and 3 deletions
|
|
@ -25,7 +25,7 @@ public class MyEndpoint extends UntypedConsumerActor{
|
||||||
}
|
}
|
||||||
|
|
||||||
public MyEndpoint() {
|
public MyEndpoint() {
|
||||||
this.uri = "mina:tcp://localhost:6200?textline=true";
|
this.uri = "mina2:tcp://localhost:6200?textline=true";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
//#Consumer-mina
|
//#Consumer-mina
|
||||||
|
|
@ -12,7 +12,7 @@ object Introduction {
|
||||||
import akka.camel.{ CamelMessage, Consumer }
|
import akka.camel.{ CamelMessage, Consumer }
|
||||||
|
|
||||||
class MyEndpoint extends Consumer {
|
class MyEndpoint extends Consumer {
|
||||||
def endpointUri = "mina:tcp://localhost:6200?textline=true"
|
def endpointUri = "mina2:tcp://localhost:6200?textline=true"
|
||||||
|
|
||||||
def receive = {
|
def receive = {
|
||||||
case msg: CamelMessage ⇒ { /* ... */ }
|
case msg: CamelMessage ⇒ { /* ... */ }
|
||||||
|
|
@ -82,7 +82,7 @@ object Introduction {
|
||||||
import scala.concurrent.duration._
|
import scala.concurrent.duration._
|
||||||
|
|
||||||
class MyEndpoint extends Consumer {
|
class MyEndpoint extends Consumer {
|
||||||
def endpointUri = "mina:tcp://localhost:6200?textline=true"
|
def endpointUri = "mina2:tcp://localhost:6200?textline=true"
|
||||||
|
|
||||||
def receive = {
|
def receive = {
|
||||||
case msg: CamelMessage ⇒ { /* ... */ }
|
case msg: CamelMessage ⇒ { /* ... */ }
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue