akka-rabbitmq
akka-rabbitmq copied to clipboard
ShellRechargeSolutionsEU
RabbitMq client in Scala and Akka actors
When the connection to RabbitMQ server is lost due to a java.net.SocketException the lib logs: 1. ERROR close com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: java.net.SocketException: Connection...
I have a problem with the logging implementation on the Connection and Channel Actors. As they use the same logger as the ActorSystem I cannot change it's level to be...
``` [ERROR] [12/11/2019 12:08:55.034] [fixture-cluster-akka.actor.default-dispatcher-4] [akka.tcp://[email protected]:2552/user/mq-connection/{queueName}] close com.rabbitmq.client.AlreadyClosedException: chan nel is already closed due to channel error; protocol method: #method(reply-code=404, reply-text=NOT_FOUND - no queue '{queueName}' in vhost '{vhost}', class-id=50, method-id=20)...
Hi, I am trying to test the following example but it doesn't work. ``` object PublishSubscribe extends App { implicit val system = ActorSystem() val factory = new ConnectionFactory() val...
In cluster environment usually it is possible to specify node's address in factory.newConnection(List addrs) method. Is it possible to do the same in Newmotion.
Hi When I send many ChannelMessage with a high rate to ChannelActor with `dropIfNoChannel = false` if I stop rabbitmq and after a duration of time like 1 minute start...
Im trying to: 1. Create channel, 2. Bind things, 3. Publish a list of messages, 4. Close everything and wait for it to close, 5. Shut down system. Here is...
Hi, Is it possible to pause|resume consuming ? According to documentation of rabbitmq it can be achieved with `channel.basicCancel | channel.basicConsume` but I can't see it available in this lib....
See #39 for more context and verification
Metadata
Owner
Metadata
RabbitMq client in Scala and Akka actors