87 questions
-3
votes
0
answers
30
views
JMS broker disconnection, message sent, pod dies before broker reconnects: what is the message lost? How to prevent the loss?
Okay, I have an interesting one so far that is difficult to Google successfully and I have no prior experience on this particular problem guiding me on a correct solution.
I have the following ...
- 1,404
0
votes
1
answer
31
views
A message consumed from AMQ even when Camel route fails
I am building a "bridge" between two AMQ7 brokers using Camel routes. When delivery of the message to the second broker fails (e.g the destination broker is offline) the message goes into ...
-1
votes
1
answer
66
views
ActiveMQ Artemis - Replicated cluster
I have a 2 server (soon to be 3) cluster running with 2 servers each with one primary node and one slave/backup node (see below)
If i take down a primary server, it's replication slave takes over and ...
- 341
0
votes
0
answers
46
views
connecting and reading from AMQ using jpype hangs some times
We are using JPype to connect to an AMQ broker and read the queue. The program works fine. However, it is frequently getting hung in the connection state. Below is the program we are using. Can ...
- 55
0
votes
0
answers
19
views
Does LVQ works with non durable queue in AMQ
We have a requirement where we need to have LVQ for a non durable queue in AMQ. We tested the same with durable queue, it works fine however it is not working with nondurable queue. I wanted to know ...
-2
votes
1
answer
39
views
Write a message to queue instead of address
I have an use case where we need to write a messages to durable/non durable queues instead of an address in AMQ broker. We don't want to write the messages to be sent address and route to respective ...
0
votes
1
answer
109
views
Taking too long to send first message to JMS topic from Spring Integration
I am using Spring Integration to produce messages to a JMS topic on Red Hat AMQ 7.8.2. It is taking 3 to 4 seconds to send the first message on application startup/restart and it does take 40 to 50 ms ...
0
votes
0
answers
140
views
How can we connect ActiveMQ and WebSphere MQ in one Spring Boot application?
In Spring Boot 2.6.11 application we are trying to consume data from ActiveMQ and publish data to WebSphere MQ.
For that if we need to manual configure both the ActiveMQ and WebSphere MQ?
If yes then ...
- 347
0
votes
3
answers
142
views
ActiveMQ Classic StatisticsPlugin not working with wildcard destinations
I am using the ActiveMQ Classic StatisticsPlugin to collect stats for destinations. I have used ActiveMQ.Statistics.Destination.* along with a replyTo header to collect the stats for all the topics. ...
- 259
0
votes
1
answer
259
views
What version of Apache ActiveMQ corresponds to the JBoss A-MQ v6.3?
Please advise what version of the Apache ActiveMQ broker/client corresponds to JBoss A-MQ v6.3?
We are considering a possibility of migrating to the open source alternative (Apache ActiveMQ "...
- 2,911
0
votes
1
answer
432
views
How to publish to a Red Hat AMQ 7 topic using AMQP 1.0 from a test case using amqp-10-jms-spring-boot-starter
I created a subscriber to a multicast queue. When starting the application I can see that the multicast address gets created, the client queue underneath gets created and if I use the web interface to ...
- 1,153
0
votes
1
answer
523
views
How to use a topic in Red Hat AMQ 7 using AMQP 1.0 and consume in Spring Boot?
How does one configure and use a Topic (publisher - subscriber model) in Red Hat AMQ 7 using AMQP 1.0 and consume in Spring Boot
I have configured the topic as follows in the Red Hat AMQ console
I ...
- 1,153
0
votes
1
answer
166
views
Openshift AMQ6 - message order - queue
I use AMQ 6 (ActiveMQ) on OpenShift, and I use a queue with re-delivery with exponentialBackoff (set in connection query params).
When I have one consumer and two messages and the first message gets ...
- 27
1
vote
0
answers
2k
views
AMQ212054: Destination address=... is blocked. If the system is configured to block make sure you consume messages on this configuration
I am using Artemis 2.7.0.redhat-00056 (AMQ 5.11 I think)
One of the camel routes was set up ages ago. It sends XML on a queue, which is then handled in a bean.
So it uses JMS style code:
producer ...
- 1,676
1
vote
0
answers
306
views
How to replace the base Java image in public base image with customized version
We are using base image of RedHat AMQ registry.access.redhat.com/jboss-amq-6/amq63-openshift which is a public base we cannot change. We use that image in jib maven plugin and did some changes to ...
- 13.1k
0
votes
1
answer
236
views
How to stop streaming when no data is left to read in the AMQ topic
I am using spark streaming to read from AMQ. I want the streaming to stop when no data is left in the message queue. I created a custom receiver that connects to the AMQ topic and starts reading the ...
- 3,400
0
votes
1
answer
316
views
Calling AMQ Listener from APIGEE Proxy end point
I am creating the APIGEE proxy from APIGEE edge. Its target is a Mule deployed application which has no HTTP listener. It is only triggered by AMQ listener. Is there any way to connect to that ...
- 37
0
votes
1
answer
308
views
What certificates does an Artemis AMQ subscriber using stomp.py need to establish a SSL connection to server
I am using stomp.py to establish a Stomp1.2 SSL connection to a ActiveMQ-Artemis/2.7.0.redhat-00056 ActiveMQ Artemis Messaging Engine. I have no control over the server and I was given the following ...
-1
votes
1
answer
730
views
Does stomp.ConnectionListener in python holds any data while dequeuing messages from ActiveMQ?
I want to pull the messages from AMQ to python. I want to use python for batch processing (like if I have 1000 messages in the queue, I need to dequeue every 100 messages and process them and take the ...
1
vote
1
answer
818
views
AMQ Error reading in simpleString, length=xxx is greater than readableBytes=yyy
I'm trying to work out how to fix this ActiveMQ Artemis error.
Seems the occasional message is too big for SimpleString, and isn't sending, and it goes to the DLQ.
java.lang.IndexOutOfBoundsException: ...
- 1,676
0
votes
1
answer
681
views
AMQ INDIVIDUAL_ACKNOWLEDGE Mode
I am using INDIVIDUAL_ACKNOWLEDGE mode to receive messages and manually acknowledge messages received from AMQ using C++ CMS library which implements JMS standards via Openwire protocol.
I have got ...
- 21
0
votes
1
answer
411
views
Why Red Hat AMQ 7.7.0.GA throws exception Invalid content was found starting with element 'broker-connections'
I am trying to use the configuration element broker-connections in Red Hat AMQ 7.7.0.GA version, but it gives me following error. The same works with AMQ 7.8.0 development version. Also as the ...
- 387
-1
votes
1
answer
532
views
Messages not coming to Java Camel route application in sequence
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 ...
- 1
0
votes
1
answer
313
views
Is it possible or does anyone know of a way to change the JMSTimestamp of an AMQ Message to send to the broker?
I'm writing an application which interfaces with multiple brokers using the springboot java framework. I'm leveraging JMS to browse/read messages which are older than 4 hours. The main issue is trying ...
- 79
0
votes
1
answer
2k
views
ActiveMQ Artemis JMS Shared Subscription
I have a single node ActiveMQ instance with two competing consumers connected to a topic. The topic subscription is shared as per JMS 2.0 specification. Shared subscription does guarantee that only ...
- 443
0
votes
0
answers
591
views
ActiveMQ clean up old queues that seems to just hang around?
So I have a jboss AMQ 6.3 cluster (3 pods in OpenShift) that keeps growing daily.
Looking in the Java Console, there are a Lot of Queues named clever things like
error-user006107e3-85ce-bdf1-f414-...
- 419
0
votes
1
answer
2k
views
Message Order in Apache ActiveMQ Artemis Cluster
I am trying to implement message ordering in Apache Artemis cluster. Producers/Consumers connecting to the cluster implement High availability. So at one point of time there will be two instances of ...
- 443
0
votes
1
answer
99
views
AMQ Message Ordering with Exponential Backoff
I am curious about the way AMQ handles message ordering when it comes to message redelivery and exponential backoff.
Say you have three messages: [M3,M2,M1]. If I pluck the the M1 message from the ...
0
votes
1
answer
178
views
Does ActiveMQManagedConnection (EAP/AMQ) support Autoclosable?
I am using:
openshift
AMQ (seems to be a forked activemq-5.11.0.redhat...... version)
EAP 7.2.3
While local debugging I get as Connection some ~ConnectionProxy with a physical ...
- 369
-1
votes
1
answer
386
views
Implement message service using AMQP 1.0 protocol using Red Hat AMQ and Spring Boot
I have to make a demo project which sends a message to and receives a message from a topic/queue using the AMQP 1.0 protocol and Red Hat AMQ (which is built on ActiveMQ Artemis). However, I am unable ...
- 145
0
votes
0
answers
148
views
ActiveMQ Topic messages are getting stuck, resent in bulk after glitch
Environment:
ActiveMQ deployed on kubernetes
Producer Java Application using openwire
Subscribers Python and C client using MQTT
Problem Statement:
Producer is sending message after every seconds ...
- 2,417
1
vote
1
answer
305
views
How do I scale up JBoss AMQ 6.3 in openshift?
I have a default setup of JBoss AMQ in OpenShift and want to scale it up to two pods. How do I accomplish this?
Just scaling it leads to the following:
INFO | Using Persistence Adapter: ...
- 2,720
0
votes
3
answers
803
views
Can I use Red Hat AMQ 7.7 in production without license/support subscription
Can I use Red Hat AMQ 7.7 in production without license or support subscription? And what's the difference between JBoss AMQ and Red Hat AMQ?
- 2,417
1
vote
1
answer
2k
views
Frame must be terminated with a null octet error in Jmeter
I have to load test a WebSocket on Jmeter. WebSocket has been implemented using Springboot.
I am facing an issue while sending Stomp data on Jmeter while testing. I am framing text appropriately ...
- 11
0
votes
1
answer
538
views
Kafka AMQ Stream - Topics command
I've never used AMQ Streams (Kafka). How can I connect to topics through the route (read/create/delete)? With Kafka, for example from my local machine, I used the CLI with the basic command. But with ...
- 1
0
votes
1
answer
86
views
Client Local Queue in Red Hat AMQ
We have a network of Red Hat AMQ 7.2 brokers with Master/Slave configuration. The client application publish / subscribe to topics on the broker cluster.
How do we handle the situation wherein the ...
- 443
0
votes
1
answer
190
views
AMQ in .Net - Certificate or credentials
Should both Trust store/Key store and Certificate should be used to access AMQ Broker over SSL connection? If yes, how to achieve this? I find very less articles, blogs to do this for NMS. I am newbie....
- 11
0
votes
1
answer
1k
views
JMS Connection to Red Hat AMQ 7 running on Openshift using a secured route
We're running AMQ 7 on Openshift 3.11. When trying to connect java clients using JMS from the Openshift platform there is no issue. However, to access it from an external client I've created a secure ...
- 1
0
votes
1
answer
671
views
How to write an integration test for service that uses ActiveMQ Artemis
I am looking into automated integration tests for a service that consumes from and produces to Red Hat AMQ 7.5.0. I am aware that you can produce & consume via REST, but this service is part of a ...
- 2,092
0
votes
1
answer
590
views
JMS 2.0 durable subscriptions topic best practice in Kubernetes
We are creating a Mule application which will be running in a container on Kubernetes and will be in a replica set that will be connecting to JMS 2.0 Red Hat AMQ 7 (based on ActiveMQ Artemis).
The ...
- 475
0
votes
1
answer
390
views
Several errors while runninv mvn clean verify
Idk whats wrong, i just wanna run an amq-broker example...Here's my full settings.xml (i just added the jboss-amq-maven-repository PROFILE & also added jboss-amq-maven-repository as my ...
- 65
0
votes
1
answer
176
views
Can't run queue example from Red Hat
I can't run a simple queue example from Red Hat AMQ. It displays the following error:
Non-resolvable parent POM for org.apache.activemq.examples:artemis-examples:2.10.0.redhat-00004: Failure to find ...
- 65
0
votes
0
answers
590
views
Apache Camel AMQ - cannot write file to queue - connection reset by peer/client
thanks in advance!
I am trying/need to write file from FTP to AMQ Queue.
Reason - I'm trying to add failover on my routes using Camel JMS AMQ.
I'm new to Apache ActiveMQ JMS. I have 2 AMQ brokers on ...
- 638
0
votes
0
answers
630
views
Wrapping http / gRPC traffic over ActiveMQ / AMQ
I have two segments of enterprise network - green (with access to the Internet) and red (internal network). So, it works like this: Internet ↔ Green ↔ Red.
Each of two segments has it's own pack of ...
- 81
0
votes
1
answer
524
views
How to set properties for AMQ message
I am sending XML message to AMQ queue. XML has header section. I need to set child nodes of header as properties of AMQ message. I am using NodeJS stompit package.
Currently message shows only one ...
- 1,877
1
vote
1
answer
509
views
How to check if there are no message to consume in AMQ queue in stopmit node.js
I am using stompit package of node.js to connect to AMQ queue to subscribe message. I used ConnectFailover class to create connection and channelPool class to create pool.
Problem I am facing is that ...
- 1,877
1
vote
2
answers
1k
views
AWS SNS-SQS Fanout Options when message order matters
We have our Active-MQ on-premise and I'm exploring options in AWS for managed messaging service. All of our applications use ActiveMQ's Virtual Topic feature. It appears that in AWS, Fanout can be ...
- 1,130
1
vote
0
answers
332
views
Push messages to AWS active mw from AWS lambda
The use case is to create a microservice-http-endpoint AWS lambda function which publishes message to Amazon ActiveMQ, I tried searching for the same but could not find an answer, is it possible to ...
- 108
1
vote
1
answer
2k
views
Does ActiveMQ Artemis / RedHat AMQ not set JMS Message ID correctly?
According to the JMS spec, I do not have to specify the message ID when sending.
When I send a message via JMSProducer#send() or when I create a message via the hawt.io console, I can see the message ...
- 1,472
0
votes
1
answer
589
views
Reuse the authentication of the user against LDAP in ActiveMQ Artemis
LDAP authentication is configured in ActiveMQ Artemis(2.6.1 -Redhat AMQ7.2) environment but i am noticing authentication for a user happens against LDAP server very frequently. Even when no messages ...
- 62