I am using ActiveMQ broker in my bot for sending message to my subscribers, and I'm receiving this error: 2023-06-09 12:57:57,650 | INFO | Usage Manager Memory Limit (1336252826) reached on queue://VIBER, size 0. Producers will be throttled to the…
I have an MQTT broker with ActiveMQ on an Ubuntu server with Windows clients. Now I want to enable SSL. I found the tutorial, but I have a question. This step 1: I do on Mqtt broker activemq Step 1…
I am building a spring boot application with a cluster of ActiveMQ servers. In order to solve the duplicate message issue in the consumer side, all the dequeued JMSMessageID will be saved in redis, and the consumer will ignore all…
I was trying to run Apache Activemq , broker ran successfully at localhost. At same machine JMS producer , consumer Java applications ran successfully . BUT I changed Uri to tcp://192.168.1.1:61616 in activemq.xml and ran the broker in machine 1(…
How to set default data format for a component in Apache Camel? I have a number of routes interacting with different ActiveMQ queues. At the moment all of them look like from("...") .process(...) .marshal().json() // (1) .to("activemq:queue:..."); or from("activemq:queue:...") .unmarshal().json()…
I have this scenario: ADDRESS1: -ADDRESS1.QUEUE1 -ADDRESS1.QUEUE2 ADDRESS2: -ADDRESS2.QUEUE1 -ADDRESS2.QUEUE2 Two addresses with multiple anycast queues. I need to route messages to a specify queue into the address. Example: Messages on ADDRESS1::ADDRESS1.QUEUE1 goes to -> ADDRESS2::ADDRESS2.QUEUE1 Messages on ADDRESS1::ADDRESS1.QUEUE2 goes…
I am trying to implement a strategy where when messages in an activemq queue expire, instead of being moved to the default dead letter queue ActiveMQ.DLQ, they will go another dead letter queue. My application uses camel-context for routing and…