On 30/01/2014 23:06, "Joshua Watkins" wrote:
>
>I am looking for a bit of advice. I have been trying to get a better
>balance of consumer per connection but have run into a bit of a sticky
>situation.
>
>So while using the AMQ 5.8 and the AMQ PooledConnectionFa
I am looking for a bit of advice. I have been trying to get a better
balance of consumer per connection but have run into a bit of a sticky
situation.
So while using the AMQ 5.8 and the AMQ PooledConnectionFactory[1], I was
setting my camel routes with Cache_None to enable more connections from
t
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);
>Acti
) )
>
>I'd love to find a way to configure the underlying jetty component to do
>this magic for me but it doesn't appear to be accessible.
>
>On Thu, Aug 18, 2011 at 8:06 AM, Joshua Watkins <
>joshua.watk...@gamesys.co.uk> wrote:
>
>> I am using the camel je
I am using the camel jetty component to route to activemq to access other
backend services.
For instance:
from("jetty:http://0.0.0.0:8083/people";)
.setHeader(JMS_TYPE, constant("AddPeople"))
.to("activemq:proxy.out").routeId("addPeople");
I would also like to serve up some s
ons
>for you with spring. You usually only have the depends-on attribute.
>
>See for example the camel management example in the Apache
>distribution. It has an embedded AMQ + Camel in the same JVM.
>
>
>On Tue, Jun 14, 2011 at 12:48 PM, Joshua Watkins
> wrote:
>> I wa
I was using ActiveMQ 5.5 with Camel 2.7.0 and during a update of the route
lost some messages and found this error in the log
2011-06-13 13:25:42,950 | INFO | Starting to graceful shutdown 1 routes
(timeout 300 seconds) | org.apache.camel.impl.DefaultShutdownStrategy |
qtp788458698-45
2011-06-13
You are missing using the routeId. When you create your route you need to:
from(uri + "?splitEntries=false&consumer.initialDelay=0").
marshal().rss().
to("mock:result").routeId("routeId");
Then when you remove the route you use the same routeId string.
I hope this
A while ago there was a discussion topic that the
SimpleMessageListenerContainer/ConsumerType.Simple was removed from
camel-jms as it was deprecated. However from looking at the latest Spring
docs (
http://static.springsource.org/spring/docs/3.1.0.M1/javadoc-api/org/springf
ramework/jms/listener/S
Have you tried using the Jackson library instead of Xstream?
There is Jackson support in camel greater than 2.0
(http://camel.apache.org/json.html). I haven't used the Camel Jackson
component but if it works anything like the regular jackson libraries it
should be straight forward with no annotati
Hadrian,
I don't see that the SimpleMessageListenerContainer is deprecated in
3.0.5_RELEASE
(http://static.springsource.org/spring/docs/3.0.5.RELEASE/javadoc-api/org/s
pringframework/jms/listener/SimpleMessageListenerContainer.html).
The reason I bring this up is that when using the
DefaultMessa
That worked. Thanks!
On 07/04/2011 13:36, "Björn Bength" wrote:
>Hi,
>
>
> test dynamicDeliveryAddress
>
>
> dynamicdestinationName
>
>
>
>
>worked for me once. but i was using java dsl at the time.
>
>/björn
>
>
>
I am trying to use the CamelJmsDestinationName header to send to a topic.
However prepending topic: or activemq:topic: to my topic name simply sends
reroutes the message to a queue with the name
"activemq:topic:dynamicdestinationName".
Ex:
test dynamicDeliveryAddress
topic:d
.
-josh
On 31/03/2011 11:48, "Joshua Watkins" wrote:
>I have run into a bit of a pickle. I am trying to use camel and Activemq
>to resequence messages off of thousands of individual topics. A
>particular topic would have a sequence number in messages delivered to it
>for that
14 matches
Mail list logo
