From 173f7107e2212d1962ee29415f801ad19c22738a Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Sat, 14 Apr 2018 18:26:54 +0100 Subject: [PATCH] remove broker default funcs --- broker/broker.go | 24 ------------------------ 1 file changed, 24 deletions(-) diff --git a/broker/broker.go b/broker/broker.go index 39db9f17..d1dccaeb 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -44,27 +44,3 @@ var ( func NewBroker(opts ...Option) Broker { return newHttpBroker(opts...) } - -func Init(opts ...Option) error { - return DefaultBroker.Init(opts...) -} - -func Connect() error { - return DefaultBroker.Connect() -} - -func Disconnect() error { - return DefaultBroker.Disconnect() -} - -func Publish(topic string, msg *Message, opts ...PublishOption) error { - return DefaultBroker.Publish(topic, msg, opts...) -} - -func Subscribe(topic string, handler Handler, opts ...SubscribeOption) (Subscriber, error) { - return DefaultBroker.Subscribe(topic, handler, opts...) -} - -func String() string { - return DefaultBroker.String() -}