raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Added possibility of sending reply messages directly by sending them to the AMQP.Consumer

Browse source
This commit is contained in:
jboner 2009-10-27 12:32:06 +01:00
parent 322a0486a9
commit 0a169fbc96
1 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-amqp/src/main/scala/AMQP.scala
View file

@ -201,7 +201,7 @@ object AMQP extends Actor {
log.info("AMQP.Producer [%s] is started", toString)
def receive: PartialFunction[Any, Unit] = {
def receive = {
case message @ Message(payload, routingKey, mandatory, immediate, properties) =>
log.debug("Sending message [%s]", message)
channel.basicPublish(exchangeName, routingKey, mandatory, immediate, properties, serializer.out(payload))
@ -304,7 +304,7 @@ object AMQP extends Actor {
listener.tag = Some(listenerTag)
}
def receive: PartialFunction[Any, Unit] = {
def receive = {
case listener: MessageConsumerListener =>
startLink(listener.actor)
listeners.put(listener, listener)
@ -326,9 +326,16 @@ object AMQP extends Actor {
}
}
case message @ Message(payload, routingKey, mandatory, immediate, properties) =>
log.debug("Sending message [%s]", message)
channel.basicPublish(exchangeName, routingKey, mandatory, immediate, properties, serializer.out(payload))
case Reconnect(delay) => reconnect(delay)
case Failure(cause) => log.error(cause, ""); throw cause
case Stop => disconnect; stop
case unknown => throw new IllegalArgumentException("Unknown message [" + unknown + "] to AMQP Consumer [" + this + "]")
}