Questions tagged [activemq-artemis]
Apache ActiveMQ® Artemis is an asynchronous messaging broker, an example of Message Oriented Middleware.
1,230
questions
0
votes
1
answer
38
views
Can we work with MDB and EJB's in Quarkus
I tried looking into whether we can use MDBs and EJBs with the Quarkus framework, but I couldn't find any resources on Quarkus documentation. Can you please explain whether it is possible?
Basically, ...
2
votes
1
answer
49
views
Error connecting to remote JMX broker ActiveMQ Artemis
I have code that connects to the ActiveMQ Artemis broker console via JMX. It connects to localhost, but it cannot connect to a remote host, although the settings are the same
Here is the code to ...
-1
votes
0
answers
49
views
SessionExpiryInterval MQTT5 has no effect?
I'm using ActiveMQ Artemis to send messages to an S3 bucket with MQTT 5. My route is like this:
from("paho-mqtt5://..
...
&qos=1
&cleanStart=false
&...
-1
votes
1
answer
43
views
How to make ActiveMQ Artemis master/slave work with shared storage, ensuring the slave takes control when the master goes down?
I have 2 servers. I installed ActiveMQ Artemis 2.28.0 master/slave with shared storage.
The console is working on both and sending a message work with the master, but if the master goes down the slave ...
0
votes
1
answer
23
views
ActiveMQ Artemis Security with OAuth2
Is there a way where we can configure OAuth2 in ActiveMQ Artemis. I found this material Extending Artemis Security with OAuth2. Is there anything in the ActiveMQ Artemis User Manual for the same?
0
votes
1
answer
30
views
Connecting to http-remoting address in Wildfly ActiveMQ Artemis using C# .NET - what am I missing?
I have a Wildfly instance running ActiveMQ Artemis. How can I set up and connect to an address "http-remoting://x.x.x.x:xxxx" in C# .NET with using a username and password?
string url = &...
0
votes
1
answer
24
views
In Apache ActiveMQ Artemis, how can I force Stomp messages to be text instead of binary?
We have just switched to Apache ActiveMQ Artemis, enabling the Stomp server for Javascript WebSocket subscriptions, and everything is working fine, but we're receiving messages as "kind of" ...
0
votes
1
answer
31
views
How to purge a queue in ActiveMQ Artemis programmatically using Java?
I am new to using ActiveMQ Artemis, and I am trying to purge one queue programmatically. I have searched through the documentation, and online but have not been able to find anything to help with this....
0
votes
0
answers
156
views
Keycloak X509TrustManager implementation
I have integrated Keycloak and ActiveMQ Artemis. Both are running on HTTPS. I have added the Keycloak truststore in ActiveMQ Artemis. Now I am getting this error in ActiveMQ. As the error says there ...
0
votes
1
answer
75
views
Keycloak Integration with ActiveMQ Artemis
The keycloak instance is running in pod on AKS. I have configured the necessary variable to run it in production mode. The keycloak and ActiveMQ Artemis both are running on HTTPS.
When I am trying to ...
1
vote
1
answer
33
views
Can't read bytes message via JMX in ActiveMQ Artemis
I am reading a message via JMX. If it is text then everything is OK, but if it is byte then it gives such an error. I can't figure out how I should read a byte message and get its text in a string.
...
0
votes
1
answer
28
views
How to send byte message to ActiveMQ Artemis queue via JMS?
I have a method for sending a message via JMS, but I don't understand why I don't change the message type.
public static void sendMessage(QueueSession queueSession, MessageProducer messageProducer, ...
0
votes
1
answer
38
views
How to connect by user/password in JMS?
I have a code that connects to a broker by url. I do not understand how to make connections also by login / password?
public static QueueSession getQueueSession(String urlBroker) throws JMSException {
...
0
votes
1
answer
15
views
WildFly Messaging Configuration For Message Retry Control
We are running WildFly 26 in a cluster and observe the automatic retry of JMS message when exception is thrown. All is working as expected where the message retries multiple times with a small delay ...
0
votes
0
answers
58
views
Large lag between client and broker (possible flow control & credit behaviour)
We are testing our application suite that uses ActiveMQ Artemis 2.27.1 (cluster but of just 1) (Core protocol).
App A sends messages to a REQUEST Q then waits for a response on an equivalent REPLY Q (...
1
vote
0
answers
25
views
JMX exporter ActiveMQ Artemis cluster monitoring
I have an artemis cluster with 3 nodes. In some times one of nodes cant see other nodes, but it works in standalone mode. In this situation I have 2 brokers (cluster and standalone node).
How I can ...
0
votes
0
answers
28
views
ActiveMQ Artemis lost connections between nodes
I have an ActiveMQ Artemis cluster with 3 live and 3 backup nodes.
When 1st live node is overloaded it becomes unstable, and then when load comes down some nodes in cluster don't see all nodes. For ...
0
votes
1
answer
42
views
ActiveMQ Artemis DLQ address with copy of each message placed in DLQ.queue?
We probably encounter a problem with the "DLQ" address (with "queue stat" command) which count more than 3,6 millions messages (MESSAGE_COUNT and MESSAGE_ADDED).
In case of auto-...
0
votes
1
answer
48
views
Why isn't JMSExpiration, JMSPriority set when sending a message to an ActiveMQ Artemis queue via JMS?
I'm sending a message to a queue with a priority of 7 and a lifetime of 600000 ms. And I do not understand why a message with a priority of 4 and a lifetime of never falls into the queue
Message ...
0
votes
1
answer
30
views
ActiveMQ Artemis 2.18.0 killed from the critical analyzer
My ActiveMQ Artemis process is restarted from the critical analyzer with this message:
Component org.apache.activemq.artemis.core.server.impl.QueueImpl is expired on path 3
AMQ224079: The process for ...
0
votes
2
answers
65
views
Insert message in JMS queue on Wildfly 27 server
For testing purposes, I want to insert a message into the queue that is embedded on the WildFly server. I tried through JMeter but I'm not sure how to set it up.
My standalone settings for ActiveMQ ...
0
votes
1
answer
53
views
Authorization by login / password does not work when connecting via JMX
I have a method whose parameters are passed values for connecting to the ActiveMQ Artemis broker via the JMX protocol. But my username/password is not working. That is, if I leave the user and ...
0
votes
1
answer
52
views
ActiveMQ Artemis 2.27.1 $.artemis.internal.sf large messages are building up
Running 3 nodes of ActiveMQ Artemis 2.27.1:
From the diagram we can see the cluster is formed:
This is node 2 view and I'm not sure but those delivering messages seem block.
Node 3 started paging ...
0
votes
1
answer
60
views
How to send message with headers to ActiveMQ Artemis queue via JMX protocol?
I want to send a message to an ActiveMQ Artemis queue, but I don't understand how to pass headers there such as: message lifetime, message type and other headers, not properties
Here is the code for ...
-1
votes
1
answer
151
views
ActiveMQ Artemis + Spring Boot 3 + Apache Camel - RouteBuilder is not working
I created a very simple Spring Boot 3.0 project with Apache Camel and ActiveMQ Artemis since ActiveMQ "Classic" support has been discontinued in Spring Boot 3. My MQ routes are not working. ...
0
votes
0
answers
32
views
MessageMigration feature not working with Artemis ActiveMQ in EKS
I have 2 Artemis ActiveMQ broker pods deployed in EKS. Each of the pods also use a separate persistent volume.
I am trying to test the message migration feature, which is failing.
Operator version: ...
0
votes
0
answers
63
views
AMQ224011: Cannot find queue messages
I am using Artemis 2.21.0 version and storing the messages in PostgreSQL DB. Recently we have started getting following errors.
Any idea what can be the reason of the error?
11:17:09.638 [http-nio-...
0
votes
1
answer
41
views
How to create a user in ActiveMQ Artemis?
I don't understand how to create user with password in ActiveMQ Artemis
Here is my artemis-roles.properties:
amq = admin
test = admin
Here is my artemis-users.properties:
admin = ENC(1024:...
0
votes
1
answer
26
views
JDBC persistence allows only shared store HA options
I want use PostgreSQL for persistence of ActiveMQ Artemis, but it's not working and shows the error "JDBC persistence allows only Shared Store HA options":
ERROR [org.apache.activemq.artemis....
0
votes
1
answer
61
views
Throws JMSException errors when connecting to a broker via JMX in ActiveMQ Artemis
I have a code to connect to the ActiveMQ Artemis broker via the JMX protocol using some kind of login/password authorization
public static MBeanServerConnection connectBroker(String brokerUrl, String ...
0
votes
0
answers
33
views
Logging and tracing ActiveMQ Artemis JMS messages from a specific consumer
We have an ActiveMQ Artemis cluster and wish to trace the messages transferred back and forth from a specific/problematic consumer.
I know we can trace all JMS messages with the logger org.apache....
-2
votes
0
answers
63
views
How to get individual properties in ActiveMQ Artemis via JMX?
I'm sending a message to an ActiveMQ Artemis queue with separate "Property: first" and "Property: second" properties. I need to get exactly 2 of these values, but property keys can ...
0
votes
1
answer
44
views
How to connect by role in ActiveMQ Artemis via JMX?
I have a Java application using JavaFX. I don't understand how to connect by role. So that each role has its own rights to proofread, etc. I know how to add a role to ActiveMQ, but my application ...
-1
votes
0
answers
32
views
ActiveMQ Artemis - message filtering
Could someone please explain how to filter messages with the header (e.g. MyHeader)? I send it through the AMQP plugin (TIBCO platform) and when he reaches ActiveMQ Artemis it somehow gets the ...
0
votes
1
answer
20
views
Why Apache Artemis Web Console cutting headers? [duplicate]
Artemis web console shorten / cutting the headers? Why? And where can I change this?
ActiveMQ doesn't do this.
[
{
"messageID": "62277035128",
"priority": 4,
...
0
votes
1
answer
56
views
How refresh token of Websocket connections secured by Keycloak
I have an ActiveMQ Artemis server and my applications are connecting via STOMP over WebSockets. Artemis is using Keycloak to validate credentials. I pass the token as part of the CONNECT frame.
...
0
votes
1
answer
29
views
How to get JMSReplyTo and JMSCorrelationID from CompositeData[]?
There is an answer where all the String properties of a message are printed, but I don't understand how to get (display) exactly JMSReplyTo and separately JMSCorrelationID.
I tried the key value ...
0
votes
2
answers
94
views
Accessing embedded ActiveMQ Artemis with JNDI
In production we use a commercial JMS broker that is not directly supported by Spring Boot (there is no starter project and there are no application properties for it). We access the connection ...
0
votes
1
answer
44
views
unable to authorise cluster control: AMQ219016: Connection failure detected
I am trying to configure the cluster in ActiveMQ Artemis using static connectors. The whole setup is running on AKS Cluster.
Static Cluster Config for POD 0:
<acceptor name="artemis">...
0
votes
0
answers
48
views
Storage usage configurations in ActiveMQ Artemis
Altering the broker configurations while migrating from ActiveMQ "Classic" to ActiveMQ Artemis, struggling to find alternatives for the following system usage related configurations:
<...
0
votes
2
answers
73
views
Subscriber-only acceptor port in ActiveMQ - is it possible?
We want to use Apache ActiveMQ (either 5.x or Artemis) as a WebSocket server sending update notifications to Internet clients via STOMP. For this to work safely, we need to configure an acceptor so ...
0
votes
1
answer
33
views
How to get the queue not from the context, but through the field?
I have a code that gets the name of the queue from a file, but how can I make it get it by the value passed in the method?
public static void initialization(String queue, String ConnectionFactory) ...
0
votes
1
answer
56
views
How to configure redelivery policy in ActiveMQ Artemis client?
In ActiveMQ default client org.apache.activemq:activemq-client:5.17.0
re-delivery policy is being configured like this
var connectionFactory = new ActiveMQConnectionFactory();
var policy = new ...
1
vote
1
answer
42
views
Irresponsible concurrentConsumers property of the Apache Camel JMS endpoint
I use concurrentConsumers=20 property for JMS endpoint in my route, but I have got different number of consumers.
My route is:
<?xml version="1.0" encoding="UTF-8"?>
<...
0
votes
0
answers
35
views
I see only partial message and not full message
In my queue hosted by ActiveMQ Artemis 2.19.0 I see only partial message and not full message. Where can I increate the setting to see full message?
I am viewing the messages by logging into the web ...
1
vote
1
answer
65
views
How to send and subtract message to ActiveMQ Artemis queue via JMX?
I can't find any documentation anywhere on how to send and subtract a message to an ActiveMQ Artemis queue via JMX
I tried via the same MBean from ActiveMQ "Classic," but those MBeans are ...
0
votes
0
answers
40
views
How can I replace the broker.xml in ActiveMQ Artemis with a customized broker.xml while creating the docker image using dockerfile?
I am trying to implement SSL certificate in my ActiveMQ Artemis docker image in on-prem server. I have modified the broker.xml and dockerfile to implement the change in the image, but whenever I am ...
0
votes
1
answer
264
views
SSLHandshakeException: No available authentication scheme
I generated a CSR with the following command:
openssl req -new -out activemq.csr -newkey rsa:2048 -nodes -sha256 -keyout activemq.key -config req.conf
I received back my-cer.cer after submitting my ...
1
vote
1
answer
57
views
How to translate CompositeData[] class objects into Message class objects in Artemis JMX?
I'm using JMX to connect to an Artemis queue via the QueueControl class and its browse method, which returns a CompositeData array, but I can't get the individual headers with the get methods as there ...
0
votes
1
answer
65
views
Getting "channel has already failed" exception publishing a message to ActiveMQ Artemis from Spring Boot using SSL
I am trying to publish/listen to ActiveMQ Artemis with Spring Boot using SSL. There is not really any documentation on how to do this.
But I am getting an exception on startup trying to connect to ...