Re: Supply custom parameters to bean

[Claus Ibsen]

On Fri, Nov 25, 2011 at 6:35 PM, Xenofon Papadopoulos  wrote:
> Is it possible to supply custom parameters to a bean used in several routes?
> For example something like:
>
> 
>   
>   
>   
>   http://camel.apache.org/bean-binding.html

For older Camel releases you cannot easily do this.

> Thanks
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

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

[Jason Dillon]

Thanks, that seems to do it :-)

--jason


On Nov 25, 2011, at 1:57 AM, Joshua Watkins wrote:

> I was able to limit the number of threads by setting the consumerType to
> simple and the taskExecutor to a spring ThreadPoolTaskExecutor
> bean that I created. I didn't use the ThreadPoolProfile class.
> 
> I hope this helps.
> 
> On 24/11/2011 22:19, "Jason Dillon"  wrote:
> 
>> rType(ConsumerType.Simple);
>> ActiveMQComponent jms = new ActiveMQComponent(jmsConfig);
>> 
> 

Re: Configuration for Apache camel...

[Björn Bength]

Hi,

depends on what you do with your objects..
if all transaction payload are very, very large objects coming in at
the same time and/or you store them in memory it will eventually leak
yes.
If you do normal sensible processing, and your load is spread out over
the day, one million transactions a day is not too much at all.
one million tx per hour should also be fine (from a camel perspective)
if your hardware is not too old and your backend systems are up to it.
you might need to add load balancing to another node at this stage
depending on all aspects of your case.

Regards
B

On Fri, Nov 25, 2011 at 10:34 PM, atiato  wrote:
> Dears ,
> I would like to know if there is special configuration for camel if we are
> having heavy load , let us assume the following :
>
> 1- have Mina TCP endpoint .
> 2- from TCP I use JAXB to transform XML coming into Object.
> 3- call the Web service using CXF endpoint.
> 4- convert response into Object .
> 5- use JAXB to convert Object to XML .
> 6- return that XML as response to TCP session.
>
> I have more than million transaction per day .
>
> How can I handle such load in apache camel taking into consideration high
> availability with two sun server and load balancing assume WS response is
> less than 1 second.
>
> Can this cause a memory leaks for example and use 100 % of memory .
>
> Can this consume all CPU and resources of the system .
>
> does this need to increase memory used for apache camel ?
>
> let us say we are having solaries sparc as hardware .
>
> I really appreciate your response .
>
> Thanks,
> Omar Atia
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Configuration-for-Apache-camel-tp5023724p5023724.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Configuration for Apache camel...

[atiato]

Dears ,
I would like to know if there is special configuration for camel if we are
having heavy load , let us assume the following :

1- have Mina TCP endpoint .
2- from TCP I use JAXB to transform XML coming into Object.
3- call the Web service using CXF endpoint.
4- convert response into Object .
5- use JAXB to convert Object to XML .
6- return that XML as response to TCP session.

I have more than million transaction per day .

How can I handle such load in apache camel taking into consideration high
availability with two sun server and load balancing assume WS response is
less than 1 second.

Can this cause a memory leaks for example and use 100 % of memory .

Can this consume all CPU and resources of the system .

does this need to increase memory used for apache camel ?

let us say we are having solaries sparc as hardware .

I really appreciate your response .

Thanks,
Omar Atia

--
View this message in context: 
http://camel.465427.n5.nabble.com/Configuration-for-Apache-camel-tp5023724p5023724.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Remote Messaging Using CAMEL

[newbiee]

CAMEL Community:

 I have raised this question earlier also and got some directions which are
great, but I am still stuck at a critical step and need your help in solving
it.

I am new to CAMEL and learning it. I have a project which I have explained
in my other post but now I am focusing on where I am stuck. I have drawn a
diagram which I am attaching with this post in an attempt to better convey
my question. I am develpoing a prototype to prove that CAMEL can be used to
solve this problem.

I have written a small java program to send a command to the digi device and
I'm sucessfully able to execute it and getting the response back from the
truck. I have used "jsch-0.1.41.jar" in my program. Now I want to prove that
this can be done in CAMEL. This will be a great way to convince others and
launch CAMEL and start using it at work place.

I have been told that NETTY or MINA camel component can be used. 
I have been told to use EXEC component for command line
I have been told to use template.requestBody

The suggestion are great, but I need more help in put all the pieces
together.

Here I only want to discuss how to prepare a route that will 

1. Send a command to the digi device
2. Receive response from the digi device

I want to implement and test it with actual digi device. I do not want a
test case. I have spent a lot of time, trying to implement it but I could
not, though I have learnt a lot about unit testing, direct endpoint,
consumer and producer template but I am unable to put all the dots together
to come-up with the solution. I think direct endpoint, consumer and producer
template are good for unit testing, not for implementing/executing actual
route. (I may be wrong)

Please help me in completing this prototype.

Thank you.




http://camel.465427.n5.nabble.com/file/n5023683/toAndFromTruck.jpg 

--
View this message in context: 
http://camel.465427.n5.nabble.com/Remote-Messaging-Using-CAMEL-tp5023683p5023683.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Remote Messaging using CAMEL

[newbiee]

CAMEL Community:

 I have raised this question earlier also and got some directions which are
great, but I am still stuck at a critical step and need your help in solving
it.

I am new to CAMEL and learning it. I have a project which I have explained
in my other post but now I am focusing on where I am stuck. I have drawn a
diagram which I am attaching with this post in an attempt to better convey
my question. I am develpoing a prototype to prove that CAMEL can be used to
solve this problem.

I have written a small java program to send a command to the digi device and
I'm sucessfully able to execute it and getting the response back from the
truck. I have used "jsch-0.1.41.jar" in my program. Now I want to prove that
this can be done in CAMEL. This will be a great way to convince others and
launch CAMEL and start using it at work place.

I have been told that NETTY or MINA camel component can be used. 
I have been told to use EXEC component for command line
I have been told to use template.requestBody

The suggestion are great, but I need more help in put all the pieces
together.

Here I only want to discuss how to prepare a route that will 

1. Send a command to the digi device
2. Receive response from the digi device

I want to implement and test it with actual digi device. I do not want a
test case. I have spent a lot of time, trying to implement it but I could
not, though I have learnt a lot about unit testing, direct endpoint,
consumer and producer template but I am unable to put all the dots together
to come-up with the solution. I think direct endpoint, consumer and producer
template are good for unit testing, not for implementing/executing actual
route. (I may be wrong)

Please help me in completing this prototype.

Thank you.


 


http://camel.465427.n5.nabble.com/file/n5023678/toAndFromTruck.jpg 

--
View this message in context: 
http://camel.465427.n5.nabble.com/Remote-Messaging-using-CAMEL-tp5023678p5023678.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Supply custom parameters to bean

[Xenofon Papadopoulos]

Is it possible to supply custom parameters to a bean used in several routes?
For example something like:


   
   
   
   

Re: CSV to database

[Idriss]

Of course. 

you find in attchement the source code for my example.
http://camel.465427.n5.nabble.com/file/n5023529/camel-example-etl2.zip
camel-example-etl2.zip 

Best,

--
View this message in context: 
http://camel.465427.n5.nabble.com/CSV-to-database-tp4435750p5023529.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Single request with multiple replies over TCP

[jonv]

Thanks Ioannis however the 'responses' are never ending. Which is why I
mentioned its like pub/sub.

The two applications I have use an 'always open' TCP connection where the in
and out messages streams are effectively 'sessionless'. E.g.

TCP Client opens connection with TCP Sever Listener .
Client sends  a message to Srv.
Srv continually sends messages to cli over the same connection.
(Plus there may be the possiblity that the client sends further messages in
the future).

So a gathering strategy will not work here!

What I require is the request and response channels to work independently.

DO you think camel can support this?

--
View this message in context: 
http://camel.465427.n5.nabble.com/Single-request-with-multiple-replies-over-TCP-tp5022206p5022909.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to create a Proxy per request

[KingAndrew]

Hi All,
  I'm sooo close. :-)  Here is my code
/*
 * It enables us to switch between iteamone corbaStubs and eagle camelProxys
 */
public Object getProxy(java.lang.Object impl, Class
interfaceToImplement){
CamelServiceExporter remoteExpt = new CamelServiceExporter ();
remoteExpt.setService(impl);
remoteExpt.setServiceInterface(interfaceToImplement);

RemoteExporter packageClass = new RemoteExporter() {
};
return remoteExpt.getProxyForService();//<- Not public but
protected.
}

Here is how I want to use the above code:

// Replacing this -> retRef =
javax.rmi.PortableRemoteObject.narrow(ref, pClass);
// With:
retRef =proxy.getProxy(ref, pClass);

Is there no way to get the RemoteExporter proxy from
the CamelServiceExporter?

Thanks for your time,

Andrew




On Mon, Nov 21, 2011 at 8:40 PM, Andrew Boyd  wrote:

> Correction: the last call should have been *getProxyForService*() instead
> of getService().
>
>
> On Mon, Nov 21, 2011 at 8:33 PM, Andrew Boyd wrote:
>
>> Ok so with messaging we are de-coupled do the proxy can accept an
>> endpoint:
>>
>> Echo service = ProxyHelper.createProxy(context.getEndpoint("direct:echo"), 
>> Echo.class);
>>
>>
>> I still need to pass around a reference to a particular Object.  So I
>> guess my question should be how I generate an Exporter on the fly.
>>
>> Now after I RTFM I think I have the answer:
>>
>> *RemoteExporter  remoteExpt = 
>> RemoteExporter
>> *()
>> remoteExpt.*setService*(br); // br from the code I need to replace.
>> remoteExpt.*setServiceInterface*(RequestInterface);
>>
>> myProxyToPassAround = (RequestInterface)remoteExpt.getService();
>>
>> I think that should do it. I didn't compile but that is basically it.
>>
>> Thanks,
>>
>> Andrew
>>
>>
>> On Mon, Nov 21, 2011 at 8:03 PM, Andrew Boyd wrote:
>>
>>> Hi Claus,
>>>   In the links you provided it shows how to make a proxy for a
>>> particular Class.  I want to make a proxy for a particular Object.
>>>
>>> I want to replace this:
>>> RequestImpl br = (RequestImpl) tmpHolder.get(ndx);  // <- br is the Impl
>>>  retList[ndx] = (RequestInterface) javax.rmi.PortableRemoteObject
>>> .narrow(br.getObjectRef(), RequestInterface.class);  //<-- The br object
>>> will be linked to the stub being created.
>>>
>>> I didn't see an api that I can pass in an object to link the proxy to
>>> the pojo.
>>>
>>> Thanks,
>>>
>>> Andrew
>>>
>>> On Fri, Nov 18, 2011 at 1:58 AM, Claus Ibsen-2 [via Camel] <
>>> ml-node+s465427n5003615...@n5.nabble.com> wrote:
>>>
 Hi

 Have you seen the user guide?
 http://camel.apache.org/user-guide.html

 It has a link to using camel proxy
 http://camel.apache.org/using-camelproxy.html



 On Fri, Nov 18, 2011 at 1:59 AM, KingAndrew <[hidden 
 email]>
 wrote:

 > Hi All,
 >  Currently my system is Corba/RMI-IIOP.  We are using Camel to
 decouple the
 > services.  We have a request repository that contains RequestItems
 which are
 > the target remote objects.  As a new RequestItemImpl is created how
 can I
 > create a CamelProxyFactoryBean (proxy) on the fly?  I would then pass
 the
 > proxy between the services as we do now with the RMI stub.
 >
 >  I checked the api for CamelProxyFactoryBean and there weren't any
 create
 > methods close to what I was hoping for.
 >
 >  Anyone have any ideas how I can tie a proxy to a specific object
 instance?
 >
 > Thanks in advance,
 >
 > Andrew
 >
 > --
 > View this message in context:
 http://camel.465427.n5.nabble.com/How-to-create-a-Proxy-per-request-tp5002903p5002903.html
 > Sent from the Camel - Users mailing list archive at Nabble.com.
 >



 --
 Claus Ibsen
 -
 FuseSource
 Email: [hidden email]
 Web: http://fusesource.com
 Twitter: davsclaus, fusenews
 Blog: http://davsclaus.blogspot.com/
 Author of Camel in Action: http://www.manning.com/ibsen/


 --
  If you reply to this email, your message will be added to the
 discussion below:

 http://camel.465427.n5.nabble.com/How-to-create-a-Proxy-per-request-tp5002903p5003615.html
  To unsubscribe from How to create a Proxy per request, click 
 here
 .
 NAML

Re: connecting to new jms implementation

[saiya-jin]

never mind last post, it was a misfired message via ProducerTemplate.
Producer part works, now I'll take a look at Consumer part, which requires
polling and firing messages into Camel. 
Thanx so far! ;)

--
View this message in context: 
http://camel.465427.n5.nabble.com/connecting-to-new-jms-implementation-tp5017200p5022888.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: using vm: with different camelContexts and property parser

[Claus Ibsen]

2011/11/25 Björn Bength :
> Hi
>
> a theory: when camel searches for properties, (anything in it's
> "registry")  it looks in Exchange.getCamelContext...
> and as the exchange (when using the vm: component) is created in one
> camelcontext and sent by reference to another camel context in the
> same jvm,
> the second context receives the exchange and then tries to use things
> on the camelcontext specified on the exchange.

Yes this is what would happen. The vm component need to create a new
Exchange and copy from the previous Exchange to ensure it's properly
setup to run in the CamelContext where its hosted.

Feel free to create a JIRA ticket.

> This has happened a lot to me regarding error handlers and other
> components available in one context but not another, but they are then
> usable in the context
> they are not supposed to be.
> Does that make sense?
> If, on the other hand, JMS or some other component is used, the first
> camel context is not copied by reference to the other context, but the
> JMS component
> knows it's own camel context.
>
> /Björn
>
>
>
> On Fri, Nov 25, 2011 at 2:45 PM, Claus Ibsen  wrote:
>> Hi
>>
>> Can you paste a sample of the routes you use?
>>
>>
>>
>> On Fri, Nov 25, 2011 at 2:03 PM, kudrevatykh  wrote:
>>> Hello, today I tried to use properties as defined in examples.
>>> And found that with vm: uri when sender uses one context and receiver
>>> another, property searched in sender context, instead of receiver, where
>>> route is defined.
>>> When using activemq anything is fine and properties searched in receiver.
>>> camel version is 2.8.1
>>> can anybody explain, why expression parser behave in such way, or, if it
>>> unexpexted behaviour create bug in bug tracker :)
>>>
>>> Thanks, Alexander.
>>>
>>> --
>>> View this message in context: 
>>> http://camel.465427.n5.nabble.com/using-vm-with-different-camelContexts-and-property-parser-tp5022731p5022731.html
>>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>>
>>
>>
>>
>> --
>> Claus Ibsen
>> -
>> FuseSource
>> Email: cib...@fusesource.com
>> Web: http://fusesource.com
>> Twitter: davsclaus, fusenews
>> Blog: http://davsclaus.blogspot.com/
>> Author of Camel in Action: http://www.manning.com/ibsen/
>>
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: using vm: with different camelContexts and property parser

[Björn Bength]

Hi

a theory: when camel searches for properties, (anything in it's
"registry")  it looks in Exchange.getCamelContext...
and as the exchange (when using the vm: component) is created in one
camelcontext and sent by reference to another camel context in the
same jvm,
the second context receives the exchange and then tries to use things
on the camelcontext specified on the exchange.
This has happened a lot to me regarding error handlers and other
components available in one context but not another, but they are then
usable in the context
they are not supposed to be.
Does that make sense?
If, on the other hand, JMS or some other component is used, the first
camel context is not copied by reference to the other context, but the
JMS component
knows it's own camel context.

/Björn



On Fri, Nov 25, 2011 at 2:45 PM, Claus Ibsen  wrote:
> Hi
>
> Can you paste a sample of the routes you use?
>
>
>
> On Fri, Nov 25, 2011 at 2:03 PM, kudrevatykh  wrote:
>> Hello, today I tried to use properties as defined in examples.
>> And found that with vm: uri when sender uses one context and receiver
>> another, property searched in sender context, instead of receiver, where
>> route is defined.
>> When using activemq anything is fine and properties searched in receiver.
>> camel version is 2.8.1
>> can anybody explain, why expression parser behave in such way, or, if it
>> unexpexted behaviour create bug in bug tracker :)
>>
>> Thanks, Alexander.
>>
>> --
>> View this message in context: 
>> http://camel.465427.n5.nabble.com/using-vm-with-different-camelContexts-and-property-parser-tp5022731p5022731.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>
>
>
> --
> Claus Ibsen
> -
> FuseSource
> Email: cib...@fusesource.com
> Web: http://fusesource.com
> Twitter: davsclaus, fusenews
> Blog: http://davsclaus.blogspot.com/
> Author of Camel in Action: http://www.manning.com/ibsen/
>

Re: Single request with multiple replies over TCP

[Ioannis Canellos]

If you are expecting one message for each response, then I guess that you
can get this message back by having the sync option set to true.
However, I think that you mentioned multiple responses per request. I think
that you could easily solve this one by implementing the appropriate
filter, that would gather all the responses and group them into a single
message before returning it to the io handler.

-- 
*Ioannis Canellos*
*
FuseSource 

**
Blog: http://iocanel.blogspot.com
**
Apache Karaf  Committer & PMC
Apache Camel  Committer
Apache ServiceMix   Committer
Apache Gora  Committer
Apache DirectMemory  Committer
*

Re: using vm: with different camelContexts and property parser

[Claus Ibsen]

Hi

Can you paste a sample of the routes you use?



On Fri, Nov 25, 2011 at 2:03 PM, kudrevatykh  wrote:
> Hello, today I tried to use properties as defined in examples.
> And found that with vm: uri when sender uses one context and receiver
> another, property searched in sender context, instead of receiver, where
> route is defined.
> When using activemq anything is fine and properties searched in receiver.
> camel version is 2.8.1
> can anybody explain, why expression parser behave in such way, or, if it
> unexpexted behaviour create bug in bug tracker :)
>
> Thanks, Alexander.
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/using-vm-with-different-camelContexts-and-property-parser-tp5022731p5022731.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: connecting to new jms implementation

[saiya-jin]

Thank You a lot, it helped me to move forward. Methods at my endpoint are
called, but unfortunately process(Exchange exchange) on my Producer is not
called when message is sent, and thus communication line is not finished.
Methods like doStart() from DefaultConsumer are. 
Is the endpoint name in URI important? I don't see what it is matched
against.
I would like to stick with creating whole component rather than separate
producers and consumers if possible, so I rather take this approach.
Thank You!

--
View this message in context: 
http://camel.465427.n5.nabble.com/connecting-to-new-jms-implementation-tp5017200p5022779.html
Sent from the Camel - Users mailing list archive at Nabble.com.

using vm: with different camelContexts and property parser

[kudrevatykh]

Hello, today I tried to use properties as defined in examples.
And found that with vm: uri when sender uses one context and receiver
another, property searched in sender context, instead of receiver, where
route is defined.
When using activemq anything is fine and properties searched in receiver.
camel version is 2.8.1
can anybody explain, why expression parser behave in such way, or, if it
unexpexted behaviour create bug in bug tracker :)

Thanks, Alexander.

--
View this message in context: 
http://camel.465427.n5.nabble.com/using-vm-with-different-camelContexts-and-property-parser-tp5022731p5022731.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Dynamic Consumers

[Willem Jiang]

You can take a look at recipient-list which can take the message header 
as a parameter to build up the endpoint uri.


[1]http://camel.apache.org/recipient-list.html

On Thu Nov 24 23:10:10 2011, suman wrote:

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"))
 .setHeader(CacheConstants.CACHE_OPERATION,
constant(CacheConstants.CACHE_OPERATION_ADD))
 .setHeader(CacheConstants.CACHE_KEY, header("eventid"))
 .to("cache://MyCache");

My problem is inside toF DSL ,header("eventid") is getting evaluated when
the route is started and hence its not finding anything.Instead i want it to
get evaluated when the message arrives.Sorry if my question is silly as iam
quite new to camel.Any help would be appreciated

Thanks



--
View this message in context: 
http://camel.465427.n5.nabble.com/Dynamic-Consumers-tp5020405p5020405.html
Sent from the Camel - Users mailing list archive at Nabble.com.





--
Willem
--
FuseSource
Web: http://www.fusesource.com
Blog:http://willemjiang.blogspot.com (English)
 http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang

--
Willem
--
FuseSource
Web: http://www.fusesource.com
Blog:http://willemjiang.blogspot.com (English)
 http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang

Re: connecting to new jms implementation

[Christian Schneider]

Hi,

I have not reviewed the whole code but at least one thing is wrong.
To use your component you should do:



my is the id of your component. Camel finds it by looking for a spring 
bean with that id.
Of course you could also use the camel bean component but then you would 
not write a component.


Christian

Am 25.11.2011 11:04, schrieb saiya-jin:








   











--

Christian Schneider
http://www.liquid-reality.de

Open Source Architect
Talend Application Integration Division http://www.talend.com

Re: connecting to new jms implementation

[saiya-jin]

Hello,
I tried to create as simple component as possible that represents the case I
need to implement (I am using provided ActiveMQ broker to post messages that
are consumed by my Component). 
When I try to launch simple test that sends 1 message to broker via
ProducerTemplate, but whole setup is behaving strangely and does not get
message where it should. Here is my code:

Spring XML:






















  









And for component:

public class MyComponent extends DefaultComponent {
private static final Logger LOG =
LoggerFactory.getLogger(MyComponent.class);
private String host;
private String port;
private String instanceId;
private String password;
private String username;

@Override
public Endpoint createEndpoint(String uri) throws Exception {
LOG.info("Creating new My endopint...");
return this.createEndpoint(uri, null, new HashMap());
}

@Override
protected Endpoint createEndpoint(String uri, String remaining, 
Map parameters) throws Exception {
LOG.info("Creating new My endopint...");

host = getAndRemoveParameter(parameters, "host", String.class);
port = getAndRemoveParameter(parameters, "port", String.class);
instanceId = getAndRemoveParameter(parameters, "instanceId",
String.class);
password = getAndRemoveParameter(parameters, "password", 
String.class);
username = getAndRemoveParameter(parameters, "username", 
String.class);

ConnectionFactory cf = new AMIQueueConnectionFactory(host, port,
instanceId);
UserCredentialsConnectionFactoryAdapter ucfa = new
UserCredentialsConnectionFactoryAdapter();
ucfa.setTargetConnectionFactory(cf);
ucfa.setUsername(username);
ucfa.setPassword(password);

MyJmsQueueEndpoint endpoint = new MyJmsQueueEndpoint(uri, this, 
ucfa,
instanceId);

return endpoint;
}

My endpoint looks like this:

public class MyJmsQueueEndpoint extends DefaultEndpoint {
private static final Logger LOG =
LoggerFactory.getLogger(MyJmsQueueEndpoint.class);
private QueueConnection connection;
private ConnectionFactory cf;
private String instanceId;

public MyJmsQueueEndpoint(String uri, MyComponent component,
ConnectionFactory cf, String instanceId) {
super(uri, component);
this.cf = cf;
this.instanceId = instanceId;
}

@Override
public boolean isSingleton() {
return true;
}

@Override
public MyConsumer createConsumer(Processor processor) throws Exception {
return new MyConsumer(this, processor);
}


@Override
public MyProducer createProducer() throws Exception {
return new MyProducer(this);
}

@Override
protected void doStart() throws Exception {
LOG.info("Starting endpoint...");
Connection c = createConnection();
LOG.info("Connection to My JMS verified");
c.close();
   }

@Override
protected void doStop() throws Exception {
LOG.info("Stopping endpoint...");
if (connection != null) {
connection.close();
}
   }

public QueueConnection createConnection() throws Exception {
if (connection == null) {
this.connection = ((UserCredentialsConnectionFactoryAdapter)
cf).createQueueConnection();;
}
return connection;  
}

public String getInstanceId() {
return instanceId;
}


and my producer look like this:

public class MyProducer extends DefaultProducer {

private static final Logger LOG =
LoggerFactory.getLogger(MyProducer.class);

public MyProducer(MyJmsQueueEndpoint endpoint) {
super(endpoint);
}

@Override
public void process(Exchange exchange) throws Exception {
LOG.info("process() method in MyProducer class invoked...");

QueueConnection connection =
((MyJmsQueueEndpoint)getEndpoint()).createConnection();

AMIQueueSession session = (AMIQueueSession)
connection.createQueueSession(true,0);
AMIQueue destination = new
AMIQueue(((MyJmsQueueEndpoint)getEndpoint()).getInstanceId() + "/" +
"QUEUE.IN");
AMIQueueSender queueSender = (AMIQueueSender)
session.createSender(destination);
AMITextMessage message = (AMITextMessage)
session.createTextMessag

Re: Testing an http component

[Willem Jiang]

Thanks for sharing it with us.
If you are using camel-http4 component, you don't  need to start a real 
Jetty server for it.
You can find more information about it by checking out the unites of 
the camel-http4[1].


[1]https://svn.apache.org/repos/asf/camel/trunk/components/camel-http4/src/test

On Fri Nov 25 15:46:23 2011, Xenofon Papadopoulos wrote:

In Camel 2.7 I need to make an HTTP request to a remote web server from
inside a bean. The route looks like:







java.lang.Exception
true
1
...




billingBean is a Spring bean that is injected with a ProducerTemplate and
after some processing it makes the request, parses the response and
continues with the exchange.
I need to write an automated test for this, so I created a simulator for
the server and a tried the following route:

public class BillingServiceTest extends CamelSpringTestSupport {


@Override
public void setUp() throws Exception {
super.setUp();
erviceTestUri = context.resolvePropertyPlaceholders( "{{mcss.uri}}" );
final String jettyEndpoint = "jetty:" + mcssServiceTestUri;
logger.info( "Setting up jetty endpoint at: " + jettyEndpoint );
context.addRoutes( new RouteBuilder() {
@Override
public void configure() throws Exception {
from( jettyEndpoint )
.beanRef( "billingServiceSimulator", "processRequest" );
}
} );
}





--
Willem
--
FuseSource
Web: http://www.fusesource.com
Blog:http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang 
Weibo: willemjiang 

Re: HTTP Basic authenticaiton on CxfEndpoint

[Willem Jiang]

Are you using the same cxfEndpoint ?
If so, You can set the AuthorizationPolicy by using the conduit[1].
If not, I'm afraid you have to use other camel component to do the job.

[1]http://cxf.apache.org/docs/client-http-transport-including-ssl-support.html#ClientHTTPTransport%28includingSSLsupport%29-The%7B%7Bconduit%7D%7Delement

On Fri Nov 25 11:57:09 2011, awillia wrote:

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 = from(RECEIVING_QUEUE_PREFIX + app.getName()); // Pull
from each application's queue

def.routeId(getRouteName(app)).transacted()
.process(new WebServiceProcessor())
 .to(cxfEndpoint);

The routes are dynamically created based on data, so I can not set up the
routes in the spring config. Is there any way I can set it to use HTTP basic
authentication and define the user name and password in the code that I have
posted above.

I can do this as parameters on the end point when using the HTTP end point,
but don't see anything for CXF.

thanks
Antony

I am using camel 2.8

--
View this message in context: 
http://camel.465427.n5.nabble.com/HTTP-Basic-authenticaiton-on-CxfEndpoint-tp5021812p5021812.html
Sent from the Camel - Users mailing list archive at Nabble.com.





--
Willem
--
FuseSource
Web: http://www.fusesource.com
Blog:http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang 
Weibo: willemjiang 

Re: Get activemq message

[davsclaus]

You can use pollEnrich instead of the processor in the Camel DSL.
http://camel.apache.org/content-enricher.html

And the problem you have is that you create a new consumer template for
*each* message. Do not do this. But create the template once. Read this FAQ
http://camel.apache.org/why-does-camel-use-too-many-threads-with-producertemplate.html


-
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
--
View this message in context: 
http://camel.465427.n5.nabble.com/Get-activemq-message-tp5020469p5022405.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Thread pool for components in Camel

[Claus Ibsen]

On Fri, Nov 25, 2011 at 10:40 AM, diwakar  wrote:
> Hi,
>
>                In Servicemix/JBI thread pools by are there by default (at
> component level).
>                Why isn't the same approach taken for Camel? In Camel thread
> (/async) has to be configured explicitly in the route.
>                Please let me know your comment.
>

SMX != Camel.

SMX is an ESB and thus its a server and therefore SMX can expose
container level configuration etc.

Camel is a framework which is deployed/embedded into any kind of
runtime. Could indeed by SMX as well. But can run standalone,
WebSphere, Tomcat etc.

Check out this page about Camel thread configuration
http://camel.apache.org/threading-model.html

You can configure thread pool profiles on a per CamelContext level.


> With Best Regards,
> Diwakar
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Thread-pool-for-components-in-Camel-tp4722190p5022361.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

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

[Joshua Watkins]

I was able to limit the number of threads by setting the consumerType to
simple and the taskExecutor to a spring ThreadPoolTaskExecutor
bean that I created. I didn't use the ThreadPoolProfile class.

I hope this helps.

On 24/11/2011 22:19, "Jason Dillon"  wrote:

>rType(ConsumerType.Simple);
>ActiveMQComponent jms = new ActiveMQComponent(jmsConfig);
>

Re: Thread pool for components in Camel

[diwakar]

Hi, 

In Servicemix/JBI thread pools by are there by default (at
component level).
Why isn't the same approach taken for Camel? In Camel thread
(/async) has to be configured explicitly in the route.
Please let me know your comment.

With Best Regards,
Diwakar

--
View this message in context: 
http://camel.465427.n5.nabble.com/Thread-pool-for-components-in-Camel-tp4722190p5022361.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Component for SSH CLI

[diwakar]

Hi, 

>> As it can scan directories for files, and download the
file
We will try this. But this was just one example of SSH
usage.

With Best Regards,
Diwakar


--
View this message in context: 
http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5022330.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Error handling: Camel (or EIP) vs Pojo

[Alistair Young]

> Isn't it difficult to do proper error handling with the EIP
> based approach? 
I wouldn't think so. In fact it's probably easier than writing lots of specific 
error handling code. I'm using Invalid Message Channel (IMS) to handle some 
errors. Anything that fails goes in the IMC via a route that uses various camel 
processors to notify/log/persist etc. So the message handler that throws the 
error doesn't need to do anything other than throw the error - by sending the 
message to an error topic. It's routed from there to the IMC after a certain 
number of retries:

http://codebrane.com/blog/wp-content/uploads/2011/11/2025-082741.jpg

Alistair

--
mov eax,1
mov ebx,0
int 80

On 25 Nov 2011, at 08:34, diwakar wrote:

> Hi, 
> 
> Very basic doubt.
> Isn't it difficult to do proper error handling with the EIP
> based approach? 
> It is much simpler with Pojo interfaces. 
> Could Camel have been a bunch of libraries? (Except for asynch
> support). With pure Java for controling the flow.
> Please let me know your comment.
> 
> With Best Regards,
> Diwakar
> 
> 
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Error-handling-Camel-or-EIP-vs-Pojo-tp5022204p5022204.html
> Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How do i use a JMS Consumer in Camel DSL?

[Freeman Fang]

Hi,

My comment inline
On 2011-11-24, at 下午11:05, Ashish wrote:


Hi,
I am new to servicemix. trying to write a simple example in which a  
file
contents are copied from a directory to a jms queue which in turn  
transfers

it to another directory. The xml file is as follows:-


http://www.springframework.org/schema/beans";
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xmlns:osgi="http://www.springframework.org/schema/osgi";
  xmlns:file="http://servicemix.apache.org/file/1.0";
  xmlns:jms="http://servicemix.apache.org/jms/1.0";
  xmlns:ifm="http://www.fico.com";
  xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/osgi
http://www.springframework.org/schema/osgi/spring-osgi.xsd
  http://servicemix.apache.org/file/1.0
http://servicemix.apache.org/file/1.0/servicemix-file.xsd
  http://servicemix.apache.org/jms/1.0
http://servicemix.apache.org/jms/1.0/servicemix-file.xsd";>


At least this is incorrect
it should be
http://servicemix.apache.org/jms/1.0/servicemix-jms.xsd
but not
http://servicemix.apache.org/jms/1.0/servicemix-file.xsd


Btw, you should post this question to Servicemix user mailling list,  
as this is a Servicemix specific question.


Freeman


   


   class 
= 
"org 
.springframework.beans.factory.config.PropertyPlaceholderConfigurer"

/>

   
  Bundle-Version = 1.0.0
  Bundle-Name = Data Handler Service Application
  Bundle-SymbolicName = org.apache.servicemix.examples.filemover
  Bundle-Description = An example which reads a file from an input
folder and writes it to an output folder
  Bundle-Vendor = lh...@apache.org
  Require-Bundle = servicemix-file
   


 


   class 
="org.apache.servicemix.components.util.SimpleFlatFileMarshaler" />



 


 

   
   class 
="org.apache.servicemix.components.util.SimpleFlatFileMarshaler" />



 

 

 




 
   



***

While deploying this I am getting this error in log - "The matching  
wildcard
is strict, but no declaration can be found for element  
'jms:consumer'". any

help on how to solve this will be highly appreciated.

Thanks in advance,
aashish

--
View this message in context: 
http://camel.465427.n5.nabble.com/How-do-i-use-a-JMS-Consumer-in-Camel-DSL-tp475447p5020399.html
Sent from the Camel - Users mailing list archive at Nabble.com.


-
Freeman Fang

FuseSource
Email:ff...@fusesource.com
Web: fusesource.com
Twitter: freemanfang
Blog: http://freemanfang.blogspot.com

RE: Selective Multicast

[Narita Bagchi]

This worked for me -

from("file://d://log//camel").convertBodyTo(String.class)
  .multicast().to("seda:a", "seda:b");
from("seda:a")
  .process(new MutlicastRecoveryProcessor("output1"))
  .choice()
  .when(header("foo").isEqualTo("one"))
  .to("log:org.apache.camel.DeadLetterChannel?level=error")
  .otherwise().to("file://c://log//camel//output1");
from("seda:b")
  .process(new MutlicastRecoveryProcessor("output2"))
  .choice()
  .when(header("foo").isEqualTo("one"))
  .to("log:org.apache.camel.DeadLetterChannel?level=error")
  .otherwise().to("file://d://log//camel//output2");


Regards,
~Narita

From: Narita Bagchi
Sent: Thursday, November 24, 2011 3:31 PM
To: users@camel.apache.org
Subject: 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")
  .multicast()
  .to("seda:a")
  .choice()
 .when(header("foo").isEqualTo("one"))
 .to("log:org.apache.camel.DeadLetterChannel?level=error")
 .otherwise()
 .to("file://d://log//camel//output1")
   .to("seda:b")
.choice()
.when(header("foo").isEqualTo("one"))
.to("log:org.apache.camel.DeadLetterChannel?level=error")
.otherwise()
.to("file://d://log//camel//output2");

Working snippet -2
from("file:inbox")
  .multicast()
.process(new MutlicastRecoveryProcessor (“output1”))

.to("file://d://log//camel//output1")
. process(new MutlicastRecoveryProcessor (“output2”))

.to("file://d://log//camel//output2");

class MutlicastRecoveryProcessor implements Processor {

private String endpointSeqID;
public MutlicastRecoveryProcessor(String endpointSeqID) {

  this.endpointSeqID = endpointSeqID;
}
@Override
public void process(Exchange exchange) throws Exception {

  if (“output1”.equals(this.endpointSeqID)) {
  exchange.getIn().setHeader(“foo”,”one”);
  }
}
}



Non Working snippet -1
from("file:inbox")
  .multicast()
.process(new MutlicastRecoveryProcessor (“output1”))
 .to("seda:a")
 .choice()
 .when(header("foo").isEqualTo("one"))
 .to("log:org.apache.camel.DeadLetterChannel?level=error")
 .otherwise()
 .to("file://d://log//camel//output1")
.process(new MutlicastRecoveryProcessor (“output2”))
.to("seda:b")
.choice()
.when(header("foo").isEqualTo("one"))
.to("log:org.apache.camel.DeadLetterChannel?level=error")
.otherwise()
.to("file://d://log//camel//output2");

class MutlicastRecoveryProcessor implements Processor {

private String endpointSeqID;
public MutlicastRecoveryProcessor(String endpointSeqID) {

  this.endpointSeqID = endpointSeqID;
}
@Override
public void process(Exchange exchange) throws Exception {

  if (“output1”.equals(this.endpointSeqID)) {
  exchange.getIn().setHeader(“foo”,”one”);
  }
}
}

Thanks.
Regards,
Narita


***The information transmitted is intended only for the person or entity to 
which it is addressed and may contain confidential and/or privileged material. 
Any review,retransmission,dissemination or other use of, or taking of any 
action in reliance upon, this information by persons or entities other than the 
intended recipient is prohibited. If you received this in error, please contact 
the sender and delete the material from any computer.***

***The information transmitted is intended only for the person or entity to 
which it is addressed and may contain confidential and/or privileged material. 
Any review,retransmission,dissemination or other use of, or taking of any 
action in reliance upon, this information by persons or entities other than the 
intended recipient is prohibited. If you received this in error, please contact 
the sender and delete the material from any computer.***

Re: Component for SSH CLI

[Claus Ibsen]

Hi

There is a SFTP component with Camel? Can you just use that? As it can
scan directories for files, and download the files.
http://camel.apache.org/ftp2

On Fri, Nov 25, 2011 at 9:38 AM, diwakar  wrote:
> Hi,
>
>                  We need to execute "ls" on one of the servers and then
> retrieve few files with SFTP. Exec is an option, but the process is about
> 1Gb in size and doing too many forks (with Runtim.exec())is not a good idea.
>
> With Best Regards,
> Diwakar
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5022216.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Error handling: Camel (or EIP) vs Pojo

[diwakar]

Hi, 

 Very basic doubt.
 Isn't it difficult to do proper error handling with the EIP
based approach? 
 It is much simpler with Pojo interfaces. 
 Could Camel have been a bunch of libraries? (Except for asynch
support). With pure Java for controling the flow.
 Please let me know your comment.

With Best Regards,
Diwakar


--
View this message in context: 
http://camel.465427.n5.nabble.com/Error-handling-Camel-or-EIP-vs-Pojo-tp5022204p5022204.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Single request with multiple replies over TCP

[jonv]

Hello all,

Im new to camel and currently doing an evaluation exercise!

What Im trying to achieve is to place camel in the middle of two apps.
The apps use XML over TCP to communicate over one connection. The message
pattern is kinda pub/sub or single request with multiple replies.

The msgs flows are

 REG>   REG--->
CLIENT   <--ACK--   CAMEL   <--ACK-   SERVER
<--MSG1<--MSG1---
<--MSG2<--MSG2---
  <--etc-

Ive implemented an XML codec which I belive works ok. However using the
following...

http://camel.apache.org/schema/spring"; trace="false">
  


  


 only allows the ACK to be received by the client (no msgs). The
additional msgs are received by the 'encoder' of the  codec but not
passed on. Im assuming that the session correlates one response for each
request.

How can camel be used for this pattern? 

Any help will be appreciated.

Cheers

Jon.

--
View this message in context: 
http://camel.465427.n5.nabble.com/Single-request-with-multiple-replies-over-TCP-tp5022206p5022206.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Component for SSH CLI

[diwakar]

Hi, 

  We need to execute "ls" on one of the servers and then
retrieve few files with SFTP. Exec is an option, but the process is about
1Gb in size and doing too many forks (with Runtim.exec())is not a good idea.

With Best Regards,
Diwakar


--
View this message in context: 
http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5022216.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Component for SSH CLI

[diwakar]

Hi, 

  Thanks for the reply.

With Best Regards,
Diwakar


--
View this message in context: 
http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5022074.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Component for SSH CLI

[Guillaume Nodet]

Yes, Mina SSHD could be used if needed, but could you elaborate a bit
more, I'm not really sure to understand what you have in mind.
You want a camel component that would connect through SSH and execute
commands remotely ?
Maybe that could be a camel-exec enhancement somehow.

On Fri, Nov 25, 2011 at 09:20, Claus Ibsen  wrote:
> Apache Mina project has a SSH sub project. Its used by Apache Karaf I think.
>
>
> On Thu, Nov 24, 2011 at 11:15 AM, 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: 
>> http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5019772.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>
>
>
> --
> Claus Ibsen
> -
> FuseSource
> Email: cib...@fusesource.com
> Web: http://fusesource.com
> Twitter: davsclaus, fusenews
> Blog: http://davsclaus.blogspot.com/
> Author of Camel in Action: http://www.manning.com/ibsen/
>



-- 

Guillaume Nodet

Blog: http://gnodet.blogspot.com/

Open Source SOA
http://fusesource.com

Re: Dynamic Consumers

[Claus Ibsen]

Hi

See this FAQ
http://camel.apache.org/how-do-i-use-dynamic-uri-in-to.html

On Thu, Nov 24, 2011 at 4:10 PM, suman  wrote:
> 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"))
>                .setHeader(CacheConstants.CACHE_OPERATION,
> constant(CacheConstants.CACHE_OPERATION_ADD))
>                .setHeader(CacheConstants.CACHE_KEY, header("eventid"))
>                .to("cache://MyCache");
>
> My problem is inside toF DSL ,header("eventid") is getting evaluated when
> the route is started and hence its not finding anything.Instead i want it to
> get evaluated when the message arrives.Sorry if my question is silly as iam
> quite new to camel.Any help would be appreciated
>
> Thanks
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Dynamic-Consumers-tp5020405p5020405.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Re: How do i use a JMS Consumer in Camel DSL?

[Ashish]

Hi,
I am new to servicemix. trying to write a simple example in which a file
contents are copied from a directory to a jms queue which in turn transfers
it to another directory. The xml file is as follows:-


http://www.springframework.org/schema/beans";  

   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
   xmlns:osgi="http://www.springframework.org/schema/osgi";   
   xmlns:file="http://servicemix.apache.org/file/1.0";
   xmlns:jms="http://servicemix.apache.org/jms/1.0";
   xmlns:ifm="http://www.fico.com";
   xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
 
   http://www.springframework.org/schema/osgi
http://www.springframework.org/schema/osgi/spring-osgi.xsd
   http://servicemix.apache.org/file/1.0
http://servicemix.apache.org/file/1.0/servicemix-file.xsd
   http://servicemix.apache.org/jms/1.0
http://servicemix.apache.org/jms/1.0/servicemix-file.xsd";>








   Bundle-Version = 1.0.0
   Bundle-Name = Data Handler Service Application
   Bundle-SymbolicName = org.apache.servicemix.examples.filemover
   Bundle-Description = An example which reads a file from an input
folder and writes it to an output folder
   Bundle-Vendor = lh...@apache.org
   Require-Bundle = servicemix-file


  
  

 

 

  

  
  



 

  
  
  
  
  
  
  


  
 
  


***

While deploying this I am getting this error in log - "The matching wildcard
is strict, but no declaration can be found for element 'jms:consumer'". any
help on how to solve this will be highly appreciated.

Thanks in advance,
aashish

--
View this message in context: 
http://camel.465427.n5.nabble.com/How-do-i-use-a-JMS-Consumer-in-Camel-DSL-tp475447p5020399.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Component for SSH CLI

[Claus Ibsen]

Apache Mina project has a SSH sub project. Its used by Apache Karaf I think.


On Thu, Nov 24, 2011 at 11:15 AM, 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: 
> http://camel.465427.n5.nabble.com/Component-for-SSH-CLI-tp5019772p5019772.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



-- 
Claus Ibsen
-
FuseSource
Email: cib...@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/