Spring AMQP Connections

Ich habe ein Spring AMQP-Projekt mit CachingConnectionFactory. Ich brauche einige Eigenschaften von der AMQP-Verbindung, zum Beispiel: Status, Verbunden bei, Kanäle und einige Laufzeitmetriken. Gibt es eine Metriken-Unterstützung für die CachingConnectionFactory (wie: https://www.rabbitmq.com/blog/2016/11/30/metrics-support-in-rabbitmq-java-client-4-0/).Spring AMQP Connections

Ich kann einen ConnectionListener für einige Daten verwenden, aber ich bevorzuge es zur Laufzeit zu bekommen.

Danke!

Quelle

2017-01-23 jandres

Spring AMQP 1.7.0 (letzte Woche veröffentlicht) unterstützt den 4.0-Client.

Sie können den zugrundeliegenden RabbitMQ ConnectionFactory konfigurieren und ihn in die CachingConnectionFactory einspeisen.

Die Verbindungsfactory kann direkt oder mithilfe der Spring RabbitConnectionFactoryBean erstellt werden, die jetzt die Einstellung des Metriksammlers unterstützt.

Quelle

2017-01-23 14:00:53

Danke! Ich habe es mit der Version 1.7.0.RELEASE versucht, aber ich habe diesen Fehler: java.lang.NoSuchMethodError: com.rabbitmq.client.ConnectionFactory.newConnection (Ljava/util/gleichzeitige/ExecutorService; Ljava/lang/String;) Lcom/Kaninchenmq/Client/Verbindung; Wenn ich eine Warteschlange deklariere: Warteschlange q = myAmqpAdmin(). declareQueue(); – jandres

Das scheint anzuzeigen, dass Sie eine alte Version von amqp-client auf dem Klassenpfad haben; nicht 4.0.x. Der Parameter 'String' wurde vor einiger Zeit der Methode 'newConnection' hinzugefügt (3.6?). Wenn Sie Maven oder Gradle verwenden, sollten Sie 4.0.1 transitiv erhalten. –

Nochmals vielen Dank! Ich hatte vergessen, die Version von amqp-client zu aktualisieren. Eine letzte Frage: Was denkst du, ist der beste Weg, um den Status einer AMQP-Verbindung zu erhalten? – jandres

Spring AMQP Connections

Antwort

Verwandte Themen