diff --git a/messages/publish.go b/messages/publish.go index 7f254e2..6abdaac 100644 --- a/messages/publish.go +++ b/messages/publish.go @@ -100,7 +100,7 @@ func (e *Publish) Parse(wampMsg []any) error { e.PublishFields = &publishFields{ requestID: fields.RequestID, - topic: fields.Topic, + topic: fields.URI, args: fields.Args, kwArgs: fields.KwArgs, } diff --git a/messages/subscribe.go b/messages/subscribe.go index 248a9d1..62b26b2 100644 --- a/messages/subscribe.go +++ b/messages/subscribe.go @@ -66,7 +66,7 @@ func (s *Subscribe) Parse(wampMsg []any) error { return fmt.Errorf("subscribe: failed to validate message %s: %w", MessageNameSubscribe, err) } - s.SubscribeFields = &subscribeFields{requestID: fields.RequestID, options: fields.Options, topic: fields.Topic} + s.SubscribeFields = &subscribeFields{requestID: fields.RequestID, options: fields.Options, topic: fields.URI} return nil } diff --git a/messages/validator.go b/messages/validator.go index f773bc6..5a9c96f 100644 --- a/messages/validator.go +++ b/messages/validator.go @@ -37,7 +37,6 @@ type Fields struct { MessageType int64 Signature string Reason string - Topic string Extra map[string]any Options map[string]any