Stack Overflow
Stack Overflow

Questions tagged [camel-jms]

36 questions
2
votes
0 answers

How to consume messages from Apache Camel JMS as Transacted Batch?

I know there is component sjms-batch which could perfectly solve my problem, but that component exist in Camel 3.7, and i need to use Camel 3.8. According to Camel documentation this component doesn't exist anymore after version 3.7. I couldn't find…
ngli0703
  • 41
  • 2
2
votes
1 answer

Camel transacted JMS component doesn't work with Aggregator

I discovered that JMS component with option transacted=true doesn't work well with Aggregator. My route is transactional until it reach the Aggregator, after Aggregator my route is not anymore transactional. If I understood well, this is because…
ngli0703
  • 41
  • 2
2
votes
3 answers

Camel JMS request-reply with 'n' reply messages

I am using Camel JMS component for request-reply for communication with MQ. For some of my requests I can receive n messages in reply. How can I aggregate these reply messages? I thought of using aggregator pattern with aggregation strategy, but…
gomzee
  • 103
  • 1
  • 9
2
votes
1 answer

Custom camel header not stored in JMS message property

I'm playing around with Camel, and as a simple testcase, I want to add an header to the incoming message and store it in a JMS queue (activemq). This is the code using the REST dsl: rest("/query-set") .id("queryset-route") .get("{id}") …
JointEffort
  • 583
  • 7
  • 21
1
vote
1 answer

How can I set the JMS_IBM_MQMD_MsgId header using Apache camel-jms

So, I have a message that I'm sending over an IBM mq queue and I would like to give it a customised MessageID. I've implemented DestinationResolver with the below properties in order to enable MQMD…
VerseBeCoding
  • 11
  • 2
1
vote
0 answers

Camel 3 - Dynamic uri for deadLetterChannel

I'm trying to setup a smart JMS deadLetterChannel where the final uri of the DLQ is computed dynamically, depending on original queue name (eg adding a ".dead" suffix). I have seen in the doc that it's possible by setting the CamelJmsDestinationName…
TacheDeChoco
  • 3,683
  • 1
  • 14
  • 17
1
vote
2 answers

Transacted Route and Transactional Endpoints, Transaction commit order

My route looks like below from("jms:queue:IN_QUEUE) //(A) Transactional Endpoint .transacted("required") //(B) TX Policy with PROPAGATION_REQUIRED and JPATxManager .bean("someBean", "readFromDB()") //(C) Read from DB …
Raju Parashar
  • 312
  • 4
  • 17
1
vote
2 answers

How to prevent message redelivery from MQ Broker after camel internal redeliveries are successfully processed (transacted camel route)

I am trying to run a camel transacted() route (a standalone java process) with JPATransactionManager is the spring PlatformTransactionManager (as I want camel route to run in a single DB transaction) but I am not able to suppress redelivery from MQ…
Shailesh Jain
  • 79
  • 6
1
vote
1 answer

Camel activemq component nosuchmethod exception

I am using activemq component to send/receive messages, however when I split() the body(), am getting this below exception. I am using camel 2.23.0 version. can someone advise what is wrong? This is an example of a route which causes this issue:…
Ponmalarvasagan Murugesan
  • 11
  • 1
1
vote
1 answer

CAMEL JMS crashed & stop producing messages

Last week we got an production issue on ESB Camel JMS, we have deployed multiple micro services on FUSE server. Below exception happened in one installed service caused all the other services stopped producing AMQ messages. 04:34:30,584 | INFO …
salz
  • 81
  • 12
1
vote
1 answer

How to solve the JVM hung issue in Apache Camel when there is a connection issue to IBM MQ?

We are seeing the frequent JVM hung in Apache camel based application whenever there is a network/connection issue to the IBM MQ. The logger clearly says the connection problem happened and Spring CachingConnectionFactory is trying to reset the…
Selvakumar
  • 189
  • 1
  • 13
1
vote
0 answers

How to add the transaction timeout for Apache Camel route with IBM MQ?

We have an issue in the application that the jms message commit on the ibm mq takes hours to complete which inturn causing the log space filling up in ibm mq and also JVM hung issues on the application side. To resolve this, I tried implementing the…
Selvakumar
  • 189
  • 1
  • 13
1
vote
1 answer

How to filter jms message in apache camel xml configuration file

I wish to create jms subscriber on a general topic. to avoid unwanted messages i wish to create a filter there. the problem is the syntax is available every where from java code but I can not find how to do same in xml configuration file like…
anna
  • 265
  • 1
  • 3
  • 17
1
vote
0 answers

Jms runtime selector not working with artemis (for Topic)

I am using Stringboot, springboot starter artemis and camel here is my dependencies for them: compile('org.springframework.boot:spring-boot-starter-artemis') compile 'org.springframework:spring-jms' compile…
Baba
  • 311
  • 1
  • 2
  • 12
1
vote
0 answers

Camel jms request/reply threading model

I am using camel jms in a synchronous way using request-reply pattern.The camel route exposes a cxf endpoint and it places the message in to the jms queue another component process it and sends the response in replyto queue. A new thread is getting…
Ravi
  • 1,247
  • 4
  • 15
  • 35
1
2 3