op-Kaninchen-Verbindung trennen

Question

Ich schrieb einen einfachen Kaninchen-mq AMQP Client mit op-Kaninchen-Client:

val rabbitControl = system.actorOf(Props[RabbitControl]) 
rabbitControl ! 
        Message.topic(
        message, 
        routingKey = topicName, 
        properties = Seq(properties.DeliveryModePersistence(persistent = false)) 
       ) 

das funktioniert gut, aber nach Anzahl der Nachrichten zu erhöhen Ich habe dies warnt sehr sehr schnell:

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 

Zehn warnt pro Sekunde, und meine AMQP Nachrichten dont dests in rabbitmq (MQTT Kunden)

was falsch liefern?

Answer 1

Ich habe das Problem gefunden. es war ein Tippfehler.
In op-Kaninchen-Konfiguration habe ich einen falschen Thema-Austausch-Namen festgelegt.
aber der Fehler war sehr illusorisch.
Es sollte sein: "Es gibt keine solche exchange"

op-rabbit { 
    topic-exchange-name = "amq.topic" 
    connection { 
    virtual-host = "/" 
    hosts = ["172.16.0.45"] 
    username = "..." 
    password = "..." 
    port = 5672 
    timeout = 3s 
    } 
}