I have a Camel route which Consumes messages from a Queue and stores the message into a Database. Now I wanted to shut down running camel route manually in a graceful manner. I have a RestEndpoint to be triggered whenever I need to stop Camel route. This endpoint should stop the route. But if there is any in-flight message or transaction running during the shutdown it has to be completed successfully without consuming any new messages from from("") endpoint of camel route and shut down after completing inflight message or transaction. Can anyone help me how Can I code this?
Apache camel graceful route shutdown
2.3k Views Asked by Ramden At
2
There are 2 best solutions below
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 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 CAMEL-JMS
- ActiveMQ embedded bridge to Camel JMS bridge
- Camel 3 - Dynamic uri for deadLetterChannel
- Why are Solace messages hanging on the server on restart after Camel 3 upgrade?
- Apache Artemis no clientId is showing in consumer section of management-console.UI
- Camel transacted JMS component doesn't work with Aggregator
- How to consume messages from Apache Camel JMS as Transacted Batch?
- Object could not transfer in camel JMS queue
- How to filter jms message in apache camel xml configuration file
- How to enable transaction with activemq camel component
- Apache camel graceful route shutdown
- How to set the JMSCorrelationID and correlate with JMSMessageID with a Camel client and a IBMMQ broker
- CAMEL JMS crashed & stop producing messages
- Camel activemq component nosuchmethod exception
- JMS component's bridge error handler not working
- How does JMS read multiple files on a queue
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?
Below are the few options to control/monitor camel routes
CamelContext API's
Control bus component
JMX API's
You can go through below two sites to get started