diff --git a/clientsession.go b/clientsession.go index 61c83fe..59a3d8f 100644 --- a/clientsession.go +++ b/clientsession.go @@ -857,6 +857,7 @@ func (s *ClientSession) processNatsMessage(msg *NatsMessage) *ServerMessage { } else if msg.Message.Event.Target == "room" { // Can happen mostly during tests where an older room NATS message // could be received by a subscriber that joined after it was sent. + log.Printf("Message %+v was sent at %s, room joined at %s", msg.Message, msg.SendTime, s.getRoomJoinTime()) if msg.SendTime.Before(s.getRoomJoinTime()) { log.Printf("Message %+v was sent before room was joined, ignoring", msg.Message) return nil diff --git a/natsclient_loopback.go b/natsclient_loopback.go index aaa1699..c13eb6e 100644 --- a/natsclient_loopback.go +++ b/natsclient_loopback.go @@ -175,8 +175,10 @@ func (c *LoopbackNatsClient) PublishNats(subject string, message *NatsMessage) e } func (c *LoopbackNatsClient) PublishMessage(subject string, message *ServerMessage) error { + now := time.Now() + log.Printf("Send message at %s: %+v", now, message) msg := &NatsMessage{ - SendTime: time.Now(), + SendTime: now, Type: "message", Message: message, } @@ -184,8 +186,10 @@ func (c *LoopbackNatsClient) PublishMessage(subject string, message *ServerMessa } func (c *LoopbackNatsClient) PublishBackendServerRoomRequest(subject string, message *BackendServerRoomRequest) error { + now := time.Now() + log.Printf("Send message at %s: %+v", now, message) msg := &NatsMessage{ - SendTime: time.Now(), + SendTime: now, Type: "room", Room: message, }