Ich versuche, eine Verbindung von meiner Android-App zu einer Warteschlange namens "messages" herzustellen.

Der Produzent (ein Webservice unter AMQP-Protokoll) ist bereits verbunden, dies kann über das RabbitMQ-Admin-Panel überprüft werden.

Um eine Verbindung mit meinem Android-Gerät herzustellen, codiere ich wie folgt.

private void connect() throws Exception {

    this.sampleClient = new MqttClient(this.broker, this.clientId);

    MqttConnectOptions connOpts = new MqttConnectOptions();
    connOpts.setUserName("user");
    connOpts.setPassword("user".toCharArray());
    /*connOpts.setConnectionTimeout(60 * 10);
    connOpts.setKeepAliveInterval(60 * 5);*/
    connOpts.setCleanSession(true);

    this.sampleClient.connect(connOpts);

    this.sampleClient.setCallback(this);

    this.sampleClient.subscribe("messages");

    if(!this.sampleClient.isConnected()){

        System.out.println("Not Connected");
        return;
    }

    System.out.println("Connected");
}

Ich habe versucht mit "amq.topic", "amq.topic. *", "Amq.topic.messages", etc ... Aber wenn ich in der RabbitMQ-Warteschlange Abschnitt "messages" mit 0 Consumer ist, und habe Es wurde automatisch eine neue Warteschlange mit dem Namen "mqtt-subscription-Sampleqos1" eingerichtet.

Was ist los? Wie kann ich die Warteschlange "Nachrichten" abonnieren?