How to access a cache entry within a Java bean called from a camel route?

2016-04-28 Thread catshout
Dear Camel community, I'm using ServiceMix with Camel and Camel Cache. I've created a route like this .. Further I've created a bean with some Java code. I want to access the cache value inside the bean. How to refer to the cache and further to the cache entry within the bean? Any help is hig

Is queue prioritization is possible if multiple queues are used to poll?

2016-04-28 Thread sabyasachi087
My from bean uses a list of messages queues (between 1-300) to poll data , check a condition , throttle and send it to another bean for processing. The router looks like :-> from(this.getQueues()).transacted("jmsRequired").choice() .when(this.predicate)

Trouble sending a ByteBuffer to a mock

2016-04-28 Thread Steve Huston
I am using Camel 2.16.3. I have a route like so: from("direct:sendPing").routeId("rms-send-ping") .process(new Processor() { public void process(Exchange exchange) throws Exception { Message in = exchange.getIn(); AssetPing p = new AssetPi

Re: Salesforce Subscription to topic not working over Proxy

2016-04-28 Thread vijaychd
Yes. Query works fine using HTTP proxy. Only Subscribe to Topic doesn't work. -- View this message in context: http://camel.465427.n5.nabble.com/Salesforce-Subscription-to-topic-not-working-over-Proxy-tp5781898p5781917.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: warning while calling Bean ref in camel route

2016-04-28 Thread ravi narayanan
Hi John, I have tried it and getting the same error... On Thursday, 28 April 2016, John D. Ament wrote: > You should quote the string when passing it in, e.g. > > > method="logAuditMessage(${body},'A1_Sync_Con_RQ Request Received :')" /> > > Then it will be passed in as the second argument as a

Re: Camel FTP + Seda problems

2016-04-28 Thread Brad Johnson
That's why when I mentioned the decoupled routes it depended on what was most important. If deleting it off the remote site quickly was the chief goal then using a file in a temp directory could accomplish that quickly. In your case that doesn't seem to be the issue. On Thu, Apr 28, 2016 at 10:40

Re: warning while calling Bean ref in camel route

2016-04-28 Thread John D. Ament
You should quote the string when passing it in, e.g. Then it will be passed in as the second argument as a string. On Thu, Apr 28, 2016 at 11:48 AM ravi21588 wrote: > Hi All, > > Iam getting below warn when i call the bean ref in camel route > > > 17:44:18,385 WARN [org.apache.camel.util.Obj

Re: Camel FTP + Seda problems

2016-04-28 Thread semephor
got it that works as expected now, thank you for quick response! -- View this message in context: http://camel.465427.n5.nabble.com/Camel-FTP-Seda-problems-tp5781799p5781910.html Sent from the Camel - Users mailing list archive at Nabble.com.

warning while calling Bean ref in camel route

2016-04-28 Thread ravi21588
Hi All, Iam getting below warn when i call the bean ref in camel route 17:44:18,385 WARN [org.apache.camel.util.ObjectHelper] (http-/127.0.0.1:8080-18) Cannot find class: A1_Sync_Con_RQRequestReceived Java class: package com.example.switchyard.a1.sync.consumer.rq; import javax.enterprise.

Re: Salesforce Subscription to topic not working over Proxy

2016-04-28 Thread Claus Ibsen
Hi Do you mean HTTP Proxy? eg you need to configure camel-salesforce to use a HTTP proxy ? On Thu, Apr 28, 2016 at 4:53 PM, vijaychd wrote: > I am using below to subscribe to a topic. > camel-salesforce > version: 2.1.17 > > Subscription fails over the proxy with "Unknown Client". Without the p

Re: Camel FTP + Seda problems

2016-04-28 Thread Claus Ibsen
See the javadoc of the receieve method you use on the consumer template. It refers you to the doneUoW method, which you must call with the exchange to signal to Camel when you are finished working with the exchange. On Thu, Apr 28, 2016 at 5:21 PM, semephor wrote: > Thanks for the responses. > O

Re: Camel FTP + Seda problems

2016-04-28 Thread semephor
Is there a way to mark the exchange as 'DONE' when the ConsumerTemplate has read it? using the exchange properties? thanks -- View this message in context: http://camel.465427.n5.nabble.com/Camel-FTP-Seda-problems-tp5781799p5781908.html Sent from the Camel - Users mailing list archive at Nabble

Re: Camel FTP + Seda problems

2016-04-28 Thread semephor
Thanks for the responses. Ok Claus I see now that the Exchange is not complete until I process the messages off the SEDA queue. I am trying to do this using a ConsumerTemplate in a seperate thread with loop as below, however, once I have taken the message off the SEDA queue it does still not seem

Re: Context Component issue

2016-04-28 Thread Aaron Birkland
Hi, I noticed a recent jira comment that indicates the context component is deprecated[1] I couldn't find anything in the code or documentation that indicates deprecation. Is there now a better alternative for the kinds of use cases the context component supported? [1] https://issues.apache.org

Re: Salesforce Subscription to topic not working over Proxy

2016-04-28 Thread Rahul Taneja
Are you from chandigarh? On Thu, Apr 28, 2016, 8:29 PM vijaychd wrote: > I am using below to subscribe to a topic. > camel-salesforce > version: 2.1.17 > > Subscription fails over the proxy with "Unknown Client". Without the > proxy, > it works fine. > > Please help. I need to use Proxy to con

Salesforce Subscription to topic not working over Proxy

2016-04-28 Thread vijaychd
I am using below to subscribe to a topic. camel-salesforce version: 2.1.17 Subscription fails over the proxy with "Unknown Client". Without the proxy, it works fine. Please help. I need to use Proxy to connect to Salesforce. Here is the log message 2016-04-06 22:07:29.760 INFO 11508 --- [

Re: Camel FTP + Seda problems

2016-04-28 Thread Brad Johnson
You could also decouple this into two atomic routes as well depending on what's important to you and what it is you're trying to achieve and if there are any security concerns about setting the file down, etc.. from ftp with delete to tempFile from tempFile to seda On Thu, Apr 28, 2016 at 4:57 A

Re: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread Sven Bauhan
On 04/27/16 15:36, ravi narayanan wrote: Hi Claus, I tried implementing timeout aware aggregation strategy and implemented timeout method in it. now when ever timeout happens(complete Timeout/Partial Response) the Old exchange message is coming to timeout method. Of course it is the old exchange,

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

2016-04-28 Thread arunkabraham
I am using camel-rx to connect to a queue from a web application. Each time I invoke the REST service it will publish a message and observe the queue with reactive camel. once it gets back a message from queue based on the correlation id, it will return the response back to the user. But a new act

Re: Camel FTP + Seda problems

2016-04-28 Thread Claus Ibsen
The file is only deleted when the exchange is "done" processed at the end. If you want to separate that, then use the wire tap EIP On Wed, Apr 27, 2016 at 3:01 PM, semephor wrote: > Hello! > > I am having a strange problem when using the FTP and SEDA components > together. > > If I do the below

Re: Camel FTP + Seda problems

2016-04-28 Thread semephor
I'm raising this as a bug. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-FTP-Seda-problems-tp5781799p5781861.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

2016-04-28 Thread Claus Ibsen
Those are ActiveMQ threads as you embed an entire ActiveMQ broker then it has its own set of threads it runs. On Thu, Apr 28, 2016 at 11:12 AM, arunkabraham wrote: > Can you please suggest on the issue mentioned above? > > > > -- > View this message in context: > http://camel.465427.n5.nabble.co

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

2016-04-28 Thread arunkabraham
Can you please suggest on the issue mentioned above? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5781857.html Sent from the Camel - Users mailing list archive at Nabble.com.

2 way asynchronous TCP/IP communication (not request-reply fashion) using netty4

2016-04-28 Thread anish
Hi All, I would like to know how can I establish a restriction-free 2 way TCP channel in camel using netty/mina ? "sync" option is allowing me to receive only the reply for the request which I have made. I would like to receive all the data which is pushing by the server followed by the login repl

Re: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread Claus Ibsen
Ah the javadoc does explain this nicely * @param oldExchange the current aggregated exchange, or the original {@link Exchange} if no aggregation * has been done before the timeout occurred On Thu, Apr 28, 2016 at 10:18 AM, Claus Ibsen wrote: > On Thu, Apr 28, 2016 at 10:09 A

Re: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread ravi narayanan
Thanks Claus and Siano,It answers my question. On Thu, Apr 28, 2016 at 10:18 AM, Claus Ibsen wrote: > On Thu, Apr 28, 2016 at 10:09 AM, Siano, Stephan > wrote: > > Hi, > > > > Maybe the issue is about the definition of the "old" exchange in the > timeout method. This is the exchange that contai

Re: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread Claus Ibsen
On Thu, Apr 28, 2016 at 10:09 AM, Siano, Stephan wrote: > Hi, > > Maybe the issue is about the definition of the "old" exchange in the timeout > method. This is the exchange that contains everything that was aggregated at > the time the timeout occurs. The timeout method just gives you the > op

RE: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread Siano, Stephan
Hi, Maybe the issue is about the definition of the "old" exchange in the timeout method. This is the exchange that contains everything that was aggregated at the time the timeout occurs. The timeout method just gives you the opportunity to clean this data up. Does this answer the question? Be

Re: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread Claus Ibsen
If you enable streaming mode on recipient then the aggregate is called when the responses come back. Otherwise the aggregate is called in the same order as the recipient list endpoints, eg first recipient response, 2nd recipient response, 3rd ... N. On Thu, Apr 28, 2016 at 10:00 AM, ravi narayana

Re: Handling timeout in Recipient list with aggregation statergy

2016-04-28 Thread ravi narayanan
Hi Sven, I have two endpoints set in recipient list header delimiter seperated. I meant when i receive response from both the endpoints only then will the aggregate method gets called,else will it call timeout method.? On Wed, Apr 27, 2016 at 10:22 PM, Sven Bauhan wrote: > On 04/27/16 15:36, r