1

次の例 ( Akka Camel docから取得) では、Jetty HTTP コンポーネントを使用して HTTP メッセージを受信します。アクターが新しい Jetty サーバーを開始したということですか?

import akka.camel.{ CamelMessage, Consumer }

class MyEndpoint extends Consumer {
  def endpointUri = "jetty:http://localhost:8877/example"

  def receive = {
    case msg: CamelMessage => { /* ... */ }
    case _                 => { /* ... */ }
  }
}
4

1 に答える 1