From 76f327b9199b31a7ae2433961a3b7ba0c1250fb0 Mon Sep 17 00:00:00 2001 From: Joachim Bauch Date: Wed, 16 Sep 2020 16:51:11 +0200 Subject: [PATCH] Log session id when creating publish/subscriber. --- src/proxy/proxy_server.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/proxy/proxy_server.go b/src/proxy/proxy_server.go index 3a22da9..d69fc56 100644 --- a/src/proxy/proxy_server.go +++ b/src/proxy/proxy_server.go @@ -639,7 +639,7 @@ func (s *ProxyServer) processCommand(ctx context.Context, client *ProxyClient, s return } - log.Printf("Created %s publisher %s as %s", cmd.StreamType, publisher.Id(), id) + log.Printf("Created %s publisher %s as %s for %s", cmd.StreamType, publisher.Id(), id, session.PublicId()) session.StorePublisher(ctx, id, publisher) s.StoreClient(id, publisher) @@ -665,7 +665,7 @@ func (s *ProxyServer) processCommand(ctx context.Context, client *ProxyClient, s return } - log.Printf("Created %s subscriber %s as %s", cmd.StreamType, subscriber.Id(), id) + log.Printf("Created %s subscriber %s as %s for %s", cmd.StreamType, subscriber.Id(), id, session.PublicId()) session.StoreSubscriber(ctx, id, subscriber) s.StoreClient(id, subscriber)