High accuracy scheduler

I need to create a schedule, i.e. a list of messages with a specific delivery time, with 100s of milliseconds accuracy. The route has only one recipent. Currently I have implemented it using ActiveMQ and the AMY_SCHEDULED_DELAY. The scheduling is working, but the accuracy is poor; the messages get

Binding IN and OUT message using annotation

In an inOut route I would like to bind the IN and the OUT message to method parameters using annotations. Something like; public void foo(@body String inMessage, @X String outMessage) I cant find this in the annottation description. -- View this message in context: http://camel.465427.n5.nabb

Re: Programatically adding beans to a registry in a RouteBuilder

I meant that I in the RouteBuilder::configure have; JndiRegistry registry = (JndiRegistry) getContext().getRegistry(); // DO NOT WORK! --- Thanks for the suggestion. The code PropertyPlaceholderDelegateRegistry registry = (PropertyPlaceholderDelegateRegistry) getContext().getRegistry()

Re: Programatically adding beans to a registry in a RouteBuilder

Hmmm... tried that but doesnt work. getContext() returns a org.apache.camel.impl.PropertyPlaceholderDelegateRegistry object. Which cant be cast to JndiRegistry. My setup is the following; In a Spring based route I have bean A. Bean As @Handler will create an instance of bean B, which is a RouteBu

Programatically adding beans to a registry in a RouteBuilder

How can I in the 'configure' method of a RouteBuilder add beans to the registry? Im in a RouteBuilder creating a route using Netty. The Netty URL reference encoder/decoder beans. I need to create and insert these beans in the registry. The Netty description (last code example) indicates that you

Problems using ProxyBuilder

Im trying to use the proxy builder but fails. I have defined the interface; *public interface IDataAccess { public List retrieveData(DataRequest request); public List retrieveState(StateRequest request); public OrbitalState getOrbitalState(OrbitalStateRe

Count of messages that have parsed an Endpoint

I want to at intervals log the number of messages that have parsed a given endpoint. I assume that JMX is the way to go, but cant figure out if there is a 'standard' Endpoint / Route property that hold the value I need. -- View this message in context: http://camel.465427.n5.nabble.com/Count-of

Re: Asynchronous Jetty

Yes, that is what I did in the end as well. I then let the 'main' route return a 'Ongoing' message using ''. Initially I considered this a 'hack', but I now start to see this as a quite valid solution. -- View this message in context: http://camel.465427.n5.nabble.com/Asynchronous-Jetty-tp474855p

Returning status messages

I have a route that is invoked by a user through a GUI. The route may easily take 2-3 hours to complete. I would like to send back notifications to the user, showing him the progress (... and that something is happening). The route has 4 processors. I have until now been using a second route as

Re: Asynchronous Jetty

Unfortunately using "threads" doesnt solve the problem as suggested. I'm also trying to configure Jetty to return immediately and failing miserably. I have tried the configuration; http://localhost:4242/request?synchronous=false"/> But the call is still "hanging" until the route completes. Wha

Re: How can I insert data in Solr from Camel ?

See http://www.villemos.com/?q=ispace/components http://www.villemos.com/?q=ispace/components . You need the 'Aperture' component for text extraction and the 'Solr' component for injection / retrieval. -- View this message in context: http://camel.465427.n5.nabble.com/How-can-I-insert-data-in-S

Re: How can I insert data in Solr from Camel ?

The Solr component has been compiled against Camel 2.7.0. I will be migrating it to the latest Camel version soon. -- View this message in context: http://camel.465427.n5.nabble.com/How-can-I-insert-data-in-Solr-from-Camel-tp4684539p4839539.html Sent from the Camel - Users mailing list archive a

Starting a route after another completes

I have a route 'from' a file component processing all files in a directory. When all have been processed (and not before), then I want another route to start. I tried 'startupOrder' but both routes are still started almost together, not when the lower order has completed. How can I configure tha

Scheduling the file component to only process at specific intervals

I'm using an omnipotent file component to read through a potentially very large directory structure (days of processing). To limit the load of the system and not interfere with existing systems, I would like to limit the time that the file component runs, for example to be from 22.00 until 06.00 t

Camel and Android

Has anyone tried to use Camel on an Android OS? It 'should just work' as its all Java, but that is famous last words. Does anyone have concrete experience demonstrating the usage? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-and-Android-tp4418575p4418575.html Sent from

Re: Conceptual 'correctness' of using Camel Unit Tests

>From the comments I conclude that we should apply both 'normal' unit tests and Camel unit tests (= integration tests). -- View this message in context: http://camel.465427.n5.nabble.com/Conceptual-correctness-of-using-Camel-Unit-Tests-tp4372286p4374003.html Sent from the Camel - Users mailing li

Conceptual 'correctness' of using Camel Unit Tests

Some would argue that a unit test per definition tests the unit completely standalone. Using JUnit this is easy, especially when combined with Spring, i.e. you can isolate your bean and test each method directly. The Camel Junit on the other hand test the unit as part of a camle route. Even if the

Re: Routing based on exchange IN message body clas

Indeed, as you say and as its documented rather nicely on the wiki, the 'is' operator works fine; ${body} is org.hbird.exchange.type.Parameter' Just out of curiosity; why doesn't 'getClass.getName' work? What are the limitations in allowed return types of a method? -- View this message in cont

Re: Routing based on exchange IN message body clas

Its because the getClass() method doesnt return a String but a Class object, i.e. creating an inheritance hierarchy and using accessor methods returning String from base classes works fine. Is there any way around this limitation? Do I need to tell 'Simple' what type is returned from getClass? --

Re: Routing based on exchange IN message body clas

There seems to be a limitation that makes this impossible; the 'Simple' evaluation doesnt seem able to access methods that are inherited. I thus cant access the 'class', as the getClass method is inherited. The route ${body.getClass.getName} == 'org.hbird.exchange.type.Parameter'}

Re: Routing based on exchange IN message body clas

... and if I'm using the Spring annotation, i.e. XML? -- View this message in context: http://camel.465427.n5.nabble.com/Routing-based-on-exchange-IN-message-body-clas-tp4313282p4313325.html Sent from the Camel - Users mailing list archive at Nabble.com.

Routing based on exchange IN message body clas

Is there a a way to route an exchange based on the class hold in the IN message body? I have a 'splitter' bean that creates message of different types. I would like to route the different messages differently. I could create a simple bean to set a header field based on the body and then route ba

Re: Camel Log4j Appender

Creating a custom log4j appender is very easy (... indeed we have one but we are not happy with it as it only injects into ActiveMQ and not into a Camel route). Our only problem (and this is now turning into a developer question more than a user question) is how can the custom Appender which is a

Camel Log4j Appender

Did this issue moved forward? I can find a log4j JMS logger that can inject data into an ActiveMQ, but I would like to inject events into a camel route which might go to ActiveMQ, but might also have other steps. Can this be done? -- View this message in context: http://camel.465427.n5.nabble.

Re: Cometd component

Thanks for the suggestion. I have found the conceptual problem on my side; the XStream / Jackson marshalling both created a Byte array as the body of the message based on the Object, not a string formatted as "{[name]:[value]}". I thus expected to receive something like "{value:123,name:"Foo",..

Cometd component

I have problems understanding how the cometd component publish objects. I have my own class called 'Parameter'. I want to publish instances of 'Parameter' through cometd to a website. I would expect the data arriving through cometd to have a structure similar to my Parameter definition. However t

'Class not found' when Creating Camel route through Activemq console

I post this here and not in the activemq forum, as its a Camel route that courses the problem. In our setup I have Camel routes configured to inject to / read from a activemq topic called 'Parameters'. Each message in the body contains a POJO of type 'org.hbird.exchange.type.Parameter'. I have no

Difference between camel-activemq (1.1.0) and activemq-camel (5.2.0) libraries

What is the difference between the * Camel-Activemq (1.1.0) * Activemq-Camel (5.2.0) Libraries? Is the 'Camel-Activemq' library simply an old deprecated version no longer used? And should I always use 'Activemq-Camel'? Or is there a subtle difference? -- View this message in context: http:/

Re: Howto use delay message brokerage in a Camel Route using AMQ_SCHEDULED_DELAY

Setting the scheduledSupport=true did the trick. And looking at the Activemq page describing the delay header fields, the second line clearly states that you have to do this to use the properties. Sight! Poor reading skills on my side. Just for anybody else who needs to set this and wonder where t

Howto use delay message brokerage in a Camel Route using AMQ_SCHEDULED_DELAY

As part of my routes, I need a processor to calculate and set a delay in the distribution. The message should be released to the Activemq topic/queue, but only send to subscribers when the delay has expired. AMQ_SCHEDULED_DELAY seems ideal for this. But I cant get it to work. In my processor bean

How to only process messages at a specific time?

I would like to have an Activemq queue, where multiple publishers push data to, and multiple subscribers pop these, in a distributed environment. Thanks to Camel and ActiveMQ that's easy, so far. My problem is that the message I push have a 'processing time', i.e. they should not be processed in t

Best way of storing JMS messages

We used ActiveMQ, sending JMS messages. The JMS messages contains a POJO, as well as header fields, set based on the values in the POJO and used for filtering in the routes. We would like to also store the messages, in a way so that we can later use the header fields for retrieving. As an example

Re: Camel and Tomcat

I must be doing something wrong. I configure a servlet component in a route. I use an applicationContext.xml file to load the application / routes. The route is defined as (an extract); The web.xml is as shown below; http://www.w3.org/2001/XMLSchema-instance"; xmlns="htt

Camel and Tomcat

I would like to create a component that process URL requests. I have implemented this using Jetty, but would now like to deploy the complete application within Tomcat. Which Camel component should I use to receive URL requests through Tomcat? I have looked at the HTTP component but that is only