diff --git a/akka-amqp/pom.xml b/akka-amqp/pom.xml index cacd9844bf..6f099ae677 100644 --- a/akka-amqp/pom.xml +++ b/akka-amqp/pom.xml @@ -25,15 +25,10 @@ ${project.groupId} ${project.version} - - - com.rabbitmq - rabbitmq-client - 0.9.1 diff --git a/akka-amqp/src/main/scala/AMQP.scala b/akka-amqp/src/main/scala/AMQP.scala index d88b4da3ca..09aca97385 100644 --- a/akka-amqp/src/main/scala/AMQP.scala +++ b/akka-amqp/src/main/scala/AMQP.scala @@ -66,10 +66,12 @@ object AMQP { initReconnectDelay: Long, passive: Boolean, durable: Boolean, - configurationArguments: Map[String, AnyRef]) = + autoDelete: Boolean, + configurationArguments: Map[String, AnyRef]) = supervisor.newConsumer( config, hostname, port, exchangeName, exchangeType, - shutdownListener, initReconnectDelay, passive, durable, configurationArguments) + shutdownListener, initReconnectDelay, + passive, durable, autoDelete, configurationArguments) def stopConnection(connection: FaultTolerantConnectionActor) = supervisor.stopConnection(connection) @@ -112,6 +114,7 @@ object AMQP { initReconnectDelay: Long, passive: Boolean, durable: Boolean, + autoDelete: Boolean, configurationArguments: Map[String, AnyRef]): Consumer = { val consumer = new Consumer( new ConnectionFactory(config), @@ -122,6 +125,7 @@ object AMQP { initReconnectDelay, passive, durable, + autoDelete, configurationArguments) startLink(consumer) consumer @@ -352,6 +356,7 @@ object AMQP { val initReconnectDelay: Long, val passive: Boolean, val durable: Boolean, + val autoDelete: Boolean, val configurationArguments: Map[java.lang.String, Object]) extends FaultTolerantConnectionActor { consumer: Consumer => @@ -406,9 +411,7 @@ object AMQP { protected def setupChannel = { connection = connectionFactory.newConnection(hostname, port) channel = connection.createChannel - channel.exchangeDeclare(exchangeName.toString, exchangeType.toString, - passive, durable, - configurationArguments.asJava) + channel.exchangeDeclare(exchangeName.toString, exchangeType.toString, passive, durable, autoDelete, configurationArguments.asJava) listeners.elements.toList.map(_._2).foreach(registerListener) if (shutdownListener.isDefined) connection.addShutdownListener(shutdownListener.get) } diff --git a/akka-amqp/src/main/scala/ExampleSession.scala b/akka-amqp/src/main/scala/ExampleSession.scala index 998c520620..c973966ce3 100644 --- a/akka-amqp/src/main/scala/ExampleSession.scala +++ b/akka-amqp/src/main/scala/ExampleSession.scala @@ -29,7 +29,7 @@ object ExampleSession { } def direct = { - val consumer = AMQP.newConsumer(CONFIG, HOSTNAME, PORT, IM, ExchangeType.Direct, None, 100, false, false, Map[String, AnyRef]()) + val consumer = AMQP.newConsumer(CONFIG, HOSTNAME, PORT, IM, ExchangeType.Direct, None, 100, false, false, false, Map[String, AnyRef]()) consumer ! MessageConsumerListener("@george_bush", "direct", actor { case Message(payload, _, _, _, _) => log.info("@george_bush received message from: %s", new String(payload.asInstanceOf[Array[Byte]])) }) @@ -38,7 +38,7 @@ object ExampleSession { } def fanout = { - val consumer = AMQP.newConsumer(CONFIG, HOSTNAME, PORT, CHAT, ExchangeType.Fanout, None, 100, false, false, Map[String, AnyRef]()) + val consumer = AMQP.newConsumer(CONFIG, HOSTNAME, PORT, CHAT, ExchangeType.Fanout, None, 100, false, false, false, Map[String, AnyRef]()) consumer ! MessageConsumerListener("@george_bush", "", actor { case Message(payload, _, _, _, _) => log.info("@george_bush received message from: %s", new String(payload.asInstanceOf[Array[Byte]])) }) diff --git a/pom.xml b/pom.xml index 5e50980fe1..1901258730 100755 --- a/pom.xml +++ b/pom.xml @@ -228,6 +228,14 @@ false + + nexus.griddynamics.net + Grid Dynamics Maven Repository + https://nexus.griddynamics.net/nexus/content/groups/public + + false + + databinder.net/repo/ dbDispatch Repository for Maven