Akka + Camel: Jetty端点的通配符匹配

Question

我想尝试匹配一个akka演员，该演员正被用作akka-camel消费者，并将码头与通配符相匹配。例如，我希望下面的每个人都去同一个akka-camel消费者：

http://<ipaddr>:8080/
http://<ipaddr>:8080/path1
http://<ipaddr>:8080/path1/subpath1
http://<ipaddr>:8080/path2

下面是一个简单的akka-camel消费者：

class CamelActorConsumer extends Consumer {
  def endpointUri = ""jetty:http://0.0.0.0:8080/"
  def receive = {
      case x: CamelMessage =>
         println("Got: " + x)
  }
}

Answer 1

我能找到的最简单的答案是在endpointUri中为akka-camel提供一个通配符匹配器，如下所示：

def endpointUri = ""jetty:http://0.0.0.0:8877/?matchOnUriPrefix=true"

这将与上面的所有路径匹配。我们可以将其更改为特定路径下的子目录，方法是将其添加到?matchOnUriPrefix=true之前的路径中