On initializing RabbitMQ connection close old connection if available.

objectscript · Mar 14, 2020 · e4c3135 · e4c3135
1 parent 11ad4a4
commit e4c3135
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/isc/rabbitmq/Common.cls b/isc/rabbitmq/Common.cls
@@ -90,6 +90,11 @@ Method ConnectToRabbitMQ() As %Status
 	}
 
 	Try {
+		If $IsObject(..API) {
+			Do ..API.close()
+			Set ..API = $$$NULLOREF
+		}
+
 		Set ..API = ##class(isc.rabbitmq.API).%New(..JGW, ..Host, ..Port, user, pass, ..VirtualHost, ..Queue, $$$YES, ..Exchange)
 	} Catch ex {
 		Set sc = ..ExceptionToStatus(ex)