The problem I am facing is very strange. My application is a Spring Boot application where I am using a Camel route to listen to AMQ 7 and then processing the message till it gets stored in a database or sent to another AMQ 7 instance. The issue is messages are consumed from AMQ via Camel but it's not maintaining the order in application logs. This means that before the flow for first message is getting completed I could see the logs start getting printed for another message dropping into AMQ which is making it difficult to track that the logs belong to which message from AMQ. Is it a prob with AMQ or Camel routes? Any suggestions is highly appreciated.
Messages not coming to Java Camel route application in sequence
451 Views Asked by RThinker At
1
There are 1 best solutions below
Related Questions in SPRING-BOOT
- Timing Issue with Spring Boot Annotation Configuration
- LightAdmin - Customise parsing DateTime with app timezone
- Creating distribution with repackaged spring boot jar using gradle application plugin
- Spring Boot MVC non-role based security
- Add JVM args to spring boot application
- The method and() is undefined for the type HttpSecurity
- swagger ui not working for swagger version 2
- Spring IO Platform 2.0 - Themes/Changes?
- JPA findDistinctPropertyBy magic method doesn't work as expected when using spring-boot-starter-jpa
- Spring boot check external service status on boot
- Running a specific spring batch job amongst several jobs contained withing a spring boot fat jar
- Adding security to rest api service built with Spring Boot app
- Spring Redirecting from Http to Https Breaks Rest Controller Test
- Service not starting using Spring-boot during integration tests
- Spring Boot Actuator Health Returning DOWN
Related Questions in APACHE-CAMEL
- Scala POJO Aggregator Exception
- Extract data from JSON in vanilla Java/Camel/Spring
- Camel route, unparsed date
- Camel rabbitmq + convertSendAndReceive() : Could not convert incoming message with content-type [null]
- Apache Camel: How to test for instance of Set<CustomObject>
- Monitoring Multiple Instances of camel web application in a single Dashboard
- Can I split compressed files into json components in Camel via Spring DSL
- Database not update when using apache camel sql component
- Error Injecting endpoint into a bean in Camel
- How to define common route body in camel configuration?
- NoInitialContextException in Apache Camel
- How to notify when a Camel seda queue is complete?
- How to access Default Idempotent Repository map from java dsl?
- Camel HTTP End point Special Charcter(+) issue
- Camel Route as a String load and Run
Related Questions in ACTIVEMQ-ARTEMIS
- SOAP or REST interface to JMS broker. "JMS over SOAP"
- Memory leak on Wildfly 10.1.0.FINAL (java.lang.ref.Finalizer / ActiveMQConnection)
- How to retreive messages from the producer Side when artemis is down?
- MDB Deploys Successfully: Then Won't Even Write to System.out. Why?
- Cannot send message to local JMS Queue over default Artemis/ActiveMQ in Wildfly 10
- Red Hat AMQ 7.0.1 certificate based authentication failed
- WildFly Swarm apps using an external ActiveMQ broker
- Failed sending message between two nodes in ActiveMQ Artemis
- Active MQ Artemis, most of the addresses and queue disappeared after HA failover
- ActiveMQ Artemis Queue does not distribute messages evenly to the STOMP-Consumers. How can we achieve an even load-balancing?
- Need Artemis Notification when the number of messages in the Queue are > 100
- ActiveMQ Artemis upgrade question: HornetQ to Artemis 2.0
- Achieve high availability and failover in Artemis Cluster with shared-store HA policy through JGroups protocol
- Artemis broker is not announcing itself as backup on RHEL machine
- ActiveMQ Artemis and broker URI
Related Questions in SPRING-CAMEL
- Apache Camel: TCP response chunked on first request
- Polymorphic Json Marshalling with Apache Camel
- Getting SSL Exception While Connecting Kafka Cluster with Spring boot and Apache Camel
- Getting PKIX path building failed Exception with Apache Camel while connecting to the Kafka cluster with SSL
- Intereceptor for REST API Camel
- Json string split and add addition object in the body using XML DSL in camel
- Camel in Action 2 - InvocationTargetException
- Copy large file from sftp
- I have a spring application exposing REST endpoints on both spring web and camel. My OpenAPI document can currently only document endpoints from one
- Duplicate message consumption on Apache Camel Kafka
- How to isolate subsequent Camel Spring-Boot test suites
- Memory leak caused by an increase in ClientState instances of the apache-camel-mqtt component
- Get white label page with status 404 using Apache Camel Servlet component
- Spring Camel: Fhir Route without explicit serverUrl parameter on XML
- Calling rest api secured with Bearer token authentication in Apache Camel route
Related Questions in AMQ
- set prefetch limit from stomp API
- Apache Camel .when() Statement Only works half of the time
- activemq memory usage 4 times greater than Maximum heap allocated
- How can we connect ActiveMQ and WebSphere MQ in one Spring Boot application?
- Does ActiveMQManagedConnection (EAP/AMQ) support Autoclosable?
- Is it possible or does anyone know of a way to change the JMSTimestamp of an AMQ Message to send to the broker?
- Messages not coming to Java Camel route application in sequence
- Why Red Hat AMQ 7.7.0.GA throws exception Invalid content was found starting with element 'broker-connections'
- JBoss AMQ / ActiveMQ Artemis: Pre-configure Durable Subscribers
- ActiveMQ Artemis STOMP acceptor not accepting
- Apache Artemis no clientId is showing in consumer section of management-console.UI
- Apache Camel - How to configure endpoint with attributes in java
- AMQ INDIVIDUAL_ACKNOWLEDGE Mode
- AMQ Error reading in simpleString, length=xxx is greater than readableBytes=yyy
- Does stomp.ConnectionListener in python holds any data while dequeuing messages from ActiveMQ?
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
This issue could be related to the camel route if the
asyncConsumeroption is enabled, see the documentation for further details https://camel.apache.org/components/latest/activemq-component.html