Skip to content

Commit

Permalink
Log session id when creating publish/subscriber.
Browse files Browse the repository at this point in the history
  • Loading branch information
fancycode committed Sep 16, 2020
1 parent 7e3a7af commit 76f327b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/proxy/proxy_server.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)

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

Expand Down

0 comments on commit 76f327b

Please sign in to comment.