Log something when proxy publisher/subscriber is deleted.

This commit is contained in:
Joachim Bauch 2020-09-24 12:43:27 +02:00
parent 76f327b919
commit 67e66c0e5a
No known key found for this signature in database
GPG Key ID: 77C1D22D53E15F02
1 changed files with 4 additions and 0 deletions

View File

@ -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{})) {