0
私はOP-ウサギのクライアントとの単純なウサギ-MQ AMQPクライアントを書いた:OP-ウサギの接続切断
val rabbitControl = system.actorOf(Props[RabbitControl])
rabbitControl !
Message.topic(
message,
routingKey = topicName,
properties = Seq(properties.DeliveryModePersistence(persistent = false))
)
これはうまく動作しますが、メッセージの数を増やした後、私はこれは非常に非常に高速に警告しました:
を何が間違って05:59:59.636 [push-server-akka.actor.default-dispatcher-12] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.637 [push-server-akka.actor.default-dispatcher-6] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
05:59:59.638 [push-server-akka.actor.default-dispatcher-3] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.639 [push-server-akka.actor.default-dispatcher-6] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
05:59:59.640 [push-server-akka.actor.default-dispatcher-3] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.641 [push-server-akka.actor.default-dispatcher-8] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
05:59:59.642 [push-server-akka.actor.default-dispatcher-3] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.643 [push-server-akka.actor.default-dispatcher-6] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
05:59:59.644 [push-server-akka.actor.default-dispatcher-5] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.645 [push-server-akka.actor.default-dispatcher-6] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
05:59:59.647 [push-server-akka.actor.default-dispatcher-5] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.647 [push-server-akka.actor.default-dispatcher-5] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
05:59:59.649 [push-server-akka.actor.default-dispatcher-12] INFO c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel connected
05:59:59.650 [push-server-akka.actor.default-dispatcher-12] WARN c.t.akka.rabbitmq.ChannelActor - akka://push-server/user/$a/connection/confirmed-publisher-channel disconnected
十秒ごとに警告し、私のAMQPメッセージがRabbitMQの中destsに(MQTTクライアント)を提供いけないの
?