op-rabbit {
topic-exchange-name = "rabbitTestQueue"
channel-dispatcher = "op-rabbit.default-channel-dispatcher"
default-channel-dispatcher {
# Dispatcher is the name of the event-based dispatcher
type = Dispatcher
# What kind of ExecutionService to use
executor = "fork-join-executor"
# Configuration for the fork join pool
fork-join-executor {
# Min number of threads to cap factor-based parallelism number to
parallelism-min = 2
# Parallelism (threads) ... ceil(available processors * factor)
parallelism-factor = 2.0
# Max number of threads to cap factor-based parallelism number to
parallelism-max = 4
}
# Throughput defines the maximum number of messages to be
# processed per actor before the thread jumps to the next actor.
# Set to 1 for as fair as possible.
throughput = 100
}
connection {
virtual-host = "/"
hosts = ["172.20.61.100"]
username = "test"
password = "123"
port = 5672
ssl = false
connection-timeout = 3s
}
[ERROR] [04/27/2018 18:43:11.034] [App-akka.actor.default-dispatcher-5] [akka://App/user/$a/connection] akka://App/user/$a/connection in Disconnected received Connect: can't connect to amqp://test@{localhost:5672}:5672//, retrying in 10 secondsval config = com.typesafe.config.ConfigFactory.load()
val rabbitControl = actorSystem.actorOf(Props(new RabbitControl(ConnectionParams.fromConfig(config.getConfig("op-rabbit.connection")))))
implicit val recoveryStrategy = RecoveryStrategy.nack(false)
--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-users+unsubscribe@googlegroups.com.
To post to this group, send email to rabbitmq-users@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.