diff --git a/pubsub.go b/pubsub.go
index 7237259..d8fc964 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -446,6 +446,7 @@ func (p *PubSub) processLoop(ctx context.Context) {
 			p.handleIncomingRPC(rpc)
 
 		case msg := <-p.publish:
+			p.tracer.PublishMessage(msg)
 			p.pushMsg(msg)
 
 		case msg := <-p.sendMsg:
diff --git a/trace.go b/trace.go
index 08ec219..fc24f76 100644
--- a/trace.go
+++ b/trace.go
@@ -14,6 +14,12 @@ type pubsubTracer struct {
 	tracer EventTracer
 }
 
+func (t *pubsubTracer) PublishMessage(msg *Message) {
+	if t != nil {
+		// TODO
+	}
+}
+
 func (t *pubsubTracer) RejectMessage(msg *Message, reason string) {
 	if t != nil {
 		// TODO