amqp

0Hitze

1Antwort

Problem beim Konfigurieren von RabbitMq Logback Appender

Mein Projekt fordert, die Protokolle an einem zentralen Standortserver (Graylog) zu senden. Also dachte ich mir "AMQP Appender" in logback.xml zu verwenden, um die Protokolle an RabbitMq zu senden und

4Hitze

2Antwort

So fügen Sie einen Header-Schlüssel: Wert-Paar beim Veröffentlichen einer Nachricht mit Pika

Ich schreibe einen automatisierten Test, um einen Verbraucher zu testen. Bisher musste ich beim Veröffentlichen von Nachrichten keinen Header hinzufügen, aber jetzt tue ich es. Und es scheint wie sein

1Hitze

1Antwort

Wie schreibe ich einen RabbitMQ Java-Client, der eine Verbindung zu IBM MQ AMQP Kanal

Ich habe IBM MQ-Server mit der neuesten Funktion des AMQP-Kanal aktiviert. Ich versuche, ein RabbitMQ-Client-Programm in Java zu schreiben, das eine Verbindung zum AMQP-Kanal in IBM MQ herstellen und

0Hitze

1Antwort

RabbitMQ Exklusive Warteschlange Verlorene Nachrichten

Wenn ein Benutzer eine Warteschlange als 'exklusiv' deklariert, wird die Warteschlange gelöscht, wenn der Benutzer die Verbindung zur Dokumentation trennt. Angenommen, es sind Nachrichten in der Warte

1Hitze

1Antwort

OpenNMS v18 AMQP Nachricht Senden Problem

Ich kann OpenNMS nicht dazu bringen, Nachrichten an einen AMQP-Endpunkt zu senden. Ich habe noch nie funktioniert und das ist das erste Mal, dass ich OpenNMS und AMQP benutzt habe, so dass meine Unerf

1Hitze

2Antwort

Java Qpid Proton - ActiveMQ-Broker Kann angeforderte Adresse nicht zuweisen: bind

Ich brauche wirklich eine Antwort auf diese Frage, weshalb ich es bearbeite. Ich habe einen Apache ActiveMQ Broker in meiner Verbindung aufgebaut mit diesem Code Broker.java public class Broker { priv

12Hitze

1Antwort

Automatische Dokumentation/Vertragsgenerierung für Pub/Sub RabbitMQ

In der REST-Welt haben wir so etwas wie eine Swagger-Spezifikation, die den Vertrag über eine REST-Schnittstellengrenze (zwischen Client und Server) vollständig beschreibt. Diese Swagger-Spezifikation

0Hitze

1Antwort

Stoppen Sie channel.basic_consume, wenn die Verbindung im Leerlauf ist/nicht lange konsumieren

Ich habe einen Anwendungsfall, in dem ich die letzte Leerlaufzeit (letzte Nachricht verarbeitete Zeit) eines Pika-Verbrauchers (pika.BlockingConnection) bekommen möchte. Anwendungsfall: Wenn die letzt

0Hitze

1Antwort

Integrierter QPid-Broker - Web Management Console wird nicht geladen

Die Verwaltungskonsole kann nicht ausgeführt werden, wenn der Broker mit dem folgenden Artefakt für QPid gestartet wird. Fehle ich eine Abhängigkeit oder Konfiguration in der folgenden Einrichtung? po

0Hitze

1Antwort

Partitionierte Themen mit AMQP 1.0 und JMS 1.1 unter Azure verwenden

Zwei Azure-Dokumente weisen auf die Fähigkeit hin, partitionierte Zweige zu verwenden. Es gibt jedoch keine Beispiele für die Verwendung von JMS mit Partitionen aus Java-Code. Ist es tatsächlich mögli