What exactly are you trying to achieve? You just want to try to talk
to OSGi services? Can't you just do that with s and
beanRef?
On Tue, May 22, 2012 at 1:57 PM, wrote:
> Hi gurus,
>
> Recently I've published camel component that uses OSGi services to
> communicate between endpoints in di
/Hi
I am doing load testing of a camel route. The route has a netty endpoint
which sends data over tcp. I am getting the following errors:/
18:50:44,771 | WARN | nt worker #109-7 | DefaultChannelPipeline |
- - | An exception was thrown by a user handler while handling an
exception e
When you post stacktraces its important to also say which versions of
the projects you us.
Otherwise the line numbers may not match up.
On Tue, May 22, 2012 at 6:00 PM, Eugeniu wrote:
> /Hi
>
> I am doing load testing of a camel route. The route has a netty endpoint
> which sends data over tcp.
I would like to listen to a list of jms queues and for each queue do the
same route.
Currently I use a RouteBuilder that gets the jms endpoint uri in its
constructor and builds the route. This routebuilder is then created once
for each jms endpoint and the
route is added each time to the conte
hi
I have used the @ManagedResource and @ManagedAttribute on a Bean that get's
used in a route.
The bean and new attribute works just fine and is visible using the jmx
console under processors, but the default processor attributes and
operations turns up as 'Unavailable' with a ReflectionExceptio
I didn't understand the problem. May you check out the camel-smpp unit
tests and see how you should use this component.
Best,
Christian
Sent from a mobile device
Am 22.05.2012 09:19 schrieb "Airwish" :
> Hello Everyone,
>
> I'm trying to integrate the Smpp-Component in my Application which has t
Couldn't you just create a seda queue once (that is your logic route),
and then for each jms queue that gets added you redirect it to that seda
queue ?
On 05/23/2012 01:03 PM, Christian Schneider wrote:
I would like to listen to a list of jms queues and for each queue do
the same route.
Curr
The code which shows your route would be also helpful...
Best,
Christian
Sent from a mobile device
Am 23.05.2012 09:56 schrieb "Eugeniu" :
> /Hi
>
> I am doing load testing of a camel route. The route has a netty endpoint
> which sends data over tcp. I am getting the following errors:/
>
> 18:50
The problem is that the from endpoints are not known at compile time and
can change at any time.
Besides that we need transactionality. Not sure if seda provides that.
Christian
Am 23.05.2012 13:41, schrieb Serkan Eryilmaz:
Couldn't you just create a seda queue once (that is your logic route),
Hi Christian,
Can you not do the following. I believe this is legal...
from("activemq:queue:foo).
from("activemq:queue:bar").
process(sinkProcessor);
I have not tried this with Activemq/JMS endpoints, however, I know that the
DSL is legal and should work...
Cheers,
A
Oops,
Just noticed that you are looking to inject endpoints at runtime and not
statically inject them...
You are right. A multi-destination consumer is not supported at the moment
by the JMS component.
Interesting thought, though... It is certainly do-able in the JMS component.
I wonder whether
You can use the setExchangePattern before the recipient list to alter it.
But yeah maybe we should consider having to override it like you can do on
Mind that this override is "local" only, and the MEP is not changed on
the original exchange, being routed afterwards.
On Wed, May 23, 2012 at 1:5
Hi
Yes this just complicates matters.
If you use ActiveMQ, then it supports wildcard destinations. Use that
instead, then you can consume from multiple queues, in a single Camel
route.
On Wed, May 23, 2012 at 2:26 PM, Ashwin Karpe wrote:
> Oops,
>
> Just noticed that you are looking to inject
Hi,
As Claus and Christian suggested, the route (scrubbed of course) as well as
camel version information would help.
Based on a superficial inspection of the error, it seems like the capacity
of the java.util.concurrent.ArrayBlockingQueue is being exceeded. This seems
to suggest that exchanges b
I have just done a prototype for a component that allows to do the
following:
from("dynamicep:file:/test,jetty:http://localhost:9000";).to("log:test");
The core of it is:
https://gist.github.com/2775140
So you can use a list of arbitrary endpoints. This has the advantage
that it works for any
Hi,
Another simpler way is to use an archetype to do all of the hard work for
you and have you focus on writing the route.
Many moons ago, I had developed a maven archetype that is part of the
Servicemix codebase called servicemix-osgi-camel-archetype. Is should be
under the group id org.apache.s
Use
from("activemq:queue:foo")
.from("activemq:queue:bar")
.from("activemq:queue:baz")
.to("mock:result");
Christian, this test works:
public class SimpleRouteTest extends CamelTestSupport {
@EndpointInject(uri = "mock:resul
Hi
There is Camel maven archetypes to setup new Camel projects for OSGi. We got for
- spring-dm
- blueprint
http://camel.apache.org/camel-maven-archetypes.html
On Wed, May 23, 2012 at 3:11 PM, Ashwin Karpe wrote:
> Hi,
>
> Another simpler way is to use an archetype to do all of the hard work
Are you in need of a topic rather than a queue?
On Wed, May 23, 2012 at 8:13 AM, Christian Schneider
wrote:
> The problem is that the from endpoints are not known at compile time and can
> change at any time.
> Besides that we need transactionality. Not sure if seda provides that.
> Christian
>
>
Hi,
you can take a look at my tutortial. It is much more curren than the one
on the camel site:
http://www.liquid-reality.de/x/G4Bk
I did not use the archetypes but they are also a good starting point. So
you can either copy and change my example or create your project from
one of the archet
This does not work in my case as the number of queues to listen on is
not fixed and can change at runtime.
Christian
Am 23.05.2012 15:25, schrieb Christian Müller:
Use
from("activemq:queue:foo")
.from("activemq:queue:bar")
.from("activemq:que
Topics would not help in my case.
The use case here is to have kind of a generic engine that can route
between queues with config from a db or file.
Christian
Am 23.05.2012 15:10, schrieb James Carman:
Are you in need of a topic rather than a queue?
On Wed, May 23, 2012 at 8:13 AM, Christi
Yeah, sorry, didn't understand what you were trying to do. Perhaps you can
programmatically stop/restart your camel context at runtime based on some
sort of event (database changes?). Then, your route builder would read the
information from the database to dynamically configure your routes?
On M
Yes .. that is what I intended to do. As the deployment is in OSGi I
plan to use the config admin service integration in blueprint.
So the bundle restarts automatically on config changes. If the config
has to be in DB then I think it is good enough if the admin restarts the
bundle by hand when
Yeah, it might be better to just have manual restarts, since they may
be in the middle of some db changes and the routes would be restarting
themselves multiple times (perhaps with half-baked config). Sounds
like you've got it under control. Please report back to let us know
how things went and s
Hi
For Camel 2.x the documentation is at:
http://camel.apache.org/ftp2.html
and not:
http://camel.apache.org/ftp.html
And for the purpose you mentioned, using the filtering support should easily
do the trick:
http://camel.apache.org/ftp2.html#FTP2-Filterusing%7B%7Borg.apache.camel.component.f
There are some, myself included, who, for whatever reason, don't use
Spring or Karaf.
Don
On Tue, May 22, 2012 at 3:19 PM, James Carman
wrote:
> What exactly are you trying to achieve? You just want to try to talk
> to OSGi services? Can't you just do that with s and
> beanRef?
>
> On Tue, May
Exactly, that would be the intention!
Here goes the ticket: https://issues.apache.org/jira/browse/CAMEL-5301.
Thanks, Claus.
On 23 May 2012 13:46, Claus Ibsen wrote:
> You can use the setExchangePattern before the recipient list to alter it.
>
> But yeah maybe we should consider having to overr
Hi,
I am coping with a case which is the following :
I have a cache.
In this cache, i can have multiple entries.
The keys of these keys are not known a priori.
When a new entries arrives i should poll this entry periodically a do a job
(even if the value has not changed).
When an entry is removed
Do you use Blueprint?
On Wed, May 23, 2012 at 11:24 AM, Donald Whytock wrote:
> There are some, myself included, who, for whatever reason, don't use
> Spring or Karaf.
>
> Don
>
> On Tue, May 22, 2012 at 3:19 PM, James Carman
> wrote:
>> What exactly are you trying to achieve? You just want to
Hi James,
s are perfect if you have a single processor, if you have more than
one processor that may come and go you
will have to write custom code to publish to all of these processors.
The main goal I was trying to achieve is to send an exchange to multiple osgi
endpoints and to load balance
Christian,
OSGi services can be used without even restarting the container or camel
contexts.
As by spec. invocation of OSGi service happens synchronously in the same
thread, so there are
no problems with transactions.
You only have to publish you consumer side into the OSGi registry somehow
(
Here is the link to the component: https://github.com/szhem/camel-osgi
> Christian,
> OSGi services can be used without even restarting the container or camel
> contexts.
> As by spec. invocation of OSGi service happens synchronously in the same
> thread, so there are
> no problems with transac
Hi
I added an unit test. But I could not reproduce it on trunk or the 2.9 branch
http://svn.apache.org/viewvc?rev=1341957&view=rev
On Fri, May 11, 2012 at 8:42 AM, arda.aydin wrote:
> Hi Claus,
>
> You're right, sorry for the absence of version number (just an oversight).
> First i was using 2.6
Hi Sergey,
Although not knowing much about the OSGi stuff, I did take a look at the
component you've provided on github which did really *impress* me as it is
clean, well structured, good documented and tested.
Keep up the good job!
Babak
--
View this message in context:
http://camel.465427.n
Hi
No the use original message, should mean the input message, which
would be A in your case.
I cannot reproduce the issue
http://svn.apache.org/viewvc?rev=1341970&view=rev
Since you run windows, then make sure the files and directories is
deleted/empty before running a test etc.
On Mon, Apr
Thanks for the hint. That could be an interesting option to split up the
route while keeping the transaction.
I know we already have the vm component which should work similar. Do
you know what the differences are from a user point of view?
Christian
Am 23.05.2012 18:50, schrieb szh.s...@gm
Hi
Thanks. I have reproduced the issue and logged a JIRA
https://issues.apache.org/jira/browse/CAMEL-5303
On Mon, May 21, 2012 at 7:38 AM, Michael Süess
wrote:
> Hi
>
>
> Camel 2.8.4
>
> Stacktrace:
>
> Starting Camel. Use ctrl + c to terminate the JVM.
>
> [ main] MainS
If vm/seda component have multipleConsumers enabled, it creates a
thread pool to preconfigure MultiCastProcessor, and this processor has
parallelProcessing enabled and stopOnException disabled by default. So
if consuming endpoint fails to process exchange you will not know
about it in
Thanks Babak,
I am trying to activate a process chain only if certain file in on the
remote sftp. Probably you or another reader can help with some errors I am
getting.
If I use wrong credentials Camel tries to reconnect several times not
obeying to maximumReconnectAttempts=0:
.from("sftp://sam
I am receiving data message from client and the body of the message is
a zip file containing multiple files. What is the best method to
process the zip data? I assume that I should use a StreamMessage. Is
there support for Camel to unzip the body as I receive it like
marshaling or do I need to w
szh.subs
I think so, that the example with two OSGi services will not work.
The object will return OsgiDefaultLoadBalancer always only one of the
services. In turn, OsgiDefaultLoadBalancer working through proxy
OsgiInvocationHandler. If you stop the OSGi bundle with the selected service
balancer d
What about using a DelegateProcessor, into which you can insert a
MulticastProcessor at runtime? If the collection of consumers
changes, you create a new MulticastProcessor with the revised
collection and use DelegateProcessor.setProcessor().
Don
Hello Aleksey,
Take a look at the following test
https://github.com/szhem/camel-osgi/blob/master/src/test/java/org/apache/camel/osgi/service/integration/OsgiDefaultEndpointTest.java.
testInstallUninstallBundle tests new bundle
installation/uninstallation and I've alre
Nestor, please have a look at
https://issues.apache.org/jira/browse/CAMEL-4075
As long as Spring doesn't support Quartz 2.x, we also want to stick with
Quartz 1.x.
Best,
Christian
On Sun, May 20, 2012 at 9:00 PM, Nestor Urquiza wrote:
> Yes they are incompatible as there are several changes in 2
Hi,
normally spring 3.1 supports quartz 2
- Romain
2012/5/23 Christian Müller
> Nestor, please have a look at
> https://issues.apache.org/jira/browse/CAMEL-4075
> As long as Spring doesn't support Quartz 2.x, we also want to stick with
> Quartz 1.x.
>
> Best,
> Christian
>
> On Sun, May 20, 2
For an upcoming series of two articles in a German magazin, I wrote a
sample application which use the CXFRS component to call a JAX-RS service.
For the unit tests, I start a JAX-RS server to export a resource. It's
available at [1] and may also useful for you.
[1] https://github.com/muellerc/came
I ended up using quartz 1 but not from Camel anyway as posted here
http://camel.465427.n5.nabble.com/Configure-Camel-to-consume-externally-configured-quartz-jobs-td5712732.html
I use persistence and the quartz api to schedule jobs that call Camel routes
but I opted not to use the camel-quartz comp
We break up our integration solution into logical parts which we deploy
separately (in it's own OSGI bundle).
Another reason could be scalability. If you break up your integration
solution into individual services and the load grows, you could start more
OSGI container running (only) this service.
I have an existing REST web service that sends an alert based upon the
provided "recipient" and "msgtext" (given in the GET url).
In camel, I have a route that takes the recipient name and msg from the
"sendTo" and "msg" headers and sends a request to the web service. This has
been working fine.
On Wed, May 23, 2012 at 11:48 PM, Romain Manni-Bucau
wrote:
> Hi,
>
> normally spring 3.1 supports quartz 2
>
Yeah but Spring 3.0 does not. And Camel have to support Spring 3.0 onwards.
> - Romain
>
>
> 2012/5/23 Christian Müller
>
>> Nestor, please have a look at
>> https://issues.apache.org/
On Tue, May 22, 2012 at 9:58 AM, cgiera wrote:
>
> Willem.Jiang wrote
>>
>> What's the problem ?
>> I don't think passing the bean object instance will introduce any
>> further issue into camel-jms and camel-jpa components.
>>
>
> Perhaps I don't understand you correctly, but if i pass the object
On Wed, May 23, 2012 at 10:43 PM, Tyler Durvik wrote:
> I am receiving data message from client and the body of the message is
> a zip file containing multiple files. What is the best method to
> process the zip data? I assume that I should use a StreamMessage. Is
> there support for Camel to u
On Wed, May 23, 2012 at 9:56 PM, Nestor Urquiza
wrote:
> Thanks Babak,
>
> I am trying to activate a process chain only if certain file in on the
> remote sftp. Probably you or another reader can help with some errors I am
> getting.
>
> If I use wrong credentials Camel tries to reconnect several
On Wed, May 23, 2012 at 2:47 AM, Nestor Urquiza
wrote:
> Hello riders,
>
> There are times when all you want is to check for the existence of a file,
> or the timestamp of it however that is not apparently available in the
> FTP/SFTP component as per http://camel.apache.org/ftp.html.
>
> Does it m
Maybe in Camel 2.11 we can upgrade to quartz 2.x.
Then if people use Spring and Quartz together, they may have to use Spring 3.1.
Any thoughts?
On Thu, May 24, 2012 at 5:32 AM, Claus Ibsen wrote:
> On Wed, May 23, 2012 at 11:48 PM, Romain Manni-Bucau
> wrote:
>> Hi,
>>
>> normally spring 3.1
56 matches
Mail list logo
