From 3d62ef5819619ffcff00f04d9db8e6c663aa7d03 Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Sun, 7 Jul 2019 12:46:31 +0100
Subject: [PATCH] Switch to broker.Event

---
 subscriber.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/subscriber.go b/subscriber.go
index 1191c86..39fd332 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -183,7 +183,7 @@ func validateSubscriber(sub server.Subscriber) error {
 }
 
 func (s *httpServer) createSubHandler(sb *httpSubscriber, opts server.Options) broker.Handler {
-	return func(p broker.Publication) error {
+	return func(p broker.Event) error {
 		msg := p.Message()
 		ct := msg.Header["Content-Type"]
 		cf, err := s.newCodec(ct)
@@ -220,7 +220,7 @@ func (s *httpServer) createSubHandler(sb *httpSubscriber, opts server.Options) b
 			co := cf(b)
 			defer co.Close()
 
-			if err := co.ReadHeader(&codec.Message{}, codec.Publication); err != nil {
+			if err := co.ReadHeader(&codec.Message{}, codec.Event); err != nil {
 				return err
 			}