change default device
This commit is contained in:
+3
-1
@@ -56,5 +56,7 @@ func PulsarSend(data string) error {
|
||||
|
||||
func ClosePulsar() {
|
||||
producer.Close()
|
||||
client.Close()
|
||||
if client != nil {
|
||||
client.Close()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user