Example of using BlobMessage

Hi all, we just switched to using Camel + Activemq for message routing and spooling in JAMES. At the moment we store the whole MimeMessage as a byte array in the payload of the Exchange. This is super inefficient because of the possibility of very big emails. So I consider using BlobMessages for s

Re: Passing Headers/Properties between (NMR) endpoints

Thanks for the response. So, how is this (setting Exchange properties) done? willem.jiang wrote: > > Hi > > I think the properties means to set the Camel Exchange properties. > There is no properties for Camel Message. > > Willem > > lekkie wrote: >> Hi guys, >> >> I 'd like to pass an hea

Re: Multiple JPA Consumers

I will use DSL and get away from Spring config. I am not fussy with how I define the route in DSL or Spring config. Thanks for quick response mate.. Claus Ibsen-2 wrote: > > On Tue, Mar 2, 2010 at 7:41 AM, vcheruvu > wrote: >> >> can jdbc or ibatis endpoint have multiple consumers from a tab

Re: Multiple JPA Consumers

On Tue, Mar 2, 2010 at 7:41 AM, vcheruvu wrote: > > can jdbc or ibatis endpoint have multiple consumers from a table rather than > creating another same route in the context file? Why isn't there multiple > consumer concept in Camel that read in from a table? I am thinking that this > would be pop

Re: Multiple JPA Consumers

can jdbc or ibatis endpoint have multiple consumers from a table rather than creating another same route in the context file? Why isn't there multiple consumer concept in Camel that read in from a table? I am thinking that this would be popular requirement that most people could face when they wa

Re: restlet header

Hi Take a look at some of the unit tests in camel-restlet. I wonder if any of those shows how to use headers? And try with a simple header without using dots (generally a bad think to do as keys). On Mon, Mar 1, 2010 at 7:03 PM, Tapdur wrote: > > Hi > > i am trying to get a specific applicatio

Re: Multiple JPA Consumers

On Mon, Mar 1, 2010 at 11:43 PM, vcheruvu wrote: > > Apologies, I did not clearly explain in the previous post. > > Basically I am trying to see how can I can have  multiple consumers at same > JPA endpoint.  So, multiple consumers will poll the table where each > consumer will get next 100 record

Re: Best Strategy - aggregation

On Mon, Mar 1, 2010 at 8:24 PM, Andrew Chandler wrote: > When does 2.3 come out - sounds like what I want, just I'm pretty sure > we can't update to something that isn't released yet or at least very > close to release > 2.2 was just recently released. I would think 2.3 is a couple of more months

Re: issue with cometd on OSGI server (SMX 4.x)

Please ignore my last mail, which past a wrong url. cometd-jetty component is broken into cometd-server and cometd-client. And lots of package name is change, it may take us some time to upgrade it. So I filled a JIRA for it[1]. [1]https://issues.apache.org/activemq/browse/CAMEL-2513 Willem W

Re: issue with HTTP response content length being set to CXF request length - causing truncated responses.

Hi Can you check out the latest released Camel 2.2.0 ? We fix this kind of issue[1] in Camel 2.2.0. [1] https://issues.apache.org/activemq/browse/CAMEL-2425 Willem Wayne Keenan wrote: Deleting the content length header as the last action is a workaround. Should I raise thus as an issue? Reg

Re: issue with cometd on OSGI server (SMX 4.x)

cometd-jetty component is broken into cometd-server and cometd-client. And lots of package name is change, it may take us some time to upgrade it. So I filled a JIRA for it[1]. [1]http://old.nabble.com/issue-with-cometd-on-OSGI-server-%28SMX-4.x%29-ts27745415.html Willem Willem Jiang wrote:

Re: issue with cometd on OSGI server (SMX 4.x)

It's looks like camel cometd component's dependency is out of date. After google a while, I found the Jetty changed the cometd artifact ID[1]. So we need to update this on camel-cometd component to fill the jetty version gap :) [1]http://groups.google.com/group/cometd-dev/browse_thread/thread/f

Re: Passing Headers/Properties between (NMR) endpoints

Hi I think the properties means to set the Camel Exchange properties. There is no properties for Camel Message. Willem lekkie wrote: Hi guys, I 'd like to pass an header in between two NMR endpoints. Here is my config:

Re: camel-http: basic authentication and query parameter "username"

Hi Matteo, Did you receive my reply mail and try the solution of setting the message header with the Exchange.HTTP_QUERY just like this ? from("timer://foo?fixedRate=true&delay=0&period=1") .setHeader(Exchange.HTTP_QUERY, "username=YOUR_NAME") .to("http://remoteserver.location/get_user_inf

Re: Camel/Mina java.net.MalformedURLException: unknown protocol: c

Hi It looks like the Camel DefaultPackageScanClassResolver can't deal with the URL like this zip:C:/bea923/user_projects/domains/iardomain/servers/AdminSer ver/tmp/_WL_user/_appsdir_CamelIAR_war/hapurq/war/WEB-INF/lib/camel-core-2.2.0.j ar!/org/apache/camel/component/file/ As we don't have th

Camel/Mina java.net.MalformedURLException: unknown protocol: c

I am getting this error when I use this route with camel 2.2, Maven POM file is attahced, is this a bug in camel 2.2 or am I doing this wrong. from("mina:tcp://localhost:6202?textline=true&sync=true").process(new Processor() { public void process(Exchange exch

Re: issue with HTTP response content length being set to CXF request length - causing truncated responses.

Deleting the content length header as the last action is a workaround. Should I raise thus as an issue? Regards Wayne On 1 Mar 2010, at 19:22, Wayne Keenan wrote: Hi, I have run into an issue where the HTTP response message is being truncated to the exactly length of the incoming CXF re

Re: Multiple JPA Consumers

Apologies, I did not clearly explain in the previous post. Basically I am trying to see how can I can have multiple consumers at same JPA endpoint. So, multiple consumers will poll the table where each consumer will get next 100 records. I am treating the table as a queue using readpast selec

Re: Best Strategy - aggregation

When does 2.3 come out - sounds like what I want, just I'm pretty sure we can't update to something that isn't released yet or at least very close to release On Mon, 2010-03-01 at 19:51 +0100, Claus Ibsen wrote: > Hi > > Try with the new overhauled aggreagtor in 2.3 > http://camel.apache.org/ag

issue with HTTP response content length being set to CXF request length - causing truncated responses.

Hi, I have run into an issue where the HTTP response message is being truncated to the exactly length of the incoming CXF request, i.e. response.contentLength seems to be being set to the request.contentLength, I have the following setup: 1. I am advertising a WSDL file via a CXF endpoint.

Re: Best Strategy - aggregation

Hi Try with the new overhauled aggreagtor in 2.3 http://camel.apache.org/aggregator2.html It works bette with completion trigger. On Mon, Mar 1, 2010 at 5:40 PM, Andrew Chandler wrote: > Hi there - with Clause help I've been able to get most of the way to > where I need to be.   Right now I'm

restlet header

Hi i am trying to get a specific application header in my http request over restlet and it always null why ? here is the client request : GET http://127.0.0.1/greeting HTTP/1.0 Accept: xml/application IGC-E164: 3370301169 User-Agent: Jakarta Commons-HttpClient/3.1 Host: 127.0.0.1 here is my lo

Re: How To Handle Mina Correlation

anandsk, i saw this somewhere http://bci.fuw.edu.pl/wiki/Multiplexer it has some code available in google code if you would take a look at it On Tue, Mar 2, 2010 at 1:06 AM, Claus Ibsen wrote: > On Mon, Mar 1, 2010 at 5:25 PM, anandsk wrote: > > > > Th

Re: Mina IP rotation on client side

On Mon, Mar 1, 2010 at 5:35 PM, anandsk wrote: > > Hi, > > I have to connect to external tcp server. I can have only one client > connection at a time and I need to send and receive messages asynchronously. > I have list of IP addresses I can connect to but can use only one at a time. > is there a

Re: How To Handle Mina Correlation

On Mon, Mar 1, 2010 at 5:25 PM, anandsk wrote: > > Thank you for quick response. In the documentation it says, it is supported > for jetty component only. Can I use it with apache Mina?. would the codecs > work with this toasync use. can I use 2.2 in prod or should I wait for it > stabilize a bit.

Best Strategy - aggregation

Hi there - with Clause help I've been able to get most of the way to where I need to be. Right now I'm doing a proof of concept with string payloads,however in the end the payload will be an object. Here's what I'm attempting I have an incoming message that contains an identifier as well as (

Mina IP rotation on client side

Hi, I have to connect to external tcp server. I can have only one client connection at a time and I need to send and receive messages asynchronously. I have list of IP addresses I can connect to but can use only one at a time. is there an easy way to rotate IP addresses on Apache Mina endpoint on

Re: How To Handle Mina Correlation

Thank you for quick response. In the documentation it says, it is supported for jetty component only. Can I use it with apache Mina?. would the codecs work with this toasync use. can I use 2.2 in prod or should I wait for it stabilize a bit. Claus Ibsen-2 wrote: > > On Mon, Mar 1, 2010 at 3:42

issue with cometd on OSGI server (SMX 4.x)

Hi, I have adapted the camel Cometd example generating randomly GPS coord which are displayed in a Google Map HTML page The producer generating the coord is started but the following error is reported on the console : ka...@root> >>> Produce coord. Exception in thread "ContinuationBayeux-0" jav

Re: How To Handle Mina Correlation

On Mon, Mar 1, 2010 at 3:42 PM, anandsk wrote: > > Hi, > > can you please share your code of thread polling for a response. I am also > need to send a message to extranl tcp/ip server visa apache mina. I can't > wait for the response so I need to poll for a response, can you please share > your co

Re: How To Handle Mina Correlation

Hi, can you please share your code of thread polling for a response. I am also need to send a message to extranl tcp/ip server visa apache mina. I can't wait for the response so I need to poll for a response, can you please share your code if you don't mind.I don't need to correlate because I do

Re: How To Handle Mina Correlation

On Mon, Mar 1, 2010 at 7:38 AM, Carlo Camerino wrote: > Hi, > > I would like to ask if this is possible, I am sending a message to an > external tcp/ip server via apache mina so i configure it in my camel > context. > I'm using one thread to send it and another thread is polling for the > reply me

Re: Multiple JPA Consumers

Hi I assume you are talking about having concurrent JPA consumers on the same JPA endpoint? eg you want this one: jpa:com.MyEntity?consumer.namedQuery=pollRecords&consumeDelete=false&delay=3000 To have concurrent threads processing it? If not what are you talking about? On Mon, Mar 1, 2010 at

Passing Headers/Properties between (NMR) endpoints

Hi guys, I 'd like to pass an header in between two NMR endpoints. Here is my config: myroute and here is my router config