:fix: service events remove durable subscriptions

Signed-off-by: riccardomodanese <riccardo.modanese@eurotech.com>
eclipse · May 15, 2024 · 7f52653 · 7f52653
1 parent c215cc9
commit 7f52653
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) {