diff --git a/broker/websocket/examples/dequeue/typed/websocket.go b/broker/websocket/examples/dequeue/typed/websocket.go
index 3eab205..2c82290 100644
--- a/broker/websocket/examples/dequeue/typed/websocket.go
+++ b/broker/websocket/examples/dequeue/typed/websocket.go
@@ -50,8 +50,6 @@ func (a *actor) handle(rcv <-chan swarm.Msg[User], ack chan<- swarm.Msg[User]) {
 	for msg := range rcv {
 		slog.Info("Event user", "data", msg.Object)
 
-		websocket.PrincipalOf(msg)
-
 		if err := a.emit.Enq(context.Background(), msg.Object, msg.Digest); err != nil {
 			ack <- msg.Fail(err)
 			continue