Re: Topic consume with polling (connection, thread) Need exmple

Babak, Below is the brief which may help you to understand my use case. I have application which uses ActiveMQ (V 5.3.0) as MOM. We are using Camel (V 2.7.2) to CONSUME messages from the MOM server. One of the Module belongs to my application needs to register to camel with 7 unique subject for

Re: connecting to new jms implementation

Hello, thank You both for advices. i started implementing my own Component and whole set of classes around it, taking inspiration from JmsComponent and ActiveMQ connector. Here is what I try to achieve in dumb code (without proper connection pooling etc.). AMIQueueConnectionFactory factory =

Re: connecting to new jms implementation

I just mentioned the camel-xmpp component as it is small. So you can learn how to wrap up your code into a camel component. So basically you would throw all the xmpp stuff out of the xmpp component and put your code below into the producer side. Christian Am 24.11.2011 10:00, schrieb

Selective Multicast

I am completely clueless of what I am doing wrong. Below are the 2 code snippets that works. But if I need to place the processor of snippet-2 in snippet-1 it doesn't work. Please help me knowing the reason. I need to solve this urgently now. :-( Working snippet -1 from(file:inbox)

Component for SSH CLI

Hi, Is there a Camel component for SSH command line interface. Please let me know your comment. With Best Regards, Diwakar -- View this message in context: http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5019772.html Sent from the Camel - Users mailing list

onCompletition block

Hi, Can I have multiple onCompletition block in single camel's route? My route is following: from(direct:test) .onCompletition().onCompleteOnly() .to(directsuccess) .end() .onCompletition().onFailureOnly() .to(direct:failure) .end() .process(new MyProcessor()) .end(); But,

Re: Component for SSH CLI

I don't think we have this kind of component out of box in Camel . On Thu Nov 24 18:15:00 2011, diwakar wrote: Hi, Is there a Camel component for SSH command line interface. Please let me know your comment. With Best Regards, Diwakar -- View this message in context:

Re: Topic consume with polling (connection, thread) Need exmple

Hi, happy to see that you've done some progress on this high-load-requirement issue, and that now we both use the same vocabulary, that's CONSUMER and not PRODUCER (just think of the camel's RouteBuilder class of yours you called it RouteProducer in [1]). But this is not sufficenat at all as

Need tips for splitter/aggregator with large data

Hi all! I have a requirement to transform a fairly large set of xml data that I fetch over HTTP and then FTP it out. After getting my first OOME I started reading up a bit on how you could utilize the splitter with streaming and tokenizing pairs (2.9RC) which worked well for me for splitting and

Dynamic Consumers

Hello All, I have a question regarding dymaic uri inside toF() DSL Given below is my route from(direct:bootstraproute) .setHeader(Exchange.HTTP_METHOD,constant(org.apache.camel.component.http4.HttpMethods.GET)) .toF(https4://myapi.com/%s.json?type=2,header(eventid))

Re: Defining a CXF bus in Blueprint for use with cxfbean endpoint

On Nov 23, 2011, at 4:40 PM, Daniel Kulp wrote: No. At that point, you start actually using parts of CXF's blueprint support: http://cxf.apache.org/schemas/blueprint/core.xsd Use: cxf:bus xmlns:cxf=http://cxf.apache.org/blueprint/core; name=cxf .. /cxf:bus Dan Thanks

Re: Topic consume with polling (connection, thread) Need exmple

Hi again, BTW the online javadoc link you've provided in your previous post [1] is not that much up-to-date, try [2] for a better javadoc documentation (activemq-pool-5.5.0) which is more accurate regarding the JMS connection session pooling. [1]

Re: CSV to database

Is it possible to share your code with us? This makes much more easier to help you. And our processor should look like this one: public class MyProcessor implements Processor { @Override public void process(Exchange exchange) throws Exception { Foo foo =

How to get full control over threads used by JMS/ActiveMQ component?

I've been trying for a while now to figure out how to get full control over the threads used by the JMS/ActiveMQ components... and so far I've had zero luck. Seems like no matter what I try, the JMS component always goes and makes a bunch of threads. I'm testing out with some simple routes:

HTTP Basic authenticaiton on CxfEndpoint

I would like to use HTTP basic authentication when making a web service call using CXF. This is basically my code. CxfEndpoint cxfEndpoint = new CxfEndpoint(app.getMessageServiceUrl(), camelContext); cxfEndpoint.setServiceClass(PartnerSMSService.class.getCanonicalName()); RouteDefinition def =

Re: Need tips for splitter/aggregator with large data

On Thu, Nov 24, 2011 at 3:47 PM, Billy billy.sjob...@gmail.com wrote: Hi all! I have a requirement to transform a fairly large set of xml data that I fetch over HTTP and then FTP it out. After getting my first OOME I started reading up a bit on how you could utilize the splitter with

Testing an http component

In Camel 2.7 I need to make an HTTP request to a remote web server from inside a bean. The route looks like: route id=billing.commit from uri=activemq:queue:billing.outbound?concurrentConsumers=50amp;maxConcurrentConsumers=70 / to uri=bean:billingBean?method=process/ inOnly