Apache camel,RabbitMQ, wie zum senden von Nachrichten/Objekte

Ich hoffe, jemand kann etwas Hilfe in dieser Angelegenheit.

Bin ich mit dem Kamel rabbitmq und für die Prüfung Zweck, die ich bin versucht zu senden eine Nachricht an die queue, die ich versuche, die Anzeige im rabbitmq-Schnittstelle und dann auch Lesen es zurück.

Aber ich kann nicht damit es funktioniert.

Was ich glaube, was funktioniert, ist, dass ich erstellt habe, in der exchange-Registerkarte des rabbitmq-management-interface, eine neue austauschen.
In meinem java-code, den ich senden Sie die Nachricht an, dass der Austausch. Wenn der code ausgeführt wird, ich kann es sehen einen Stachel im web-interface zeigen, dass etwas eingegangen ist, aber ich kann nicht sehen, was empfangen wurde.
Wenn ich versuche zu Lesen, kann ich nicht Lesen und bekomme die folgende errror:
< route: route(route2) [[[rabbitmq://192.168.59.103:5672/rt... wegen der Route route2 hat keine Ausgabe-Prozessoren. Man muss hinzufügen, Ausgänge auf der Strecke wie("log:foo").

Kann jemand geben Sie mir ein praktisches Beispiel, wie eine Nachricht zu senden,sehen Sie es in der web-Oberfläche und auch gelesen? jedes tutorial zeigt dieser Prozess wird auch geschätzt.

Danke

=================
DER ZWEITE TEIL

Die Fehler, die ich bekommen hab ist nun Folgendes:

Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; reason: {#method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - cannot redeclare exchange 'rhSearchExchange' in vhost '/' with different type, durable, internal or autodelete value, class-id=40, method-id=10), null, ""}
    at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
    at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
    at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
    ... 47 more

Habe ich folgende Einstellungen:

Bekomme ich diesen Fehler, ich glaube ich mache etwas falsch mit dem URI und ich haben zu definieren, die einige zusätzliche Parameter, die ich bin fehlt
Mein exchange ist der direkte Typ
Meine Warteschlange ist langlebig Typ
Und meine uri ist :
rabbitmq://192.168.59.105:5672/rhSearchExchange?username=guest&password=guest&routingKey=rhSearchQueue

alle Eingaben auf dieser?

Dank

irgendwelche Ratschläge dazu ?
Ich habe auf der Suche für ein ähnliches tutorial... ich kann veröffentlichen, Nachrichten an die exchange-aber ich kann es nicht konsumieren, Sie vom Kamel. Jedoch, für Ihre Fehler, ich denke, das problem ist Sie sind nicht die Weiterleitung der Nachricht überall. Zum Beispiel, ich glauben Sie, dass Ihre Konfiguration ist from("rabbitmq:localhost..."); aber es sollte from("rabbitmq:localhost:...").to("foo:bar") foo:bar könnte so etwas wie mock:result
Danke für die Antwort. Ich verstehe, dass ich muss "zu" streamen/speichern Sie es irgendwo. Ich habe meinen thread aktualisiert, um zu zeigen, die Fehler, die ich jetzt zu bekommen. Wenn jemand, hat jemand Rat, wie dieses Problem zu lösen.
BITTE LESEN SIE DEN ZWEITEN TEIL ALS DAS IST DER FEHLER, ICH BIN IMMER JETZT

InformationsquelleAutor cpu2007 | 2014-10-20

  1. 9

    So, ich war in der Lage, um dies herauszufinden, gestern hatte ich das gleiche (oder zumindest ähnliche) Probleme, die Sie hatten.

    Den Optionen, die Sie haben in der RabbitMQ-URI muss exakt die Optionen, die auf Ihrem exchange erstellt wurde. Zum Beispiel, in meiner Konfiguration, ich hatte ein exchange genannt tasks das war ein direkter Typ war robust und nicht so konfiguriert wurde, um der automatischen Löschfunktion. Beachten Sie, dass der Standardwert für die option der automatischen Löschfunktion in der rabbitmq-camel-Komponente ist true. Zusätzlich wollte ich die Nachrichten mit der routing-Taste camel. Das bedeutet, dass meine rabbitmq-URI benötigt, um Aussehen: 

    rabbitmq:localhost:5672/tasks?username=guest&password=guest&autoDelete=false&routingKey=camel

    Darüber hinaus wollte ich Lesen aus einer vorhandenen Warteschlange, genannt task_queue habe anstatt rabbitmq camel-Komponente deklarieren, es ist ein eigenes queue. Daher brauchte ich auch, um eine zusätzliche Abfrage-parameter, so meine rabbitmq URI war 

    rabbitmq:localhost:5672/tasks?username=guest&password=guest&autoDelete=false&routingKey=camel&queue=task_queue

    Diese Konfiguration funktioniert für mich. Unten, ich habe ein paar Java-code-snippets aus dem code konfiguriert den Austausch und die Warteschlange und sendet eine Nachricht, und mein Kamel-Route-Konfiguration.

    Exchange-und Queue-Konfiguration:

    rabbitConnFactory = new ConnectionFactory();
rabbitConnFactory.setHost("localhost");
final Connection conn = rabbitConnFactory.newConnection();
final Channel channel = conn.createChannel();

//declare a direct, durable, non autodelete exchange named 'tasks'    
channel.exchangeDeclare("tasks", "direct", true); 
//declare a durable, non exclusive, non autodelete queue named 'task_queue'
channel.queueDeclare("task_queue", true, false, false, null); 
//bind 'task_queue' to the 'tasks' exchange with the routing key 'camel'
channel.queueBind("task_queue", "tasks", "camel");

    Nachricht senden:

    channel.basicPublish("tasks", "camel", MessageProperties.PERSISTENT_TEXT_PLAIN, "hello, world!".getBytes());

    Camel Route:

    @Override
public void configure() throws Exception {
    from("rabbitmq:localhost:5672/tasks?username=guest&password=guest&autoDelete=false&routingKey=camel&queue=task_queue")
        .to("mock:result");
}

    Ich hoffe, das hilft!

    Vielen Dank llawj, es funktionierte. Ich fügte hinzu, autoDelete=false und auch den Namen der Warteschlange sowie den routingkey, die war schon da bevor. Also im Grunde war es eine Frage der immer die richtige uri. Ein problem, dass ich habe ist, dass wenn es liest die queue, er liest alle Nachrichten? Ich versuchte, zu prefetchEnabled=true und prefetchCount=1 in der uri aber, dass die Klickrate einen Fehler. Irgendwelche Tipps, wie Sie ziehen, nur eine Nachricht? Danke
    Ich bin mir nicht wirklich sicher um ehrlich zu sein. Ich bin gerade erst angefangen mit Camel / RabbitMQ, und ich habe nicht brauchte, um die Anzahl der Nachrichten, die ich bin, zu Lesen.
    Ich werde prüfen, ob ich einen Weg finde, es zu tun. Danke für Eure Hilfe.
    Jederzeit! Viel Glück!
    was ist der Fehler, die Sie sehen? haben Sie versucht autoAck=false zusätzlich zu prefetchCount=1? Diese Weise broker geben nicht mehr Meldungen, bis Sie diese senden ein ack für die, die Sie gerade Bearbeiten

    InformationsquelleAutor Jeff

  2. 1

    Weil diese es als den top-Treffer auf Google für rabbitmq/camel integration fühle ich das Bedürfnis, fügen Sie ein bisschen mehr zu dem Thema. Der Mangel an einfach camel Beispiele ist erstaunlich, zu mir.

    import org.apache.camel.CamelContext;
import org.apache.camel.ConsumerTemplate;
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.impl.DefaultCamelContext;
import org.junit.Test;

public class CamelTests {
    CamelContext context;
    ProducerTemplate producer;
    ConsumerTemplate consumer;
    Endpoint endpoint;

    @Test
    public void camelRabbitMq() throws Exception {
        context = new DefaultCamelContext();

        context.start();

        endpoint = context.getEndpoint("rabbitmq://192.168.56.11:5672/tasks?username=benchmark&password=benchmark&autoDelete=false&routingKey=camel&queue=task_queue");

        producer = context.createProducerTemplate();

        producer.setDefaultEndpoint(endpoint);
        producer.sendBody("one");
        producer.sendBody("two");
        producer.sendBody("three");
        producer.sendBody("four");
        producer.sendBody("done");

        consumer = context.createConsumerTemplate();
        String body = null;
        while (!"done".equals(body)) {
            Exchange receive = consumer.receive(endpoint);
            body = receive.getIn().getBody(String.class);
            System.out.println(body);
        }

        context.stop();

    }

}
    mvnrepository.com/artifact/org.apache.camel/camel-core
    mvnrepository.com/artifact/org.apache.camel/camel-rabbitmq

    InformationsquelleAutor slf

Schreibe einen Kommentar