Is it better to use PooledConnectionFactory in Parallel Processing
Hi, Previously we are using ActiveMQConnectionFactory alone, and we observed that while starting the JBoss Server ActiveMQ is creating multiple threads and closing (ActiveMQ Task 1, ActiveMQ Task 2, ...), we thought it creating multiple connections/session are creating and closing. As a resolution, we want to use PooledConnectionFactory 1) We are using Camel Routes to prepare and send messages to destination, we invoke 7 routes and each route configured with parallel processing (Min value is 5 and max value is 25 threads), daily we process around 3 Lakh Messages (= 300.000) and All Routes are TRANSACTED. In Parallel Processing Is it better to use PooledConnectionFactory? For Each Message PooledConnectionFactory create one session (or) Session object will be shared by Multiple messages? -- View this message in context: http://camel.465427.n5.nabble.com/Is-it-better-to-use-PooledConnectionFactory-in-Parallel-Processing-tp5742350.html Sent from the Camel - Users mailing list archive at Nabble.com.
ConsumerTemplate is not fetching data in insertion Order
Hi,
I have some messages in the JMS Queue and if i fetch the message from Queue
by using
consumerTemplate.receiveBodyNoWait("jms:queue:destinationEndPoint",
String.class);
By i observed that consumerTemplate is not maintaining insertion order.
Please let me know how can i get insertion order by using consumerTemplate
--
View this message in context:
http://camel.465427.n5.nabble.com/ConsumerTemplate-is-not-fetching-data-in-insertion-Order-tp5744663.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: ConsumerTemplate is not fetching data in insertion Order
Hi Claus, We are using Camel 2.9.2 version. -- View this message in context: http://camel.465427.n5.nabble.com/ConsumerTemplate-is-not-fetching-data-in-insertion-Order-tp5744663p5744805.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: ConsumerTemplate is not fetching data in insertion Order
Hi Claus,Thanks for your reply.I want to add some more information.We are
having a route which is configured with parallel
Processing.from("jms:queue:jobQueue" + "?" + Constants.CONCURRENT_CONSUMERS
+ "=" +
(Constants.CONCURRENT_CONSUMERS) + "&"
+
Constants.MAX_CONCURRENT_CONSUMERS + "="
+
(Constants.MAX_CONCURRENT_CONSUMERS) + "&"
+
Constants.MAX_MESSAGES_PERTASK + "="
+
(Constants.MAX_MESSAGES_PERTASK)) .transacted() .process(new
JobProcessor())
.split((body())).to("jms:queue:destinationQueue");Where Job Processor
prepares a list, each list contains two Messages ex: List1(m1, m2)
List(m3,m4) List(m5, m6)By using Split() method, we keep each message in
Outbound Queue (m1, m2, m3, m4, m5, m6).While fetching messages from
outbound queue using ConsumerTemplate
consumerTemplate.receiveBodyNoWait("jms:queue:destinationQueue",
String.class);/*we are not getting insertion order (m2, m1, m4, m5, m3,
m6).*/We are using camel 2.9.2.jar and VM Broker.Please help us to resolve
this issue.Regards,Dayakar
Dayakar wrote
> Hi Claus,We are using Camel 2.9.2 version.
--
View this message in context:
http://camel.465427.n5.nabble.com/ConsumerTemplate-is-not-fetching-data-in-insertion-Order-tp5744663p5744813.html
Sent from the Camel - Users mailing list archive at Nabble.com.
What the main Difference between Stoppping the Route and Suspending the Route
-- View this message in context: http://camel.465427.n5.nabble.com/What-the-main-Difference-between-Stoppping-the-Route-and-Suspending-the-Route-tp5732059.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: What the main Difference between Stoppping the Route and Suspending the Route
Hi,
Thanks for your Reply
I Have gone through the link which you suggested.
But i have some doubts regarding Stop and suspending the route.
I Have a Route with following Code
from("jms:queue:JobQueue")
.routeId(getName())
.process(new JobProcessor())
.to("jms:queue:destQueue");
If i stop the Above route by using camelContext.stopRoute(id)
==> Does this stop the route and when we say startRoute(id) it start the new
Route?
If i suspend the Above route by using camelContext.suspendRoute(Id)
=>Does this suspend route for sometime and when we invoke resumeRoute(id) it
start the existing Route?
Can you please explain the exact when we need to use stopRoute(id) and
suspendRoute(id) with an examples
Thanks in advance
--
View this message in context:
http://camel.465427.n5.nabble.com/What-the-main-Difference-between-Stoppping-the-Route-and-Suspending-the-Route-tp5732059p5732067.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: What the main Difference between Stoppping the Route and Suspending the Route
-- View this message in context: http://camel.465427.n5.nabble.com/What-the-main-Difference-between-Stoppping-the-Route-and-Suspending-the-Route-tp5732059p5732068.html Sent from the Camel - Users mailing list archive at Nabble.com.
CamelSpringTestSupport with PowerMock
Hi,
Iam using CamelSpringTestSupport class to write my JUnit.
But in one scenario i want to use PowerMock too.
If i use PowerMock with CamelTestSupport its giving following error
Error:
java.lang.IllegalStateException: Failed to transform class with name
org.apache.camel.test.junit4.CamelTestSupport. Reason: [source error] cannot
find constructor
org.apache.camel.impl.InterceptSendToMockEndpointStrategy(java.lang.String,boolean)
Below is my SampleCode:
@RunWith(PowerMockRunner.class)
@PrepareForTest({SecurityUtil.class })
public class TestCEM extends CamelTestSupport {
@Test
public void testeventProcessorFailureDetails(){
}
}
Could anyone can help in this
--
View this message in context:
http://camel.465427.n5.nabble.com/CamelSpringTestSupport-with-PowerMock-tp5735421.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Can we give Configure Stop Time for Quartz Component
Hi,
I am using Quartz Component which run Daily at 20:00 I configured it as
from("quartz://myGroup/myTimerName?cron=0+0+20+1/1+*+?+*").to("jms:queue:outBoundQueue")
It should run untill Dec 31 2013 after that it should stop the rOute.
How can i configure the stop time for this Route
--
View this message in context:
http://camel.465427.n5.nabble.com/Can-we-give-Configure-Stop-Time-for-Quartz-Component-tp5735888.html
Sent from the Camel - Users mailing list archive at Nabble.com.
How to Pause Quartz Componenent
Hi,
I am using Quartz Component which run Daily at 20:00 I configured it as
from("quartz://myGroup/myTimerName?cron=0+0+20+1/1+*+?+*").routeid("MainRoute").to("jms:queue:outBoundQueue")
I need to pause the Route for few Days
Iam using camelContext.suspendRoute("MainRoute");
But still Quartz is firing .
How can i pause Quartz Component
Thanks in Advance
Regards,
Dayakar
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-Pause-Quartz-Componenent-tp5736101.html
Sent from the Camel - Users mailing list archive at Nabble.com.
How to Add Routepolicy to RouteBuilder Dynamically
Hi,
I am creating a RouteBuilder dynamically by using Factory Mechanism.
RouteBuilder routeBuilder = subscriptionFactory.getRouteBuilder("Cancer");
For this Route I need to add .routePolicy(createRoutePolicy()).
routeBuilder.routePolicy(createRoutePolicy()) is not allowing
How can i add RoutePolicy for existing Route?
Thanks & Regards,
Dayakar
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-Add-Routepolicy-to-RouteBuilder-Dynamically-tp5737132.html
Sent from the Camel - Users mailing list archive at Nabble.com.
HL7 Mina throwing org.apache.mina.filter.codec.ProtocolDecoderException: org.apache.mina.common.BufferDataException
Hi, I am new to Camel-HL7 component. It seems like you implemented this component. can you please share me the sample code base/ your project code? In my case , I need to convert the java object to HL7 format and then send those messages to an endpoint. Thanks,,,
