Fix for stomp-php - Use one connection for each message.

atrauzzi · atrauzzi · commit 2a0545c15a39 · 2020-09-30T11:55:53.000-05:00
diff --git a/pkg/stomp/StompProducer.php b/pkg/stomp/StompProducer.php
@@ -47,10 +47,12 @@ public function send(Destination $destination, Message $message): void
                 throw $ex;
             }
 
-            $this->stomp->disconnect(true);
+            $this->stomp->disconnect();
             $this->stomp->connect();
 
             $this->stomp->send($destination->getQueueName(), $stompMessage);
+        } finally {
+            $this->stomp->disconnect();
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -47,10 +47,12 @@ public function send(Destination $destination, Message $message): void`
`47`	`47`	`throw $ex;`
`48`	`48`	`}`
`49`	`49`
`50`		`- $this->stomp->disconnect(true);`
	`50`	`+ $this->stomp->disconnect();`
`51`	`51`	`$this->stomp->connect();`
`52`	`52`
`53`	`53`	`$this->stomp->send($destination->getQueueName(), $stompMessage);`
	`54`	`+ } finally {`
	`55`	`+ $this->stomp->disconnect();`
`54`	`56`	`}`
`55`	`57`	`}`
`56`	`58`