2016-08-10 16 views
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クライアント)を提供いけないの

答えて

1

問題が見つかりました。それはタイプミスでした。
op-rabbitの設定で間違ったtopic-exchange-nameを設定しました。
しかし、このエラーは非常に幻想的でした。
「このような交換はありません」

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