Holding Messages for 10 Seconds in Artemis ActiveMQ
I am using WebSphere for both the web server and app server. The web server connects to Artemis ActiveMQ
using JMS, while the app server connects to Artemis ActiveMQ using a resource adapter. Once a request
comes into the web server, it is sent to an Artemis ActiveMQ queue, and then the request is sent to the
consumer. However, I want to hold that message for 10 seconds before it is delivered to the consumer.
journaling recovery of unrouted messages after a disaster activemq artemis
Background:
I am trying to recover messages that were sent by an application to an activemq artemis queue for a disaster related scenario. The scenario goes as such artemis broker1 is up and running talking to application1 and another application2 using jms. messages are routed from application2 to artemis to application1. During use application1 dies unexpectedly while the artemis broker1 is still receiving messages from application2 resulting in a bunch of unrouted messages stacking up. The artemis broker1 dies eventually and is restarted. application1 is restarted as well. application2 never dies. when the artemis broker1 comes up I want to recover the unrouted messages. and replay them to application1. I am having problems with recovering the unrouted messages.
Spilt brain (Pinging the network) concept in primary and backup
Recently, I faced a latency issue where the backup server became active after the primary server was disconnected, resulting in both servers being active simultaneously (a split-brain issue).
Getting Latency issue in the backup Server
Artemis MQ Primary broker 2024-05-25 02:00:52,946 WARN [org.apache.activemq.artemis.core.server] AMQ222207: The backup server is not responding promptly introducing latency beyond the limit. Replication server being disconnected now. Artemic MQ Seconaday broker 2024-05-25 02:01:00,230 INFO [org.apache.activemq.artemis.core.server] AMQ221066: Initiating quorum vote: PrimaryFailoverQuorumVote 2024-05-25 02:01:00,230 INFO [org.apache.activemq.artemis.core.server] AMQ221084: Requested 0 quorum votes 2024-05-25 02:01:00,231 INFO [org.apache.activemq.artemis.core.server] AMQ221083: ignoring quorum […]
Openwire error receving in the artemis console for each messages
2024-04-28 13:01:48,064 WARN [org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection] Errors occurred during the buffering operation javax.jms.IllegalStateException: Transaction not started, XID:[1463898948,globalId=001ffffff8fbffffffc9fffffffbffffffe70004126ffffffbb3618ffffffbeffffffca60ffffffa27850ffffff8a4f28ffffffa022227e24ffffffa1ffffffedffffff9cffffffe9ffffffeb29,branchId=001ffffff8fbffffffc9fffffffbffffffe70004126ffffffbb3618ffffffbeffffffca60ffffffa27850ffffff8a4f28ffffffa022227e24ffffffa1ffffffedffffff9cffffffe9ffffffeb29000100000000000002] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processCommit(OpenWireConnection.java:1549) ~[artemis-openwire-protocol-2.33.0.jar:2.33.0] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection$CommandProcessor.processCommitTransactionTwoPhase(OpenWireConnection.java:1602) ~[artemis-openwire-protocol-2.33.0.jar:2.33.0] at org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:102) ~[activemq-client-5.18.3.jar:5.18.3] at org.apache.activemq.artemis.core.protocol.openwire.OpenWireConnection.act(OpenWireConnection.java:366) ~[artemis-openwire-protocol-2.33.0.jar:2.33.0] at org.apache.activemq.artemis.utils.actors.ThresholdActor.doTask(ThresholdActor.java:68) ~[artemis-commons-2.33.0.jar:2.33.0] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68) ~[artemis-commons-2.33.0.jar:2.33.0] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:57) ~[artemis-commons-2.33.0.jar:2.33.0] at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:32) ~[artemis-commons-2.33.0.jar:2.33.0] at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:68) ~[artemis-commons-2.33.0.jar:2.33.0] at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.33.0.jar:2.33.0] Each and every request […]