[CONF] Apache Camel MongoDB
Specifying a fields filter ... Code Block // from(direct:count).to(mongodb:myDb?database=ticketscollection=flightsoperation=countdynamicity=true); Long result = template.requestBodyAndHeader(direct:count, irrelevantBody, MongoDbConstants.COLLECTION, dynamicCollectionName); assertTrue(Result is not of type Long, result instanceof Long); FromCamel 2.14 onwards you can provide acom.mongodb.DBObject object in the message body as a query,and operation will return the amount of documents matching this criteria. Code Block DBObject query = ... Long count = template.requestBodyAndHeader(direct:count, query, MongoDbConstants.COLLECTION, dynamicCollectionName); getDbStats Equivalent of running the db.stats() command in the MongoDB shell, which displays useful statistic figures about the database. For example: ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel MINA2
=true).process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
exchange.getOut().setBody(Bye + body);
exchange.getOut().setHeader(Mina2Constants.MINA_CLOSE_SESSION_WHEN_COMPLETE, true);
}
});
...
Filters permit you to use some Mina Filters, such as SslFilter. You can also implement some customized filters. Please note that codec and logger are also implemented as Mina filters of type, IoFilter. Any filters you may define are appended to the end of the filter chain; that is, after codec and logger.
Include Page
Endpoint See Also
MinaMINA
Netty
View Online Like View Changes
Stop watching space Manage Notifications
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel HL7
. The ack _expression_ lets us accomplish this very elegantly: ... Online anzeigen Gefllt mir nderungen anzeigen berwachung des Bereichs beenden Benachrichtigungen verwalten Diese Nachricht wurde von Atlassian Confluence 5.0.3, der Kollaborationssoftware fr Teams, gesendet
[CONF] Apache Camel Olingo2
Consumer Endpoints Only the read endpoint can be used as a consumer endpoint. Consumer endpoints can useScheduled Poll Consumer Optionswith aconsumer.prefix to schedule endpoint invocation. By default consumer endpoints that return an array or collection will generate one exchange per element, and their routes will be executed once for each exchange. This behavior can be disabled by setting the endpoint property consumer.splitResult=false. Message Headers Any URI option can be provided in a message header for producer endpoints with aCamelOlingo2.prefix. Message Body All result message bodies utilize objects provided by the underlying Apache Olingo 2.0 API used by the Olingo2Component. Producer endpoints can specify the option name for incoming message body in theinBodyendpoint URI parameter. For endpoints that return an array or collection, a consumer endpoint will map every element to distinct messages, unless consumer.splitResult is set to false. View Online Like Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Olingo2
); The following route polls Manufacturer delta feedevery 30 seconds. The bean blahupdates the beanparamsBeanto add an updated!deltatoken property with the value returned in the ODataDeltaFeed result. Since the initial delta token is not known, the consumer endpoint will produce anODataFeed value the first time, and ODataDeltaFeed on subsequent polls. from( olingo2://read/Manufacturers?queryParams=#paramsBeanconsumer.timeUnit=SECONDSconsumer.delay=30 ) .to( bean:blah ); View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Olingo2
); View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Olingo2
Zero or one association link entity-set(key-predicate/$link/one-to-one-entity-set-property String Zero or many association links entity-set(key-predicate/$link/one-to-many-entity-set-property java.util.ListString Count resource-uri/$count java.lang.Long ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Olingo2
. from( olingo2://read/Manufacturers?queryParams=#paramsBeanconsumer.timeUnit=SECONDSconsumer.delay=30 ) .to( bean:blah ); View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. Fixed Advice-With to honor autoStartup option. FixedOnCompletion to route the completedExchangeeven if it was marked to stop / failed due exception / handled by error handler etc. Fixed using@EndpointInject with ref in RouteBuilderclasses, to enlist the endpoints in JMX during starting CamelContext when using OSGi FixedProperty Trigger.timerZone is declared as constant for camel-quartz component but not implemented when endpoint is instantiated FixedJPAto not shareEntityManager with concurrent threads or other exchanges, as anEntityManager is not thread-safe accordingly to the JPA spec. New Enterprise Integration Patterns ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Content Enricher
Using This Pattern View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
during starting CamelContext when using OSGi FixedProperty Trigger.timerZone is declared as constant for camel-quartz component but not implemented when endpoint is instaniatedinstantiated New Enterprise Integration Patterns ... camel-ahc-ws camel-atmosphere-websocket camel-box camel-dropbox camel-metrics camel-netty4 camel-olingo2 camel-openshift camel-gora camel-rest (in camel-core) camel-spark-rest camel-swagger ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. FixedOnCompletion to route the completedExchangeeven if it was marked to stop / failed due exception / handled by error handler etc. Fixed using@EndpointInject with ref in RouteBuilderclasses, to enlist the endpoints in JMX during starting CamelContext when using OSGi FixedProperty Trigger.timerZone is declared as constant for camel-quartz component but not implemented when endpoint is instantiated ... Polling Consumerallows to configure initial queue size and whether to block when full when using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x The optionuseSsl has been removed fromcamel-twitter as ssl is always enabled now, enforced by twitter FixedRestlet to return error code 405 (instead of 404 if a http method is not allowed Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. If you want the routes to keep accepting messages during shutdown of Camel, then setacceptMessagesWhileStopping=true. OnCompletion now runs without thread pool by default. To restore old behavior setparalllelProcessing to true. Setting autoStartup to false, and starting a CamelContext the 2nd time now does not start the routes, instead use the new startAllRoutes method on CamelContext to start all the routes. Bean component caches the bean by default (eg a single instance of the bean is reused). This can be turned off by setting cache=false, which now enforces a new instance of the bean is created and used once (no reuse, aka prototype scoped) Important changes to consider when upgrading ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Metrics Component
. durationUnit TimeUnit.MILLISECONDS The unit to use for duration in the metrics reporter or when dumping the statistics as json. From Java code tou can get hold of thecom.codahale.metrics.MetricRegistryfrom the org.apache.camel.component.metrics.routepolicy.MetricsRegistryService as shown below: ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Articles
and Implementing our Camel-based mgm Cosmo Router - First blog of a series of blogs on experience with using Apache Camel implementing a solution for integrating an insurance software with a CRM system. Recommended read. Lessons learned from using Apache Camel, MTOM and JMS - Blog post on experience using SOAP with MTOM (using Apache CXF) and JMS (using Apache ActiveMQ). Camel CXF Component – WSDL First Example - A simple WSDL first Camel CXF producer and consumer. Camel CXFRS Component - Simple REST - A simple CXFRS example exposing a REST interface to a database table. From inside the code: Camel RouteBuilder and Java DSL - A deep dive into the internals of Apache Camel to see how the Java DSL works From inside the code: Camel Routing Engine Part I - A deep dive into the internals of Apache Camel to see how Camel setup the routes Testing Camel JPA routes with Pax-Exam and Karaf - This blog is about how to use JPA, CXF and ActiveMQ with Camel in Karaf and how to do the testing best Testing with Apache Camel - Blog post from April 2014 byGnanaguru summarizing his experience looking into unit testing with Camel and all the possible ways this can be done. Correctly using Camel's AdviceWith in Unit Tests from April 2014 by Dugg Turnbull talking about his experience how to write unit tests with the powerful advice with functionality in Camel. Parleys Rest SMS with Apache Camel from April 2014 Imran Raza Khan talking about how to send SMS text messages using REST api with Apache Camel. Camel HTTP file upload with multipart/form-data from August 2014 by Peter Hilton how to send files over legacy system using HTTP built using Scala and the Scala DSL. Tooling / Combination with other Products ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel MQTT
the topic property name of the MQTT producer from the message header. mqttRetainPropertyName MQTTRetain The property name to look for on an Exchange for an individual published message. If this is set (expects a Boolean value) - then the retain property will be set on the message sent to the MQTT message broker. mqttQosPropertyName MQTTQos The property name to look for on an Exchange for an individual published message. If this is set (one of AtMostOnce, AtLeastOnce or ExactlyOnce ) - then that QoS will be set on the message sent to the MQTT message broker. connectWaitInSeconds 10 Delay in seconds the Component will wait for a connection to be established to the MQTT broker disconnectWaitInSeconds 5 the number of seconds the Component will wait for a valid disconnect on stop() from the MQTT broker sendWaitInSeconds 5 The maximum time the Component will wait for a receipt from the MQTT broker to acknowledge a published message before throwing an exception ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel MQTT
producer. mqttRetainPropertyName MQTTRetain The property name to look for on an Exchange for an individual published message. If this is set (expects a Boolean value) - then the retain property will be set on the message sent to the MQTT message broker. mqttQosPropertyName MQTTQos The property name to look for on an Exchange for an individual published message. If this is set (one of AtMostOnce, AtLeastOnce or ExactlyOnce ) - then that QoS will be set on the message sent to the MQTT message broker. connectWaitInSeconds 10 Delay in seconds the Component will wait for a connection to be established to the MQTT broker disconnectWaitInSeconds 5 the number of seconds the Component will wait for a valid disconnect on stop() from the MQTT broker sendWaitInSeconds 5 The maximum time the Component will wait for a receipt from the MQTT broker to acknowledge a published message before throwing an exception ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel XSLT
Claus Ibsen edited the page: XSLT ... Available as of Camel 2.9 (removed in 2.11.4, 2.12.3 and 2.13.0) Camel provides the CamelXsltResourceUri header which you can use to define a stylesheet to use instead of what is configured on the endpoint URI. This allows you to provide a dynamic stylesheet at runtime. Accessing warnings, errors and fatalErrors from XSLT ErrorListener Available as of Camel 2.14 From Camel 2.14 onwards, any warning/error or fatalError is stored on the current Exchange as a property with the keysExchange.XSLT_ERROR,Exchange.XSLT_FATAL_ERROR, orExchange.XSLT_WARNING which allows end users to get hold of any errors happening during transformation. For example in the stylesheet below, we want to terminate if a staff has an empty dob field. And to include a custom error message using xsl:message. Code Block xsl:template match=/ html body xsl:for-each select=staff/programmer pName: xsl:value-of select=name/br / xsl:if test=dob='' xsl:message terminate=yesError: DOB is an empty string!/xsl:message /xsl:if /p /xsl:for-each /body /html /xsl:template This information is not available on the Exchange stored as an Exception that contains the message in the getMessage() method on the exception. The exception is stored on the Exchange as a warning with the keyExchange.XSLT_WARNING. Notes on using XSLT and Java Versions ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel XSLT
. transformerCacheSize 0 Camel 2.9.3/2.10.1: The number of javax.xml.transform.Transformer object that are cached for reuse to avoid calls to Template.newTransformer(). saxon false Camel 2.11: Whether to use Saxon as the transformerFactoryClass. If enabled then the class net.sf.saxon.TransformerFactoryImpl. You would need to add Saxon to the classpath. errorListener Camel 2.14: Allows to configure to use a custom javax.xml.transform.ErrorListener. Beware when doing this then the default error listener which captures any errors or fatal errors and store information on the Exchange as properties is not in use. So only use this option for special use-cases. Using XSLT endpoints For example you could use something like ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. Fixed Advice-With to honor autoStartup option. FixedOnCompletion to route the completedExchangeeven if it was marked to stop / failed due exception / handled by error handler etc. Fixed using@EndpointInject with ref in RouteBuilderclasses, to enlist the endpoints in JMX during starting CamelContext when using OSGi New Enterprise Integration Patterns ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel iBATIS
oint See Also MyBatis View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Swagger
://localhost:8080/api-docs/param-value /init-param init-param param-nameapi.version/param-name param-value1.2.3/param-value /init-param init-param param-nameapi.title/param-name param-valueUser Services/param-value /init-param init-param param-nameapi.description/param-name param-valueCamel Rest Example with Swagger that provides an User REST service/param-value /init-param load-on-startup2/load-on-startup /servlet !-- swagger api declaration -- servlet-mapping servlet-nameApiDeclarationServlet/servlet-name url-pattern/api-docs/*/url-pattern /servlet-mapping ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel RabbitMQ
) topologyRecoveryEnabled true Camel 2.14: Enables connection topology recovery (should topology recovery be performed?) prefetchEnabled false Camel 2.14: Enables the quality of service on the RabbitMQConsumer side, you need to specify the option of prefetchSize, prefetchCount, prefetchGlobal at the same time prefetchSize 0 Camel 2.14: The maximum amount of content (measured in octets) that the server will deliver, 0 if unlimited. prefetchCount 0 Camel 2.14: The maximum number of messages that the server will deliver, 0 if unlimited. prefetchGlobal false Camel 2.14: If the settings should be applied to the entire channel rather than each consumer declare true Camel 2.14: If the option is true, camel declare the exchange and queue name and bind them together. If the option is false, camel won't declare the exchange and queue name on the server. See http://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/ConnectionFactory.html and the AMQP specification for more information on connection options. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel SJMS
=my.response.queueamp;exchangePattern=InOut / /route ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel SJMS
... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. OnCompletion can now be configured to use or not use a thread pool, and as well whether to run before or after the route consumer. Running before the consumer allows to modify the exchange before the consumer writes it as response to the callee (if consumer is InOut mode) AddedBulk Index message operation to Elasticsearch component. Added RoutePolicyFactory to create and assign aRoutePolicy for every route, instead of having to configure this for every route. MetricsRoutePolicyFactoryto expose route statistics using the codehale metrics library. ImprovedNettyWorkerPoolBuilder#buildvisibility. The SJMS component now uses Apache commons-pool for the pool implementation instead of custom code. UsingQuartz2 as polling consumer (QuartzScheduledPollConsumerScheduler) now supports task stored in JDBC data store, which means users can setup quartz in clustered mode Fixed Issues Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. Fixed Advice-With to honor autoStartup option. FixedOnCompletion to route the completedExchangeeven if it was marked to stop / failed due exception / handled by error handler etc. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Kafka
. From an Endpoint you can use the following methods createProducer() will create a Producer for sending message exchanges to the endpoint createConsumer() implements the Event Driven Consumer pattern for consuming message exchanges from the endpoint via a Processor when creating a Consumer createPollingConsumer() implements the Polling Consumer pattern for consuming message exchanges from the endpoint via a PollingConsumer See Also Configuring Camel Message Endpoint pattern URIs Writing Components View Online Like Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel XSLT
. transformerCacheSize 0 Camel 2.9.3/2.10.1: The number of javax.xml.transform.Transformer object that are cached for reuse to avoid calls to Template.newTransformer(). saxon false Camel 2.11: Whether to use Saxon as the transformerFactoryClass. If enabled then the class net.sf.saxon.TransformerFactoryImpl. You would need to add Saxon to the classpath. errorListener Camel 2.14: Allows to configure to use a custom javax.xml.transform.ErrorListener. Using XSLT endpoints For example you could use something like ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. OnCompletion can now be configured to use or not use a thread pool, and as well whether to run before or after the route consumer. Running before the consumer allows to modify the exchange before the consumer writes it as response to the callee (if consumer is InOut mode) AddedBulk Index message operation to Elasticsearch component. Added RoutePolicyFactory to create and assign aRoutePolicy for every route, instead of having to configure this for every route. MetricsRoutePolicyFactoryto expose route statistics using the codehale metrics library. ImprovedNettyWorkerPoolBuilder#buildvisibility. The SJMS component now uses Apache commons-pool for the pool implementation instead of custom code. Fixed Issues Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. Fixed Advice-With to honor autoStartup option. FixedOnCompletion to route the completedExchangeeven if it was marked to stop / failed due exception / handled by error handler etc. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel UuidGenerator
Claus Ibsen edited the page: UuidGenerator ... Starting with Camel 2.5, Camel supports 3rd party UUID generator(s). This is useful, if e.g. your messaging provider does not support UUID's with a length of 36 characters (like Websphere MQ). Another useful scenario is to use a simple counter for testing purpose. With this it is easier to correlate the exchanges in the log/debugger. Camel uses UUIDs in the exchange and message ids, and other unique ids it uses. You only have to implement org.apache.camel.spi.UuidGenerator and tell Camel, that it should use your custom implementation: Configuring from Java DSL Code Block getContext().setUuidGenerator(new MyCustomUuidGenerator()); ... Camel will configure this UUID generator by doing a lookup in the Spring bean registry to find the bean of the type org.apache.camel.spi.UuidGenerator. Code Block bean id=activeMQUuidGenerator class=org.apache.camel.impl.ActiveMQUuidGenerator / camelContext id=camel xmlns=http://camel.apache.org/schema/spring route from uri=direct:start / to uri=mock:result / /route /camelContext ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel User Stories
by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Idempotent Consumer
. Include Page Using This Pattern View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Infinispan
=org.infinispan.manager.DefaultCacheManager init-method=start destroy-method=stop/ bean id=infinispanRepo class=org.apache.camel.component.infinispan.processor.idempotent.InfinispanIdempotentRepository factory-method=infinispanIdempotentRepository argument ref=cacheManager/ argument value=idempotent/ /bean Then we can create our Infinispan idempotent repository in the spring XML file as well: Code Block xml camelContext xmlns=http://camel.apache.org/schema/spring route id=JpaMessageIdRepositoryTest from uri=direct:start / idempotentConsumer messageIdRepositoryRef=infinispanStore headermessageId/header to uri=mock:result / /idempotentConsumer /route /camelContext In c For more information, see these resources... ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Infinispan
Bilgin Ibryam edited the page: Infinispan ... Code Block xml camelContext xmlns=http://camel.apache.org/schema/spring route id=JpaMessageIdRepositoryTest from uri=direct:start / idempotentConsumer messageIdRepositoryRef=infinispanStore headermessageId/header to uri=mock:result / /idempotentConsumer /route /camelContext In c For more information, see these resources... ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Articles
Claus Ibsen edited the page: Articles ... Linkedin Apache Camel group - Linkedin group for the Apache Camel project. Google Plus Apache Camel community - G+ community for the Apache Camel project. EIP printable flashcards - A 6 page PDF with printable EIP cards. There are several companies that provide extra documentation, examples, tutorials, etc... See the Commercial Camel Offerings page for more details. Apache Camel Reference Card at DZone by Claus Ibsen The Top Twelve Integration Patterns for Apache Camel Reference Card at DZone by Claus Ibsen Essential Camel Components Reference Card at DZone by Christian Posta The Apache Camel Components Poster (PDF,PDF w/ crops and bleed,JPG image,Printed)by Gliesian LLC.(October, 2013) ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x The optionuseSsl has been removed fromcamel-twitter as ssl is always enabled now, enforced by twitter FixedRestlet to return error code 405 (instead of 404 if a http method is not allowed Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. If you want the routes to keep accepting messages during shutdown of Camel, then setacceptMessagesWhileStopping=true. OnCompletion now runs without thread pool by default. To restore old behavior setparalllelProcessing to true. Setting autoStartup to false, and starting a CamelContext the 2nd time now does not start the routes, instead use the new startAllRoutes method on CamelContext to start all the routes. Important changes to consider when upgrading ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel ServletListener Component
. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Solr
Endpoint See Also View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Metrics Component
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Metrics Component
. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... New Languages XMLTokenizer New Examples camel-example-splunk camel-example-servlet-rest-blueprint camel-example-servlet-rest-tomcat camel-example-spark-rest-tomcat camel-example-box-osgi New Tutorials New Tooling API changes ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. OnCompletion can now be configured to use or not use a thread pool, and as well whether to run before or after the route consumer. Running before the consumer allows to modify the exchange before the consumer writes it as response to the callee (if consumer is InOut mode) AddedBulk Index message operation to Elasticsearch component. Added RoutePolicyFactory to create and assign aRoutePolicy for every route, instead of having to configure this for every route. MetricsRoutePolicyFactoryto expose route statistics using the codehale metrics library. Fixed Issues Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. ImprovedNettyWorkerPoolBuilder#build visibility. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. OnCompletion can now be configured to use or not use a thread pool, and as well whether to run before or after the route consumer. Running before the consumer allows to modify the exchange before the consumer writes it as response to the callee (if consumer is InOut mode) AddedBulk Index message operation to Elasticsearch component. Added RoutePolicyFactory to create and assign aRoutePolicy for every route, instead of having to configure this for every route. MetricsRoutePolicyFactoryto expose route statistics using the codehale metrics library. ImprovedNettyWorkerPoolBuilder#buildvisibility. Fixed Issues Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses.ImprovedNettyWorkerPoolBuilder#build visibility FixedOnCompletion to route the completedExchangeeven if it was marked to stop / failed due exception / handled by error handler etc. New Enterprise Integration Patterns ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Advanced configuration of CamelContext using Spring
Claus Ibsen edited the page: Advanced configuration of CamelContext using Spring ... Type Number of beans Description InterceptStrategy 0..n To use your own Intercept that intercepts every processing steps in all routes in the CamelContext. For instance you can use this to do an AOP like performance timer interceptor. LifecycleStrategy 0..n Camel 2.1: To use 3rd party lifecycle strategies. By default Camel uses a JMX aware that does JMX instrumentation. EventNotifier 0..n Camel 2.2: To use 3rd part event notifiers. RoutePolicyFactory 0..n Camel 2.14: To use a 3rd party route policy factory to create a route policy for every route. Camel will log at INFO level if it pickup and uses a custom bean using org.apache.camel.spring.CamelContextFactoryBean as name. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. OnCompletion can now be configured to use or not use a thread pool, and as well whether to run before or after the route consumer. Running before the consumer allows to modify the exchange before the consumer writes it as response to the callee (if consumer is InOut mode) AddedBulk Index message operation to Elasticsearch component. Added RoutePolicyFactory to create and assign aRoutePolicy for every route, instead of having to configure this for every route. Fixed Issues Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. ImprovedNettyWorkerPoolBuilder#build visibility. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel RoutePolicy
org.apache.camel.spi.RoutePolicy}, or ttnull/tt to not use a policy for this route */ RoutePolicy createRoutePolicy(CamelContext camelContext, String routeId, RouteDefinition route); Note you can have as many route policy factories as you want. Just call the addRoutePolicyFactory again, or declare the other factories as bean in XML. See Also Route Throttling Example for an example using this in practice with the ThrottlingInflightRoutePolicy ScheduledRoutePolicy for information on policy based scheduling capability for camel routes Architecture View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Facebook
willem jiang edited the page: Facebook ... Code Block from(facebook://home?consumer.delay=55000) .to(bean:blah); Searching using a producer with dynamic options from header. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel File2
attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured. See more details at Polling Consumer. backoffIdleThreshold 0 Camel 2.12: The number of subsequent idle polls that should happen before the backoffMultipler should kick-in. backoffErrorThreshold 0 Camel 2.12: The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in. ... In the sample below we want to sort by last modified file, so we do: Code Block sortBy=file:modifedmodified And then we want to group by name as a 2nd option so files with same modifcation is sorted by name: Code Block sortBy=file:modifedmodified;file:name Now there is an issue here, can you spot it? Well the modified timestamp of the file is too fine as it will be in milliseconds, but what if we want to sort by date only and then subgroup by name? Well as we have the true power of File Language we can use the its date command that supports patterns. So this can be solved as: ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel ElasticSearch
route from uri=direct:index / to uri=elasticsearch://local?operation=INDEXindexName=twitterindexType=tweet/ /route A client would simply need to pass a body message containing a Map to the route. The result body contains the indexId created. Code Block java MapString, String map = new HashMapString, String(); map.put(content, test); String indexId = template.requestBody(direct:index, map, String.class); ... ElasticSearch Main Site ElasticSearch Java API Include Page Endpoint See Also View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
. Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. OnCompletion can now be configured to use or not use a thread pool, and as well whether to run before or after the route consumer. Running before the consumer allows to modify the exchange before the consumer writes it as response to the callee (if consumer is InOut mode) AddedBulk Index message operation to Elasticsearch component. Fixed Issues Timer consumer is now scheduled after CamelContext has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. ImprovedNettyWorkerPoolBuilder#build visibility. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Metrics Component
Name Default Description action - start or stop If no action or invalid value is provided then warning is logged without any timer update. If action start is called on already running timer or stop is called on not running timer then nothing is updated and warning is logged. // measure time taken by route calculate from(direct:in) .to(metrics:timer:simple.timer?action="" .to(direct:calculate) .to(metrics:timer:simple.timer?action=""> TimerContext objects are stored as Exchange properties between different Metrics component calls. Headers Message header can be used to override action value specified in Metrics component URI. Name Description Expected type CamelMetricsTimerAction Override timer action in URI org.apache.camel.component.metrics.timer.TimerEndpoint.TimerAction // sets timer action using header from(direct:in) .setHeader(MetricsConstants.HEADER_TIMER_ACTION, TimerAction.start) .to(metric:timer:simple.timer) .to(direct:out); View Online Like Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Metrics Component
Lauri Kimmel edited the page: Metrics Component ... Themetrics:component allows you to collect various metrics directly from Camel routes. Supported metric types arecounter,histogram, meterandtimer.Metricsprovides simple way to measure behaviour of your application. Configurable reportingbackendis enabling different integration options for collecting and visualizing statistics. ... Each metric has type and name. Supported types are counter, histogram,meterand timer. Metric name is simple string. If metric type is not provided then type meter is used by default. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Metrics Component
Lauri Kimmel edited the page: Metrics Component ... Themetrics:component allows to collect various metrics directly from Camel routes. Supported metric types arecounter,histogram, meterandtimer.Metricsprovides simple way to measure behaviour of your application. Configurable reportingbackendis enabling different integration options for collecting and visualizing statistics. ... Each metric has type and name. Supported types are counter, histogram,meterand timer. Metric name is simple string. If metric type is not provided then type meter is used by default. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Lauri Kimmel edited the page: Camel 2.14.0 Release Comment: Linked camel-metrics ... camel-ahc-ws camel-atmosphere-websocket camel-box camel-dropbox camel-metrics camel-netty4 camel-openshift camel-gora camel-rest (in camel-core) camel-spark-rest camel-swagger ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel HTTP4
Camel 2.14: The maximum number of total connections that the connection manager has. If this option is not set, camel will use the component's setting instead. connectionsPerRoute null Camel 2.14: The maximum number of connections per route. If this option is not set, camel will use the component's setting instead. authenticationPreemptive false Camel 2.11.3/2.12.2: If this option is true, camel-http4 sends preemptive basic authentication to the server. The following authentication options can also be set on the HttpEndpoint: ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Removed duplicate getter getMessageHistory onManagedCamelContextMBean Added org.apache.camel.spi.SynchronizationRouteAware AddedbeforeRoute and afterRoute methods to UnitOfWork. Added a new method toorg.apache.camel.component.jms.QueueBrowseStrategy to support JMS selectors Known Issues Dependency Upgrades ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel OnCompletion
/onCompletion See Also Unit of Work View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel SQL Component
charles Moulliard edited the page: SQL Component Comment: #:name to :#name_of_the_parameter ... From Camel 2.11 onwards you can use named parameters by using #:name :#name_of_the_parameter style as shown: Code Block sql:select * from table where id=:#myId order by name[?options] ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Swagger
.
Wiki Markup
{snippet:id=e2|lang=xml|url="">
The CorsFilter sets the following headers for all requests
Access-Control-Allow-Origin = *
Access-Control-Allow-Methods =GET, HEAD, POST, PUT, DELETE, TRACE, OPTIONS, CONNECT, PATCH
Access-Control-Max-Age = 3600
Access-Control-Allow-Headers =Origin, Accept, X-Requested-With, Content-Type, Access-Control-Request-Method, Access-Control-Request-Headers
Notice this is a very simple CORS filter. You may need to use a more sophisticated filter to set the header values differently for a given client. Or block certain clients etc.
Examples
In the Apache Camel distribution we ship thecamel-example-servlet-rest-tomcat which demonstrates using this Swagger component.
View Online Like View Changes
Stop watching space Manage Notifications
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Facebook
. It is also used by consumer endpoints to poll Facebook data to avoid sending duplicate messages across polls. ... Message header Any of the URI optionsoptions#urioptions can be provided in a message header for producer endpoints with CamelFacebook. prefix. ... To create a post within your Facebook profile, send this producer a facebook4j.PostUpdate body. Code Block from(direct:foo) .to(facebook://postFeed/inBody=postUpdate); To poll, every 5 sec .(You can set thepolling consumeroptions by adding a prefix of consumer), all statuses on your home feed: Code Block from(facebook://home?consumer.delay=5) .to(bean:blah); ... In the bar header we have the Facebook search string we want to execute in public posts, so we need to assign this value to the CamelFacebook.query header. Code Block from(direct:foo) .setHeader(CamelFacebook.query, header(bar)) .to(facebook://posts); View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Swagger
g headers for all requests ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Maven Archetypes ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Swagger
Path of the api api.title String Required.The title of the application. api.description String Required.A short description of the application. api.termsOfServiceUrl String A URL to the Terms of Service of the API. api.contact String An email to be used for API-related correspondence. api.license String The license name used for the API. api.licenseUrl String A URL to the license used for the API. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Swagger
The version of the api. Is default 0.0.0. api.path String Path of the apiTo setup the path where the API is available (eg /api-docs) api.title String Required.The title of the application. api.description String Required.A short description of the application. api.termsOfServiceUrl String A URL to the Terms of Service of the API. api.contact String An email to be used for API-related correspondence. api.license String The license name used for the API. api.licenseUrl String A URL to the license used for the API. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
details. jsonDataFormat Name of specific json data format to use. By default json-jackson will be used. Notice: Currently Jackson is what we recommend and are using for testing. xmlDataFormat Name of specific XML data format to use. By default jaxb will be used. Notice: Currently only jaxb is supported. componentProperty Allows to configure as many additional properties. This is used to configure component specific options such as forRestlet/Spark-Restetc. endpointProperty Allows to configure as many additional properties. This is used to configure endpoint specific options for Restlet/Spark-Restetc. consumerProperty Allows to configure as many additional properties. This is used to configure consumer specific options for Restlet/Spark-Restetc. dataFormatProperty Allows to configure as many additional properties. This is used to configure the data format specific options. For example set property prettyPrint to true to have json outputted in pretty mode. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Polling Consumerallows to configure initial queue size and whether to block when full when using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x The optionuseSsl has been removed fromcamel-twitter as ssl is always enabled now, enforced by twitter FixedRestlet to return error code 405 (instead of 404 if a http method is not allowed Routes starting fromJMSwill now shutdown the consumer (MessageListenerContainer) quicker when CamelContext is being stopped. (assuming theacceptMessagesWhileStopping hasn't been set to true). This can also help a cleaner shutdown as otherwise some JMS clients may attempt re-connect/failover during shutdown which isn't desired anyway as we are shutting down. If you want the routes to keep accepting messages during shutdown of Camel, then setacceptMessagesWhileStopping=true. Important changes to consider when upgrading ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
specific options for Restlet/Spark-Restetc. dataFormatProperty Allows to configure as many additional properties. This is used to configure the data format specific options. For example set property prettyPrint to true to have json outputted in pretty mode. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
consumer specific options for Restlet/Spark-Restetc. dataFormatProperty Allows to configure as many additional properties. This is used to configure the data format specific options. For example set property prettyPrint to true to have json outputted in pretty mode. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel XmlJson
dependency groupIdorg.apache.camel/groupId artifactIdcamel-xmljson/artifactId versionx.x.x/version !-- Use the same version as camel-core, but remember that this component is only available from 2.10 onwards -- /dependency ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel JDBC
. For example {{CUST_ID}} is mapped as {{custId}}. |
{div}
...
View Online Like View Changes
Stop watching space Manage Notifications
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel JDBC
. For example {{CUST_ID}} is mapped as {{custId}}. |
{div}
...
View Online Like View Changes
Stop watching space Manage Notifications
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... camel-ahc-ws camel-atmosphere-websocket camel-box camel-dropbox camel-metrics camel-netty4 camel-openshift camel-gora camel-rest (in camel-core) camel-spark-rest ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Christian Mueller edited the page: Camel 2.14.0 Release ... Polling Consumerallows to configure initial queue size and whether to block when full when using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x The optionuseSsl has been removed fromcamel-twitter as ssl is always enabled now, enforced by twitter FixedRestlet to return error code 405 (instead of 4040 404 if a http method is not allowed ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Polling Consumerallows to configure initial queue size and whether to block when full when using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x The optionuseSsl has been removed fromcamel-twitter as ssl is always enabled now, enforced by twitter FixedRestlet to return error code 405 (instead of 4040 if a http method is not allowed Important changes to consider when upgrading ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Splunk
Preben Asmussen edited the page:
Splunk
...
Wiki Markup
{div:class=confluenceTableSmall}
|| Name || Default Value || Context || Description ||
|host | localhost | Both | Splunk host.
|port | 8089 | Both | Splunk port
| username | null | Both | Username for Splunk
| password | null | Both | Password for Splunk
| connectionTimeout | 5000 | Both | Timeout in MS when connecting to Splunk server
| useSunHttpsHandler | false | Both | Use sun.net.www.protocol.https.Handler Https hanlder to establish the Splunk Connection.
Can be useful when running in application servers to avoid app. server https handling.
| index | null | Producer | Splunk index to write to
| sourceType | null | Producer | Splunk sourcetype arguement
| source | null | Producer | Splunk source arguement
| tcpReceiverPort | 0 | Producer | Splunk tcp receiver port when using tcp producer endpoint.
| initEarliestTime | null | Consumer | Initial start offset of the first search. Required
| earliestTime | null | Consumer | Earliest time of the search time window.
| latestTime | null | Consumer | Latest time of the search time window.
| count | 0 | Consumer | A number that indicates the maximum number of entities to return.
Note this is not the same as maxMessagesPerPoll which currently is unsupported
| search | null | Consumer | The Splunk query to run
| savedSearch | null | Consumer | The name of the query saved in Splunk to run
| streaming | false | Consumer | *Camel 2.14.0* : Stream exchanges as they are received from Splunk, rather than returning all of them in one batch. This has the benefit of receiving results faster, as well as requiring less memory as exchanges aren't buffered in the component.
{div}
Message body
Splunk operates on data in key/value pairs. The SplunkEvent class is a placeholder for such data, and should be in the message body for the producer. Likewise it will be returned in the body per search result for the consumer.
...
View Online Like View Changes
Stop watching space Manage Notifications
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel How do I import rests from other XML files
. View Online Like Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
Claus Ibsen edited the page: Rest DSL ... See Also DSL Rest Spark-rest How do I import rests from other XML files View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... camel-ahc-ws camel-atmosphere-websocket camel-box camel-dropbox camel-metrics camel-openshift camel-gora camel-rest (in camel-core) camel-spark-rest ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Removed duplicate getter getMessageHistory onManagedCamelContextMBean Added org.apache.camel.spi.SynchronizationRouteAware AddedbeforeRoute and afterRoute methods to UnitOfWork. Added a new method toorg.apache.camel.component.jms.QueueBrowseStrategy to support JMS selectors Known Issues Dependency Upgrades ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
Claus Ibsen edited the page: Rest DSL ... The following Camel components supports the Rest DSL. See the bottom of this page for how to integrate a component with the Rest DSL. camel-netty-http camel-jetty camel-restlet camel-servlet camel-spark-rest Rest DSL with Java To use the Rest DSL in Java then just do as with regular Camel routes by extending theRouteBuilder and define the routes in theconfigure method. ... Any Apache Camel component can integrate with the Rest DSL if they can be used as a REST service (eg as a REST consumer in Camel lingo). To integrate with the Rest DSL, then the component should implement theorg.apache.camel.spi.RestConsumerFactory. The Rest DSL will then invoke thecreateConsumer method when it setup the Camel routes from the defined DSL. The component should then implement logic to create a Camel consumer that exposes the REST services based on the given parameters, such as path, verb, and other options. For example see the source code for camel-restlet, camel-spark-rest. See Also DSL Rest Restlet Spark-rest View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
has started all routes, to ensure other routes is running when timer routes is triggered to run. Netty HTTP now returns HTTP status 404 if resource not found instead of 503. Fixed the MongoDBreadPreferenceoption which used to cause an IllegalArgumentExceptionto be thrown. Fixed issue with Netty producer may leak HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. ImprovedNettyWorkerPoolBuilder#build visibility. ... New Tutorials New Tooling API changes Removed duplicate getter getMessageHistory onManagedCamelContextMBean Added org.apache.camel.spi.SynchronizationRouteAware AddedbeforeRoute and afterRoute methods to UnitOfWork. Known Issues Dependency Upgrades ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel OnCompletion
Claus Ibsen edited the page: OnCompletion ... Camel has this concept of a Unit of Work that encompass the Exchange. The unit of work among others supports synchronization callbacks that are invoked when the Exchange is complete. The callback API is defined in org.apache.camel.spi.Synchronization. From Camel 2.14 onwards we have an extended synchronization org.apache.camel.spi.SynchronizationRouteAwarethat have callbacks for route events. Tip title Getting the UnitOfWork You can get hold of the org.apache.camel.spi.UnitOfWork from org.apache.camel.Exchange with the method getUnitOfWork(). ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
Claus Ibsen edited the page: Rest DSL ... The Rest DSL is a facade that builds Restendpoints as consumers for Camel routes. The actual REST transport is leveraged by using Camel REST components such asRestlet,Spark-rest, and others that has native REST integration. Components supporting Rest DSL The following Camel components supports the Rest DSL. See the bottom of this page for how to integrate a component with the Rest DSL. camel-jetty camel-restlet camel-spark-rest Rest DSL with Java To use the Rest DSL in Java then just do as with regular Camel routes by extending theRouteBuilder and define the routes in theconfigure method. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Jetty
} ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel XStream
willem jiang edited the page: XStream ... Code Block XStream xStream = new XStream(); xStream.aliasField(money, PurchaseOrder.class, cash); // new Added setModel option since Camel 2.14 xStream.setModel(NO_REFERENCES); ... from(direct:marshal). marshal(new XStreamDataFormat(xStream)). to(mock:marshaled); ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
. componentProperty Allows to configure as many additional properties. This is used to configure component specific options such as forRestlet/Spark-Restetc. endpointProperty Allows to configure as many additional properties. This is used to configure endpoint specific options for Restlet/Spark-Restetc. consumerProperty Allows to configure as many additional properties. This is used to configure consumer specific options for Restlet/Spark-Restetc. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Jasypt
l.result}}/
/route
/camelContext
/blueprint
ThePropertiescomponent can also be inlined inside thecamelContexttag which is shown below. Notice how we use thepropertiesParserRefattribute to refer toJasypt.
Code Block
language
xml
blueprint xmlns=http://www.osgi.org/xmlns/blueprint/v1.0.0
xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance
xmlns:cm=http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0
xsi:schemaLocation=
http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
!-- define the jasypt properties parser with the given password to be used --
bean id=jasypt class=org.apache.camel.component.jasypt.JasyptPropertiesParser
property name=password value=secret/
/bean
camelContext xmlns=http://camel.apache.org/schema/blueprint
!-- define the camel properties placeholder, and let it leverage jasypt --
propertyPlaceholder id=properties
location=classpath:org/apache/camel/component/jasypt/myproperties.properties
propertiesParserRef=jasypt/
route
from uri=direct:start/
to uri={{cool.result}}/
/route
/camelContext
/blueprint
See Also
Security
Properties
Encrypted passwords in ActiveMQ - ActiveMQ has a similar feature as this camel-jasypt component
View Online Like View Changes
Stop watching space Manage Notifications
This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Rest DSL
. componentProperty Allows to configure as many additional properties. This is used to configure component specific options such as forRestlet/Spark-Restetc. endpointProperty Allows to configure as many additional properties. This is used to configure endpoint specific options for Restlet/Spark-Restetc. consumerProperty Allows to configure as many additional properties. This is used to configure consumer specific options for Restlet/Spark-Restetc. dataFormatProperty Allows to configure as many additional properties. This is used to configure the data format specific options. For example set property prettyPrint to true to have json outputted in pretty mode. For example to configure to use the spark-rest component on port 9091, then we can do as follows ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Atomikos 3.9.2 to 3.9.3 Commons-codec 1.8 to 1.9 CXF 2.7.11 to 3.0.0 Deltaspike 0.7 to 1.0.0 Dozer 5.4.0 to 5.5.1 EhCache 2.8.1 to 2.8.3 Groovy 2.2.2 to 2.3.3 Guava 16.0.1 to 17.0 Hapi 2.1 to 2.2 Hazelcast 3.0.3 to 3.2.4 JRuby 1.7.10 to 1.7.12 MongoDB-Java-Driver 2.11.4 to 2.12.0 RabbitMQ AMQ Client 3.2.2 to 3.3.0 RxJava 0.17.5 to 0.19.4 Scala 2.10.3 to 2.10.4 Snmp4j 2.2.5 to 2.3.0 SSHD 0.10.1 to 0.11.0 spring-redis 1.1.0 to 1.3.0 ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Atomikos 3.9.2 to 3.9.3 Commons-codec 1.8 to 1.9 CXF 2.7.11 to 3.0.1 Deltaspike 0.7 to 1.0.1 Dozer 5.4.0 to 5.5.1 EhCache 2.8.1 to 2.8.3 Groovy 2.2.2 to 2.3.4 Guava 16.0.1 to 17.0 Hapi 2.1 to 2.2 Hazelcast 3.0.3 to 3.2.4 JRuby 1.7.10 to 1.7.12 MongoDB-Java-Driver 2.11.4 to 2.12.0 RabbitMQ AMQ Client 3.2.2 to 3.3.0 RxJava 0.17.5 to 0.19.4 Scala 2.10.3 to 2.1011.42 Snmp4j 2.2.5 to 2.3.0 SSHD 0.10.1 to 0.11.0 spring-redis 1.1.0 to 1.3.0 ... Polling Consumerallows to configure initial queue size and whether to block when full when using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x Important changes to consider when upgrading ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Restlet
} ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel XML Security component
. Verifying Options The verifier endpoint has the following options. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
Claus Ibsen edited the page: Camel 2.14.0 Release ... Atomikos 3.9.2 to 3.9.3 Commons-codec 1.8 to 1.9 CXF 2.7.11 to 3.0.1 Deltaspike 0.7 to 1.0.1 Dozer 5.4.0 to 5.5.1 EhCache 2.8.1 to 2.8.3 Groovy 2.2.2 to 2.3.4 Guava 16.0.1 to 17.0 Hapi 2.1 to 2.2 Hazelcast 3.0.3 to 3.2.4 JRuby 1.7.10 to 1.7.12 MongoDB-Java-Driver 2.11.4 to 2.12.0 RabbitMQ AMQ Client 3.2.2 to 3.3.0 Restlet 2.17 to 2.2.1 RxJava 0.17.5 to 0.19.4 Scala 2.10.3 to 2.11.2 Snmp4j 2.2.5 to 2.3.0 SSHD 0.10.1 to 0.11.0 spring-redis 1.1.0 to 1.3.0 Twitter4j 3.0.5 x to 4.0.1 Internal changes Changed ... ... Polling Consumerallows to configure initial queue size and whether to block when full when using the defaultEventDrivenPollingConsumer which most components does. We now block by default, as otherwise the message may be lost if the queue was full, and a new message was offered. camel-scala upgraded from Scala 2.10.x to 2.11.x The optionuseSsl has been removed fromcamel-twitter as ssl is always enabled now, enforced by twitter Important changes to consider when upgrading ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel JSON
(); format.setInclude(NON_NULL); Or from XML DSL you configure this as Code Block dataFormats json id=json library=Jackson include=NOT_NULL/ /dataFormats Dependencies for XStream To use JSON in your camel routes you need to add the a dependency on camel-xstream which implements this data format. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel JSON
. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
[CONF] Apache Camel Camel 2.14.0 Release
HashWhealTimer instances when having many producers that are not reused. Fixed issue with Netty consumer should wait for join to complete when joining a multicast group over UDP Improved stability when testing withcamel-test-blueprint component. Netty HTTPnow removes headerFilterStrategy option after resolvingit Fixed POJO aggregating when the parameter type was referring to a type that was class annotated. FixedMyBatisto keep the message body as-is when calling stored procedures, if the procedure returns data as OUT parameters. Fixed Camel Karaf commands to work with multiple CamelContext from the same bundle. Fixed Advice-With to work with transacted routes defined in XML DSL Fixed Advice-With to work with Content Based Router when adding outputs to the when clauses. ImprovedNettyWorkerPoolBuilder#build visibility. ... View Online Like View Changes Stop watching space Manage Notifications This message was sent by Atlassian Confluence 5.0.3, Team Collaboration Software
