Tag: spring-rabbit

Federelemente für den AMQP-basierten messaging mit RabbitMQ.

Kanal-shutdown: Kanal-Fehler

Anzahl der Antworten 1 Antworten
manchmal fand ich Folgen Eintrag in meine log-Datei. Ich habe keine Ahnung, was das problem ist. Meine Vermutung ist, zum einstellen einer niedrigeren Anforderung Herzschlag. Irgendwelche anderen Ideen? Darüber hinaus hatte ich die Situation, dass nach einem

Set-message-header in rabbitmq beim senden

Anzahl der Antworten 1 Antworten
Möchte ich set message header beim senden einer Nachricht an Kaninchen. Ich verwende folgenden code, aber verwirrt, wie man set-message-header in es. public static <T> void sendMessage(String routingKey,final Object message,Class<T> type){ DefaultClassMapper typeMapper = new DefaultClassMapper(); typeMapper.setDefaultType(type);

Frühjahr SimpleMessageListenerContainer für RabbitMQ ist Abbruch auf ungültige Nachricht

Anzahl der Antworten 1 Antworten
Ich bin mit Federn SimpleMessageListenerContainer zu konsumieren-Nachrichten von einem RabbitMQ Warteschlange. Alles funktioniert gut, aber wenn eine ungültige Nachricht an die Warteschlange gesendet wird (z.B. ungültige json) den Hörer einfach abgebrochen wird, ist das Herunterfahren des Arbeitnehmers

Ausnahmen in rabbitmq mit spring boot

Anzahl der Antworten 3 Antworten
Ich bin immer der folgenden Ausnahme wiederholt, wenn ich mein spring-boot-Anwendung mit rabbitmq. Der gesamte Durchfluss ist in Ordnung, die sogar von den unten genannten Ausnahmen. hat es zu tun mit der auto-delete durch ? 08 Jul

Spring-RabbitMQ - mit manueller Kanal-Bestätigung auf einen Dienst mit @RabbitListener Konfiguration

Anzahl der Antworten 3 Antworten
Wie zu erkennen die Nachrichten manuell, ohne die Verwendung der automatischen Anerkennung. Gibt es eine Möglichkeit, verwenden Sie diese zusammen mit der @RabbitListener und @EnableRabbit - Stil der Konfiguration. Der größte Teil der Dokumentation erzählt uns SimpleMessageListenerContainer

wie zum Hohn spring amqp/Kaninchen im Frühjahr boot-test

Anzahl der Antworten 5 Antworten
Wie mock spring-rabbitmq/amqp so wird es nicht scheitern während eines Spring-Boot-Test beim Versuch das automatische erstellen Umtausch/Warteschlangen? Gegeben habe ich eine einfache RabbitListener dazu führen, dass der queue und exchange werden automatisch wie folgt erstellt: @Component @RabbitListener(bindings

Konfigurieren von RabbitMQ-Verbindung mit Feder-Kaninchen?

Anzahl der Antworten 1 Antworten
Bin ich nach diese Anleitung um zu lernen, wie spring-rabbit mit RabbitMQ. Aber in dieser Anleitung, die RabbitMQ-Konfiguration als default(localhost-server und mit Berechtigung als Gast/Gast). Was soll ich tun, wenn ich will, um eine Verbindung zu einem