Hi,
I've got 2 Play applications (2.4.0-M2), one is being the producer, one
being the consumer. I can send a message to the consumer using the ActiveMQ
console, that works, and get's received.
Message send by the Play application that acts as a producer isn't.
*Consumer code :*
public abstract class Consumer extends UntypedConsumerActor {
@Override
onReceive(Obhect m) {
}
}
public class DCSConsumer extends Consumer {
@Override
public String getEndpointUri() {
return "activemq:topic:dcs?exchangePattern=InOnly";
}
}
In the app's startup code :
Camel camel = CamelExtension.get(system);
CamelContext camelContext = camel.context();
camelContext.addComponent("activemq",
ActiveMQComponent.activeMQComponent("tcp://localhost:61616"));
Props p = Props.create(DCSConsumer.class);
system.actorOf(p, "dcs");
*Producer code* :
public class DCSUpdateProducer extends UntypedProducerActor {
@Override
public String getEndpointUri() {
return "activemq:topic:dcs";
}
@Override
public boolean isOneway() {
return true;
}
}
Props props = Props.create(DCSUpdateProducer.class);
ActorRef producer = actorLifecycle.getActorSystem().actorOf(props,
DCS_ACTOR_NAME);
producer.tell(message, ActorRef.noSender());
Where message is some object.
I'm sure the message get's send : The ActiveMQ messages enqueued and
dequeued are both increased. The consumer's onReceived is however never
called, and nothing is logged.
Anyone got a clue what's going on, or how to start debugging this ? Any
help is much appreciated.
Regards,
Igmar
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
