Tag: apache-camel

Ich bin in den Prozess des Lernens, ActiveMQ und Camel, mit dem Ziel zu erstellen, einen kleinen Prototyp-system, das funktioniert ungefähr so: (Quelle: paulstovell.com) (big) Bei einer Bestellung wird in der Orders-system, eine Nachricht wird verschickt an

Ich versuche apache-Kamel -, und ich habe eine einfache route, die den Aufruf eines http-service über das http4-Komponente, wandelt das Ergebnis über unmarshal().json(JsonLibrary.Jackson), und dann druckt ein Teil der Antwort in einer bean-Komponente. Das problem das ich

Ich habe eine Allgemeine Frage zu Apache Camel. Ich war nicht in der Lage, um herauszufinden, ob der aggregator abgewickelt wird. Wenn es abgewickelt wird, wie die Transaktionen umgesetzt werden und wie schnell die aggregation ist? InformationsquelleAutor

Erstens, ja, ich habe gesucht und ja, ich habe den gleichen Apache-Dokument jedem Punkte zu. 🙂 Ich glaube, es ist ein wenig Verwirrung und ich glaube, ich weiß eine Antwort, so lassen Sie mich legen Sie ein

Gibt es eine Möglichkeit(api-Funktion) Lesen Sie den gesamten Inhalt einer Datei(oder Zeile) in camel-ohne einen Konverter zu schreiben oder irgendwelche java-code? Dank Was meinst du. Bitte formulieren Sie Ihre Frage und liefern weitere Details, wo und wie

Ich habe ein Problem mit cxf soap-Header. Ich habe eine cxf-Projekt-mit dem Vertrag-Tannen-Entwicklung Methode. Ich möchte zum Aufruf eines web-service mit einer cxf-Komponente, die wie folgt aussieht. <cxf:cxfEndpoint id="ICCSCustomerService" address="http://localhost:8080/iccs-xsoap/CustomerService/updateCustomer" serviceClass="de.iccs.xsoap.customer.v1.CustomerServiceImpl" > </cxf:cxfEndpoint> Ich will senden ein

Wie bereits in Apache Camel, ist es erlaubt zu schreiben, dynamische URI in(), hat es ermöglicht zu schreiben, dynamische URI Aus(). Ursache, die ich aufrufen müssen, die mehrere FTP-Adressen zum herunterladen der Dateien auf der Grundlage der

Ich verändern wollen, einige Feld die Daten in bestimmte Zeilen in der csv-Datei.Ich habe versucht, die folgenden . 1).Mithilfe von csv-marshaling und unmarshaling ich es erreicht ,aber die Ausgabe CSV-kommen nicht in der richtigen Reihenfolge, obwohl ich

Will ich testen mehrerer camel RouteBuilder in einem einzigen unit test was ich habe: Benutzerdefinierte camel-Prozessor, der Zustand ändert public class MyProcessor implements Processor { MyState state; public MyProcessor(MyState state) {this.state = state;} @Override public void process(Exchange

Teste ich ein Kamel Runde, aber wenn ich die Strecke versuchen, auf eine bestimmte Methode in einer bean-es wird immer behauptet, dass es keine solche Methode gefunden. Quelle: public class CommunicatorTest { FakeMessageConverter converter; CamelContext context; ProducerTemplate

Ich bin versuchen, um eine Kamel-Projekt nur die Verwendung der Eclipse-IDE. Offenbar werden die neuesten Versionen der Eclipse Maven-Unterstützung out of the box, so dass ich dort keine Notwendigkeit zur Installation der m2e-plugin. Trotzdem, ich kann nicht

In meine Anwendung bauen mit apache camel (mavenized, Frühling dsl) , ich lese Nachrichten aus eine Warteschlange, etwa 3/5 der Nachrichten müssen verworfen werden, basierend auf bestimmten Bedingungen, die in Daten -, payload'. Aber ich bin neu

Habe ich eine einfache Kamel-route, die ich ändern muss. Die route sieht wie folgt aus: from(source.uri) .unmarshal() .bean(TransformMessageBean.class, "SomeMethod") .to(destination.uri) Möchte ich hinzufügen, eine andere bean-Methode aufrufen, nachdem die unmarshaling, dass set ist ein header-Wert, ohne Unterbrechung

Habe ich folgende XML-Datei: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxrs="http://cxf.apache.org/jaxrs" xmlns:context="http://www.springframework.org/schema/context" xmlns:cxf="http://cxf.apache.org/core" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://cxf.apache.org/core http://cxf.apache.org/schemas/core.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring-2.9.0.xsd "> Wenn ich meine web-Anwendung, es gibt mir folgenden Fehler: Apr 19, 2012

Würde ich mag, um das setup eine spring bean (entweder über die Schnittstelle oder bean-Klasse). dass ich anrufen kann, um "start" einer Route. In diesem einfachen Beispiel, wenn ich rufe sayHello("world") aus dem code möchte ich es

Bin ich immer die folgende Fehlermeldung ganz sporadisch, wenn ich WS durch SOAP-UI. Manchmal funktioniert es nicht und dann hält es auch funktioniert und dann wieder manchmal funktioniert es nicht. Ein weiteres Problem ist die test-web-service funktioniert

Apache Camel, sofern die Art der konfigurierbaren Architektur, die es ermöglicht web-service-Nachrichten bestimmt werden, die dynamisch während der Laufzeit für die web services gehostet werden, die in der Java-Umgebung. Ich Frage mich, ob es eine ähnliche/gleichwertige framework

Sagen wir, ich habe ein Kamel-route, die wie folgt aussieht : from("direct:myRoute") .setHeader("someHeader", simple("some header value")) .beanRef("myBean", "beanMethod"); Und ich habe eine Bohne, die ich cannot change sieht wie folgt aus : public class MyBean { public

Sende ich JAXB-Objekt Rabbit MQ via Java. JAXBContext jaxbContext = JAXBContext.newInstance(MyDTO.class); Marshaller jaxbMarshaller = jaxbContext.createMarshaller(); //output pretty printed jaxbMarshaller.setProperty(Marshaller.JAXB_FRAGMENT, true); java.io.StringWriter sw = new StringWriter(); jaxbMarshaller.marshal(deliveryrequest, sw); ConnectionFactory factory = new ConnectionFactory() ; //TODO change the hardcoding

Ich versuche die Aufteilung einer ArrayList und schreiben Sie jedes element in eine eigene Datei mit Apache Camel wie in diesem vereinfachten Beispiel: from("timer://poll?period=10000").process(new Processor(){ public void process(Exchange exchange){ ArrayList<String> list = new ArrayList<String>(); list.add("one"); list.add("two"); list.add("three");

Habe ich ein activeMQ-broker, die ein SSL-transport. Ich habe über 10 Verbrauchern sind mit der broker. Ich bin mit dem Kamel zum konfigurieren der meine Routen. Jeder so oft, es hängt sich auf und wird nicht verbrauchen,

Will ich tun, leiten Nachrichten basierend auf der ERHOLUNG von url-mustern für verschiedene Dienste, Meine route in die myRouteBuilder Klasse ist wie folgt, String module1RestUrls = "/client,/price,/client/add,/client/hello"; String module2RestUrls = "/order,/order/invoice,/suppliers"; from("jetty:http://192.168.1.1?matchOnUriPrefix=true&amp;traceEnabled=true") .process(customProcessor) .choice() .when(simple("${module1RestUrls} contains ${header('CamelHttpUri')}"))

Ich bin derzeit mit einer HTTP-Methode für das aufrufen der URL, die erstellt ein JIRA-issue. Jetzt will ich mit Apache Camel,, wie kann ich nutzen? Ich dazu rufen Sie den folgenden link durch Kamel: http://localhost:8080/rest/api/2/project/" + key

Wie kann ich tun, multipart-Datei-uploads mit dem Apache Camel-HTTP-Komponente ? InformationsquelleAutor Kai Sternad | 2010-03-10

Wie kann ich ein Kamel-route, die zur Laufzeit in Java? Ich habe eine Grails-Beispiel, aber ich habe die Implementierung in Java. Meine applicationContext.xml bereits einige vordefinierte statische Routen, und ich möchte hinzufügen, dass einige dynamische Routen zur