OK, forgot to post that I found solution to my problem, it is based on some
of postings I've found but unfortunately I don't remember which one.
Still, I had to modify it to get it to work for me so here is how I did it,
in case someone else runs into the same problem:
(javax.net.ssl.SSLPeerUnverif
Greetings.
I had a similar issue with activemq and httpservlet, that, until now, stayed
unsolved, in the activemq forum. Now, its camel and jersey classes. This is
what its going on: this is my code:
http://pastie.org/2307602
I have already included the jersey jar in the eclipse project buildpat
Hi,
Can you check the timedroute route states ?
CronScheduledRoutePolicy start or resume the route when the route
status is ready.
ServiceStatus routeStatus =
route.getRouteContext().getCamelContext().getRouteStatus(route.getId());
if (action == Action.START) {
if (r
Martin, you use the ISO-8859-1 URL encoding, the String "Keine gültige
GPS-Daten!" is converted to "Keine+g%FCltige+GPS-Daten%21".
If you use UTF-8 URL encoding (which is what Jetty use by default), you will
get "Keine%20g%C3%BCltige%20GPS-Daten!". And this works well in Camel (I
added a unit test
Which version of Camel do you use?
Will have a look into TRUNK (2.9-SNAPSHOT)...
Best,
Christian
In Quartz the first parameter is seconds.
To execute every 5 min cron-style use this cron expression (works for me):
cron=0+0/5+*+*+*+?
Brgds, Magnus Palmér
2011/8/1 dattu.1729
> Hi,
>
> I am using camel->quartz component. My use case is "Have to merge all
> avaliable files for every 5 mins." I
Ah, that's the parameter i needed.
Thanks Jon!
On Mon, Aug 1, 2011 at 11:16 AM, Jon Anstey wrote:
> Maybe try setting maxMessagesPerTask to a positive value? Seems to imply
> that this is required here when the feature was introduced:
> https://jira.springsource.org/browse/SPR-2814 I haven't tr
Maybe try setting maxMessagesPerTask to a positive value? Seems to imply
that this is required here when the feature was introduced:
https://jira.springsource.org/browse/SPR-2814 I haven't tried this for
myself though :)
On Mon, Aug 1, 2011 at 3:19 PM, Tommy Chheng wrote:
> Thanks Jon,
> Upon re
Could it be useful to have an spring implementation which follow their
Resource abstraction?
2011/7/30 jmandawg
>
> It looks like you might be able to do something even simpler by calling
> resolveMandatoryResource from within the ModuleURIResolver. That way it
> will resolve the import in the s
Thanks Jon,
Upon reading the Spring documentation link, I'm a little confused about
dynamic scaling of consumers.
*There is another parameter IdleTaskExecutionLimit which states it
should close idle resources:*
The default is 1, closing idle resources early once a task didn't receive a
message. T
FYI idleConsumerLimit will be configurable in the next release of Camel
(2.9) see https://issues.apache.org/jira/browse/CAMEL-4290
On Mon, Aug 1, 2011 at 2:41 PM, Claus Ibsen wrote:
> Hi Tommy
>
> Fell free to create a JIRA ticket as I there may be new/missing
> options from DMLC that we have no
Hi Tommy
Fell free to create a JIRA ticket as I there may be new/missing
options from DMLC that we have not exposed in camel-jms yet.
http://static.springsource.org/spring/docs/3.0.x/javadoc-api/org/springframework/jms/listener/DefaultMessageListenerContainer.html
On Mon, Aug 1, 2011 at 6:52 PM
That looks like a new property in Spring 3... we should add that option to
camel-jms but for now you should be able to make your own custom
JmsConfiguration class (extending the Camel JmsConfiguration one) and
override configureMessageListenerContainer to set up your idleConsumerLimit
value. You ca
Looking at
http://bsnyderblog.blogspot.com/2010/05/tuning-jms-message-consumption-in.html,
it looks like the setting i need is idleConsumerLimit
"idleConsumerLimit property specifies the limit on the number of idle
consumers"
I think this means that after the message volume decreases, the consumer
Most likely this was just the most common configuration used. Setting the
auth required to false is possible though. To do this you'll need to set the
sslHandler property on the producer URI. For example:
...to("netty:tcp://localhost:12345?sslHandler=#myHandler");
You can see how the default SSL
Hi
You may want to try the simple trigger instead of cron based, to
indicate a 5 minute gap between tasks.
Or use the timer component instead?
http://camel.apache.org/timer
And use the fixedRate=true option.
On Mon, Aug 1, 2011 at 4:49 PM, dattu.1729 wrote:
> Hi,
>
> I am using camel->quartz co
On Mon, Aug 1, 2011 at 5:12 PM, Tommy Chheng wrote:
> I'm using camel 2.7.2 and connecting to an ActiveMQ queue with
> concurrentConsumers=2&maxConcurrentConsumers=20
>
> Should the current # of concurrent consumers dynamically adjust due to
> message volume from activemq?
>
> At the start, when t
I'm using camel 2.7.2 and connecting to an ActiveMQ queue with
concurrentConsumers=2&maxConcurrentConsumers=20
Should the current # of concurrent consumers dynamically adjust due to
message volume from activemq?
At the start, when there are 0 messages, the # of consumers is 2.
When I have a large
Hi,
I am using camel->quartz component. My use case is "Have to merge all
avaliable files for every 5 mins." In this example, I don't want to run
parallel thread.
final FileEndpoint enpoint = (FileEndpoint)endpoint("file:src/ip/ch1");
final RouteBuilder route = new Filecopy("mergeRoute",enpoint);
Hi
You should be able to use
marshal(jacksonDataFormat)
To use the data format you have configured.
On Mon, Aug 1, 2011 at 3:45 PM, nizhnegorskiy wrote:
> Hi,
>
> Can you tell me please, how do I use enum with Camel?
> F.e. I have something like this:
> public class Profile{
> public A
On Mon, Aug 1, 2011 at 3:21 PM, Gnanaguru S
wrote:
>
> Hi Thanks.
>
> By the way. i want to do the same between two different fuse runninf in same
> machin or between two machines. Like clusters. What is the solution in that
> way.
You can configure the activemq component to connect to a network
I cannot tell any thing is wrong from your configuration.
Can you double check the JBI endpoint uri[1] to make sure you servicemix
client can access the enpdoint?
BTW, you may need to go through the servicemix log to check if there
error message which is related to access the JBI endpoint.
W
Hi,
Can you tell me please, how do I use enum with Camel?
F.e. I have something like this:
public class Profile{
public ArrayList daypart_targets;
public enum Days {
MONDAY("monday"),
TUESDAY("tuesday");
private Days
Hi Thanks.
By the way. i want to do the same between two different fuse runninf in same
machin or between two machines. Like clusters. What is the solution in that
way.
Cheers
Guru
--
View this message in context:
http://camel.465427.n5.nabble.com/Remote-Write-and-Read-tp4654906p4655016.html
Hi
I'm trying to expose cxf service bean via cxf-camel transport. Basically
I want my bean to be accessible via JBI in Servicemix 4 - some other
services refer this service by jbi endpoints. Theses services are also
camel routers.
Unfortunatelly the whole setup fails, the cxf bean never rece
How do you stop the route ?
The myroute route will keep running until you stop the route from the
camel context.
On 8/1/11 6:10 PM, srimin wrote:
Hi
using FuseESB- apache-servicemix-4.4.0-fuse-00-43
'myroute' should be opened from 13.00 to 13:50, but i see the messages are
pumping in every
Hi
You need to setup your activemq component as documented here
http://camel.apache.org/activemq
Basically more or less just this
Where the brokerURL points to the remote ActiveMQ broker.
On Mon, Aug 1, 2011 at 2:31 PM, Gnanaguru S
wrote:
> Hi,
>
> In the following code i am wo
Hi,
In the following code i am working with the files in my local machine. If i
want to read or write from remote machine or from some other node in the
network. What should i do.
Eg: i want to write into the
inputqueue which is present with the ip 10.200.208.129
http://www.osgi.org/xmlns/blue
Hi,
Is there any specific reason to hard code the client authentication to true.
In SSLEngineFactory class i found below:
serverEngine.setNeedClientAuth(true);
I have a specific requirement to send message from a java client which i
need not to be authenticated.
Please suggest if it's possible.
An addition:
The resulting string is not "Keine g?ltige GPS-Daten!" but "Keine g?tige
GPS-Daten!". The „l“ is missing. I think the decoding has eaten it.
Von: Christian Mueller [via Camel]
[mailto:ml-node+4654840-686073351-230...@n5.nabble.com]
Gesendet: Montag, 1. August 2011 13:57
An: Heinema
Well, i also thought about this but i was not able to find a switch on the
jetty endpoint to configure the expected encoding.
Von: Christian Mueller [via Camel]
[mailto:ml-node+4654840-686073351-230...@n5.nabble.com]
Gesendet: Montag, 1. August 2011 13:57
An: Heinemann, Martin
Betreff: Re: Get r
I will have a look on it later. But may be the header is set with a
different encoding then you/Camel uses (UTF-8 vs. ISO-8859-1)?
Best,
Christian
Sent from a mobile device
Am 01.08.2011 11:43 schrieb "heinrichheine" :
> Hi there,
>
> i have a simple jetty:http endpoint in my route that receives
I think I have this worked out now. I found the PollingConsumerPollStrategy
interface so I created an EmptyPollStrategy class. I changed the begin()
method to simply return true. In the commit() method I checked the
numberPolled parameter and if it is 0 then I just stop the consumer. I left
the
Hi
using FuseESB- apache-servicemix-4.4.0-fuse-00-43
'myroute' should be opened from 13.00 to 13:50, but i see the messages are
pumping in every minute
as if there is no routePolicy applied.
myroute.xml looks like this
> class="org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy
Hi there,
i have a simple jetty:http endpoint in my route that receives a http-GET
call.
This call contains a parameter "message".
This parameter can include some german umlauts which are encoded in
URLEncoding.
Example:
url request looks like this:
http://1.2.3.4/?message=Keine+g%FCltige+GPS-Dat
35 matches
Mail list logo
