Questions tagged [jms]

The Java Message Service (JMS) API is a Java Message Oriented Middleware (MOM) API for sending messages between two or more clients. JMS is a part of the Java Platform, Enterprise Edition, and is defined by a specification developed under the Java Community Process.

Filter by
Sorted by
Tagged with
0 votes
1 answer
27 views

Configuring Maximum Concurrent Message Processing in Amazon MQ w/ActiveMQ with JMS

I'm trying to understand how to integrate Amazon MQ using the ActiveMQ Engine and the JMS protocol into my application. The main goal is to slow down certain processes and execute them sequentially in ...
Alessandro Abruzzo's user avatar
0 votes
0 answers
15 views

Wildfly CLI - "jms-queue" not in the command list

I'm trying to build a CLI script to configure my WildFly 29 server. The Wildfly starts with the standard standalone.xml. But after starting the script I get the message that the command jms-queue is ...
Net_Hans's user avatar
  • 135
0 votes
1 answer
85 views

"java.lang.IllegalStateException: Failed to introspect Class [com.app.api.config.JmsConfig] from ClassLoader.." at springboot startup

I am trying to deploy my springboot application on a tomcat server, compiling it in a .war, when starting the project I receive the following error Caused by: java.lang.IllegalStateException: Failed ...
Mauro Pandolfo's user avatar
0 votes
2 answers
34 views

How to do JMS performance testing with JMeter?

I'm using @JmsListener annotation to fetch logs from Azure service bus queue and later saving it into Elasticsearch. I need to conduct performance testing using JMeter. There's no http endpoint. I'm ...
Cdac15655482's user avatar
0 votes
0 answers
30 views

WildFly MDB continues to consume messages after graceful shutdown has initiated

When I gracefully shutdown WildFly my MDBs continue to consume messages from our ActiveMQ queue. Then the thread will die to an exception thrown by WildFly. Our current workaround solution is to ...
canEE's user avatar
  • 5
-1 votes
0 answers
34 views

Consume Camel JMS queue with username and password throws SingleConnectionFactory error

When I try to consume from a JMS queue programmatically everything works fine, but when I try to use Apache Camel I always get the following error: [Camel (camel-1) thread #1 - JmsConsumer[MySyncQueue]...
Zeussi's user avatar
  • 569
0 votes
2 answers
36 views

WildFly JMS topic consumer receives null value

I am using WildFly 19 and a JMS topic application. After running this program it returns a null value. try { final Properties env = new Properties(); env.put(Context.INITIAL_CONTEXT_FACTORY, &...
Masum Mia's user avatar
1 vote
1 answer
109 views

WildFly JMS error: does not have permission='CONSUME' for queue jms.queue.exampleQueue

I am using WildFly 19 and a JMS application. After running this program it gives bellow error: AMQ229213: User: murad does not have permission='CONSUME' for queue jms.queue.exampleQueue on address jms....
Gulam Samdani's user avatar
1 vote
0 answers
46 views

RabbitMQ cannot bind JMS exchange to queue

I face an odd issue when I bind an x-jms-topic exchange to a queue using the JMS plugin rabbitmq_jms_topic_exchange as RabbitMQ is not a JMS provider. I face the issue that neither the UI nor the ...
Nikolas Charalambidis's user avatar
-1 votes
1 answer
29 views

Move single message into different queue using github.com/fmtn/a

I have an JMS setup using ActiveMQ 5.13.4 with several dead letter queues (DLQ), and I want to move specific messages from the DLQ back into the original queue so that my app can process them again ...
zoomzoomvince's user avatar
0 votes
0 answers
29 views

Jms connection timeout

I'm using jms to publish messages to Azure service bus and jmsListener to fetch published data from service bus. Sometimes I come across below error: Caused by: org.apache.qpid.jms.provider.exceptions....
Cdac15655482's user avatar
0 votes
1 answer
17 views

How to handle jmsTemplate.receive no response case

I'm using jmsTemplate.receive("queueName") to receive data from service bus queue. I'm using it as an API request. One issue I'm facing is if no message left to process from the queue it's ...
Cdac15655482's user avatar
0 votes
0 answers
25 views

JmsListener - Receive message from topic

Is there any way to receive message from service bus topic without using the @JmsListener annotation? The issue with using the @JmsListener and @EnableJms annotations is that as soon as I start the ...
Cdac15655482's user avatar
0 votes
1 answer
33 views

JmsListener listen generic container object

I'm doing an event based system which consists of multiple services that communicate via kind of domain events. All services are on spring boot 3.1.3 and send messages via activemq artemis. I've got ...
mr.nothing's user avatar
  • 5,220
0 votes
0 answers
32 views

Error JMSCMQ1049 in JMS message received in listener - IBM MQ

I'm creating a Listener with Java 17, driver IBM MQ Jakarta.client version 9.3.3.0, Spring Boot 3. I would like to know if anyone has experienced this. I receive a message that I cannot deal with, and ...
CÉSAR SANTOS's user avatar
0 votes
0 answers
72 views

Same ClientID required on Subscription

How to start two subscription topics with same clientID in tomcat setup. Currently, I have started topic with different clientID on two servers and getting two messages which is correct behavior Topic ...
user17745726's user avatar
0 votes
0 answers
24 views

Update ActiveMQ Artemis client libraries in JBoss EAP 7.4

JMS servers: ActiveMQ Artemis cluster - version 2.28.0 JMS clients: Apache Camel routes embedded in JBoss EAP 7.4 application servers What is the recommended/appropriate way to update the ActiveMQ ...
Surjit Sen's user avatar
0 votes
1 answer
47 views

Implementing simple transactions with Apache Camel and ActiveMQ Artemis

I am trying to implement a simple JMS Camel route that reads from a ActiveMQ Artemis queue. This route needs to be transacted to avoid message loss in case of application crashes or other unforeseen ...
worldbeater's user avatar
0 votes
1 answer
54 views

ApacheMQ 5.18.2 resource adapter on Wildfly 29 not working

I'm trying to use the resource adapter for Apache ActiveMQ 5.18.2 on a wildfly 29 application server. However, it seems to not be working, throwing errors when I deploy the rar-file. Looking at the ra....
JohnRun's user avatar
  • 11
0 votes
0 answers
24 views

Correlation between a single HTTP request and multiple JMS messages

Service A receives an HTTP request. If the request already has a request id the service will use it, otherwise the service will generate one. At this point the request id is guaranteed to exist and ...
Attila T's user avatar
  • 598
0 votes
1 answer
85 views

Setup messaging subsystem using ActiveMQ in WildFly

I'm trying to enable ActiveMQ from WildFly 30 (I need MQTT support), but I'm having a problem even when trying to add a server: [standalone@localhost:9990 /] /subsystem=messaging-activemq/server=...
mr mcwolf's user avatar
  • 2,644
0 votes
1 answer
63 views

Cannot see Pub/Sub message on ActiveMQ Artemis console

I'm studying JMS using the book Spring Boot Messaging by Felipe Gutierrez (2017). It illustrates several patterns about message driven programming but, arriving at brokers, it explain Java / Spring ...
CoderJammer's user avatar
0 votes
0 answers
54 views

Injected JMS ConnectionFactory is null in simple JMS example using ActiveMQ Artemis with OpenLiberty

I am trying to create a simple JMS example application using ActiveMQ Artemis but I am having issues with my Connection Factory that returns null. Below I am giving you my code, so far, as well as the ...
Alex_Pap's user avatar
  • 316
0 votes
0 answers
28 views

JMS message sent with JMSXGroupId to ActiveMQ Artemis queue on one server in a cluster does not get delivered to consumer connected to another server

A JMS message with JMSXGroupId sent to a dynamic queue on ActiveMQ Artemis server from Java code (JDK 11) does not get delivered to consumer connected to another server. Is this normal behavior? Is ...
Surjit Sen's user avatar
0 votes
0 answers
89 views

Java 17 java.lang.reflect.InaccessibleObjectException with new InitialContext()

I was having a client to put messages on a JMS queue in Java 8 using the following code. I anonymized the code a bit. public class Application { public static void main(String[] args) throws ...
wouter's user avatar
  • 1
0 votes
2 answers
53 views

IBM MQ JMS selector using a list of values

I'm encountering a situation for which I can't find any other examples on the Internet, and I was wondering if anyone had any idea about this. Basically, we need to use a selector a Spring JmsListener ...
Ginel Guiu's user avatar
1 vote
0 answers
71 views

Spring Boot JmsListener not reading from IBM MQ after service inactive for long periods (e.g. 1 month)

I am facing an issue where the listener is not reading messages from IBM MQ after the service being inactive for a long period, probably like a month or so. Below is a warning from Tomcat's log ...
athul rajesh's user avatar
0 votes
1 answer
45 views

How to get queue length in ActiveMQ Artemis?

I have a code where I get the queue length, but on the browse method. How can I get the queue length, but on consumer via JMS? If not via JMS, then maybe via some other class from another package? I'm ...
PingvinAnbu's user avatar
0 votes
0 answers
36 views

ActiveMQBytesMessage writeBytes not working, message not sent

I'm trying to send a message to ActiveMQ "Classic" 5.7.0. However, it doesn't seem to reach its target even though there is no error message or anything indicating what went wrong. ...
Noel93's user avatar
  • 136
0 votes
0 answers
84 views

Quarkus Opentelemetry - Trace propagation

Our application has a flow that involves messaging and REST calls. Flow looks like serviceA -> message -> ServiceB -> REST -> ServiceC -> REST -> ServiceD When the OpenTelemetry is ...
sg2000's user avatar
  • 91
0 votes
0 answers
75 views

Mulesoft not setting JMS type when publishing to Oracle queue

I am publishing a message to an Oracle queue through JMS, and I am receiving this error: JMS-108: Messages of type TextMessage not allowed with Destinations containing payload of type SYS.XMLTYPE I ...
Mishael Harrison's user avatar
0 votes
1 answer
45 views

Seedstack JMS listener enable disable from properties file

I have 4 JMS listener classes. Sometimes I need to stop a listener (e.g. if the queue attached to this listener is not working). Is there any way to stop the listener from properties file using some ...
user432843's user avatar
0 votes
0 answers
64 views

Robot Framework JMS Library Test

I've seen the only chance I have to make Robot tests consume from JMS queues is to use this library, but I don't understand how it is supposed to work. When I install a Robot library I do it through ...
Maurizio Cimino's user avatar
0 votes
0 answers
48 views

Intermittently application is not able to send message on ActiceMQ "Classic" due to javax.jms.JMSException: Could not connect to broker URL

The application uses pooled JMS connection. On startup the application is working fine, but after a couple of days it is not able to send messages to ActiveMQ "Classic." As soon as the ...
Prabhjot Sokhi's user avatar
-2 votes
1 answer
77 views

How to send a custom object using JMS & ActiveMQ "Classic" in Spring Boot?

I'm trying to send an ObjectMessage using ActiveMQ "Classic." For this purpose I created two Spring Boot projects - customer and producer. I use the code below to sent from producer. @...
bro's user avatar
  • 11
-1 votes
1 answer
47 views

How to get message properties in ActiveMQ Artemis broker queue via JMS?

I have a code that gets the property name _AMQ_LARGE_SIZE, but I don't understand how I can get all the headers. ArrayList<Message> messages = new ArrayList<>(); Enumeration propertyNames =...
Limbarunda's user avatar
0 votes
1 answer
32 views

How to adapt JMS code to ActiveMQ Artemis code?

I have code that simply reads a queue and receives JMS Message class objects. But this class does not have many getters, such as getPersistenSize and others. I found the answer to my question about ...
Vanish's user avatar
  • 127
0 votes
1 answer
31 views

How do I get LargeMessage in ActiveMQ Artemis queue via JMS?

I can't figure out how to get LargeMessage in an Artemis ActiveMQ queue using JMS. I didn't find any get method in the Message class. There are different methods for getting message ID, lifetime and ...
Vanish's user avatar
  • 127
0 votes
1 answer
35 views

How to get protocol in ActiveMQ Artemis via JMS?

I'm sending a message to an Artemis ActiveMQ queue, but I can't find a method to get the message protocol Code for receiving the body of the message, but in this class I did not find a method for ...
Vanish's user avatar
  • 127
0 votes
1 answer
295 views

IBM MQ call failed with compcode '2' ('MQCC_FAILED') reason '2009' ('MQRC_CONNECTION_BROKEN')

I'm getting this error till there was no publisher to the topic. As soon as there was a publisher and the message started to get published on the topic, the JMS listener was actively listening and the ...
ahmetyavuzoruc's user avatar
-1 votes
1 answer
105 views

How to get the body of a byte message in JMS ActiveMQ Artemis?

I have a code that gets a message from a JMS queue, but I don't understand how to get the body of the message if it is a byte and translate it into a String: connectQueueBrowser(); Enumeration<...
Vanish's user avatar
  • 127
0 votes
1 answer
100 views

How do I configure WildFly's messaging-activemq subsystem to create JMS connections using the server hostname rather than an IP address?

I have an application running on WildFly 26.1.3 that I've been securing to use only HTTPS. I've got almost everything sorted out, except for the JMS connections generated by the messaging-activemq ...
Psirax's user avatar
  • 51
0 votes
1 answer
34 views

How do I get persistentSize in ActiveMQ Artemis queue via JMS?

I can't figure out how to get persistentSize in an Artemis ActiveMQ queue using JMS. I didn't find any get method in the Message class. There are different methods for getting message ID, lifetime and ...
Vanish's user avatar
  • 127
1 vote
1 answer
37 views

How to get JMSType in ActiveMQ Artemis via JMS?

I have code that looks at a message and tells me its type (text or byte). I don't understand why my message type outputs null and not text or byte. Enumeration<Message> messageEnumeration = ...
Vanish's user avatar
  • 127
0 votes
1 answer
29 views

How to get a queue from a consumer in JMS?

I have a code that gets a queue from browse, but I can't find a method that gets a queue from a consumer.Is it possible to get a queue from the consumer? Method for getting a queue from browse: ...
Vanish's user avatar
  • 127
0 votes
1 answer
73 views

How to view the messageId of a message in ActiveMQ Artemis?

I'm using a QueueBrowser to get a message from the queue, but I can't get the messageId. For some reason my userId is displayed private void viewMessage() throws NamingException, JMSException { ...
Vanish's user avatar
  • 127
0 votes
0 answers
53 views

JMS message sent to Artemis queue from JBoss 7.4.2 does not get delivered to Camel route using JMS component

A JMS message sent to a dynamic queue on Artemis server in JBoss EAP 7.4.2 does not get delivered to Camel route listener using JMS component Camel route: from("jms:queue:XXX") .process(&...
Surjit Sen's user avatar
0 votes
1 answer
55 views

Is it possible to get all messages from a queue via JMS without deleting them from the queue?

I would like to know if it is possible to get the messages from a queue through JMS without removing them. There is a browse() method in JMX, but is there a similar method in JMS?
Vanish's user avatar
  • 127
0 votes
1 answer
74 views

How to consume JMS messages from the middle or end of the queue?

I have a code that hangs a reader on a queue and receives a message when the method completes. I want to receive messages not from the beginning of the queue but from the end or from the middle ...
Vanish's user avatar
  • 127
0 votes
1 answer
85 views

Error reading message from ActiveMQ Artemis queue

I want to subtract the last message from an ActiveMQ Artemis queue. I have a lot of messages in the queue and when I read one message, the rest just disappear, but the message counter in the broker ...
Vanish's user avatar
  • 127

1
2 3 4 5
152