R2.0.2

Minor patch to properly handle message producer unexpected session terminate state in SolacePublishingService.
solacese · Mar 19, 2024 · 0131d59 · 0131d59
1 parent ca450c7
commit 0131d59
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.solace.swim</groupId>
 	<artifactId>swim-feed-handler</artifactId>
-	<version>2.0.1</version>
+	<version>2.0.2</version>
 	<name>swim-feed-handler</name>
 	<description>SWIM Feed Handler Spring Boot Application</description>
 

diff --git a/src/main/java/com/solace/swim/service/publish/SolacePublishingService.java b/src/main/java/com/solace/swim/service/publish/SolacePublishingService.java
@@ -163,7 +163,16 @@ public void invoke(Message<?> message) {
 
             properties = null;
             logger.info("Published message id {} to topic {}.", message.getHeaders().get("jms_messageId"), topic.getName());
-        } catch (Exception ex) {
+        } catch (IllegalStateException ex) {
+            logger.error("Error in state of publisher. Trying to recover...");
+            if (!messagePublisher.isTerminated()) {
+                messagePublisher.terminate(100);
+            }
+            messagingService.disconnect();
+            init();
+            invoke(message);
+        }
+        catch (Exception ex) {
             logger.error("Unable to send message", ex);
         }
     }