Akka Camel: No consumers available on endpoint
<p>I am new to <code>Akka</code> and am attempting to use the <code>Camel</code> component.</p>

<p>I've simplified the code here, but basically I have a <code>Consumer</code> actor that consumes from a <code>JMS</code> endpoint.</p>

<p>In my integration tests, I do not wish to consume from <code>JMS</code>. Instead, I wish to send messages to an endpoint that my consumer reads from.</p>

<p>Therefore, I am attempting this "direct" approach but I get a <code>No consumers available on endpoint: Endpoint[direct://myCamelEndpoint]. Exchange[Message: My test message]</code> exception.</p>

<p>What configuration am I missing here?</p>

<pre><code>object TestApp extends App {
  implicit val system = ActorSystem()
  val camel = CamelExtension(system)
  val producer = system.actorOf(Props[MyProducer])
  val consumer = system.actorOf(Props[MyConsumer])

  producer ! "My test message"


}

class MyProducer extends Producer {
  override def endpointUri: String = "direct:myCamelEndpoint"
}

class MyConsumer extends Consumer with ActorLogging{
  override def endpointUri: String = "direct:myCamelEndpoint"

  override def receive: Receive = {
    case event: Any =&gt; log.info("Received event {}", event)
  }
}
</code></pre>