From 67e66c0e5a2dbcff8c809a523ba7936883dc35ef Mon Sep 17 00:00:00 2001 From: Joachim Bauch Date: Thu, 24 Sep 2020 12:43:27 +0200 Subject: [PATCH] Log something when proxy publisher/subscriber is deleted. --- src/signaling/mcu_proxy.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/signaling/mcu_proxy.go b/src/signaling/mcu_proxy.go index 9cd4b5c..d53aa97 100644 --- a/src/signaling/mcu_proxy.go +++ b/src/signaling/mcu_proxy.go @@ -149,6 +149,8 @@ func (p *mcuProxyPublisher) Close(ctx context.Context) { log.Printf("Could not delete publisher %s at %s: %s", p.proxyId, p.conn.url, err) return } + + log.Printf("Delete publisher %s at %s", p.proxyId, p.conn.url) } func (p *mcuProxyPublisher) SendMessage(ctx context.Context, message *MessageClientMessage, data *MessageClientMessageData, callback func(error, map[string]interface{})) { @@ -222,6 +224,8 @@ func (s *mcuProxySubscriber) Close(ctx context.Context) { log.Printf("Could not delete subscriber %s at %s: %s", s.proxyId, s.conn.url, err) return } + + log.Printf("Delete subscriber %s at %s", s.proxyId, s.conn.url) } func (s *mcuProxySubscriber) SendMessage(ctx context.Context, message *MessageClientMessage, data *MessageClientMessageData, callback func(error, map[string]interface{})) {