:fix: service events remove durable subscriptions

Signed-off-by: riccardomodanese <riccardo.modanese@eurotech.com>
eclipse · Apr 17, 2024 · 144bc00 · 144bc00
1 parent 0d289f9
commit 144bc00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/commons/src/main/java/org/eclipse/kapua/commons/event/jms/JMSServiceEventBus.java b/commons/src/main/java/org/eclipse/kapua/commons/event/jms/JMSServiceEventBus.java
@@ -319,7 +319,7 @@ synchronized void subscribe(Subscription subscription)
  final Session jmsSession = jmsConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  Topic jmsTopic = jmsSession.createTopic(subscriptionStr);
  for (int i = 0; i < consumerPoolSize; i++) {
- MessageConsumer jmsConsumer = jmsSession.createSharedDurableConsumer(jmsTopic, subscription.getName());
+ MessageConsumer jmsConsumer = jmsSession.createSharedConsumer(jmsTopic, subscription.getName());
  jmsConsumer.setMessageListener(message -> {
  try {
  if (message instanceof TextMessage) {