Log session id when creating publish/subscriber.

This commit is contained in:
Joachim Bauch 2020-09-16 16:51:11 +02:00
parent 7e3a7af9a3
commit 76f327b919
Failed to extract signature
1 changed files with 2 additions and 2 deletions

View File

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