From 79b03a6825d9630bb6ac605c05e5e5a765ed480c Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Sun, 7 Jul 2019 12:36:14 +0100
Subject: [PATCH] add broker args

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

diff --git a/broker/broker.go b/broker/broker.go
index 31013784..28fe953a 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -7,8 +7,8 @@ type Broker interface {
 	Options() Options
 	Connect() error
 	Disconnect() error
-	Publish(string, *Message, ...PublishOption) error
-	Subscribe(string, Handler, ...SubscribeOption) (Subscriber, error)
+	Publish(topic string, m *Message, opts ...PublishOption) error
+	Subscribe(topic string, h Handler, opts ...SubscribeOption) (Subscriber, error)
 	String() string
 }