Tag: spring-amqp
Federelemente für den AMQP-basierten messaging.
Queue-Größe in Spring AMQP-Java-client
2 Antworten
Bin ich mit Spring amqp version 1.1 als mein java-client. Ich habe eine Warteschlange, die rund 2000 Meldungen. Ich will einen service haben die Prüfungen dieser queue-Größe und und wenn es leer ist, sendet Sie eine Meldung
Set-message-header in rabbitmq beim senden
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);
Spring AMQP v1.4.2 - Kaninchen erneute Problem auf Netzwerk-Ausfall
3 Antworten
Teste ich das folgende Szenario in Spring AMQP v1.4.2 und es schlägt fehl, um die Verbindung nach einer Netzwerkunterbrechung: Starten Sie in den Frühling-Anwendung, die Nachrichten verbraucht asyncly mit Kaninchen:listener-container und Kaninchen:connection-factory (genaue Konfiguration folgt). Das log
Keine Verbindung mit Spring AMQP / Rabbit MQ : org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect
3 Antworten
Ich bin neu in Spring AMQP /Rabbit MQ. Bin mit einem Spring AMQP /Rabbit MQ in meinem Projekt. Ich bin mit folgenden Fehler nach der Ausführung einer tomcat: org.springframework.amqp.Kaninchen.listener.SimpleMessageListenerContainer - Verbraucher ausnahmeereignis, kann die Verarbeitung neu starten,
Beim senden der Nachricht SocketException: (Zurücksetzen der Verbindung, AmqpIOException: java.io.IOException)
1 Antworten
Arbeite ich an einem Spring-Integration AMQP RabbitMQ-Projekt. Ich bin versucht zu haben, die <rabbit:admin> erstellen Sie eine nicht vorhandene Warteschlange, die auf einem bereits existierenden Thema, Austausch und binden Sie Sie mit einem routing-Taste. Dann bin ich
spring boot rabbitmq MappingJackson2MessageConverter benutzerdefinierten Objekts der Konvertierung
2 Antworten
Ich bin versucht, zu erstellen eine einfache spring-boot-Anwendung mit spring-boot, die "produzieren" - Nachrichten an einen rabbitmq exchange/queue und ein weiteres Beispiel spring-boot-app, die sich "verbrauchen" diese Nachrichten. Also ich habe zwei apps (oder microservices, wenn Sie
Spring-RabbitMQ - mit manueller Kanal-Bestätigung auf einen Dienst mit @RabbitListener Konfiguration
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
MessageConversionException: Fehler beim konvertieren der Inhalt der Nachricht
2 Antworten
Ich habe eine SpringBoot Anwendung macht die Verwendung von Spring AMQP. Im moment bin ich der Umsetzung der Empfängerseite mit JavaConfig Klassen unter der Leitung der offizielle Frühling docs Beispiele. Aber, ich erhalte eine MessageConversionException und die
Spring-RabbitMQ-tutorial Ergebnisse in Connection Refused Fehler
2 Antworten
Ich bin ein erfahrener Java-Programmierer und bin ausprobieren, Spring Rabbit MQ für die erste Zeit. Folgte ich dem messaging-rabbitMQ-tutorial genau mit Maven. http://spring.io/guides/gs/messaging-rabbitmq/ Läuft bei mir auf CentOS als ein Benutzer-Konto. Bei mir lief der Anwendung am
wie zum Hohn spring amqp/Kaninchen im Frühjahr boot-test
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
Durchführung von Kaninchen-message-listener zu ausgefallen und keine ErrorHandler festgelegt wurde. Fehler beim aufrufen von Ziel-Methode mit dem argument type = [class [B],
2 Antworten
Bin ich mit spring amqp rabbitmq und senden von Nachrichten mithilfe Message message = MessageBuilder .withBody(item.toString().getBytes()) .setReplyTo("importReply") .setCorrelationId(item.toString().getBytes()).build(); Meine message handler public class Foundation { public Message importExchange(Message exchange) { System.out.println("Command:" + exchange.getBody()); Message message = MessageBuilder
Wie zu konfigurieren und receiveAndConvert jSON-Nutzlast in das domain-Objekt im Frühjahr Starten und RabbitMQ
2 Antworten
Vor kurzem habe ich ein großes Interesse an Microservice-Architektur mit Spring Boot. Meine Implementierung hat zwei Spring-boot-Anwendungen; Anwendung Einer empfängt Anforderungen von einem RESTful API, wandelt und sendet jSON-Nutzlast auf eine RabbitMQ queueA. Anwendung Zwei, hat abonniert
Konfigurieren von RabbitMQ-Verbindung mit Feder-Kaninchen?
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
Synchronisieren Tabelle Daten in Datenbanken
10 Antworten
Ich habe eine Tabelle, die Datensätze der Zeilen-insert - /update-Zeitstempel für ein Feld. Ich die zu synchronisierenden Daten in dieser Tabelle mit einer anderen Tabelle auf einem anderen db-server. Zwei db-Servern sind nicht miteinander verbunden und die
RabbitMQ / AMQP - Best Practice Queue / Themenentwurf in einer MicroService-Architektur
3 Antworten
Denken wir nur an die Einführung einer AMQP-basierten Ansatz für unsere microservice-Infrastruktur (Choreographie). Wir haben mehrere Dienste, sagen wir, den Kunden-service, Benutzer-service, Artikel-service etc. Wir planen die Einführung RabbitMQ als unser zentrales Messaging-System. Ich bin auf der
Spring AMQP + RabbitMQ 3.3.5 ACCESS_REFUSED - Die Anmeldung wurde mit dem Authentifizierungsmechanismus PLAIN abgelehnt
7 Antworten
Bin ich immer unter Ausnahme org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login wurde verweigert mit Authentifizierungsmechanismus PLAIN. Für details siehe die broker logfile. Konfiguration: RabbitMQ 3.3.5 auf windows Auf Config-Datei in %APPDATA%\RabbitMQ\rabbit.config Ich habe unten getan ändern, wie pro