From 92082ac9271477895e3d793f82d95578b1b7f51d Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Fri, 30 Nov 2018 17:32:48 +0000
Subject: [PATCH] NewSubscribeOptions

---
 broker/http_broker.go | 2 +-
 broker/options.go     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/broker/http_broker.go b/broker/http_broker.go
index dad8ed6c..a761a197 100644
--- a/broker/http_broker.go
+++ b/broker/http_broker.go
@@ -523,7 +523,7 @@ func (h *httpBroker) Publish(topic string, msg *Message, opts ...PublishOption)
 }
 
 func (h *httpBroker) Subscribe(topic string, handler Handler, opts ...SubscribeOption) (Subscriber, error) {
-	options := newSubscribeOptions(opts...)
+	options := NewSubscribeOptions(opts...)
 
 	// parse address for host, port
 	parts := strings.Split(h.Address(), ":")
diff --git a/broker/options.go b/broker/options.go
index 46136ac9..ae55ede1 100644
--- a/broker/options.go
+++ b/broker/options.go
@@ -50,7 +50,7 @@ var (
 	registryKey = contextKeyT("github.com/micro/go-micro/registry")
 )
 
-func newSubscribeOptions(opts ...SubscribeOption) SubscribeOptions {
+func NewSubscribeOptions(opts ...SubscribeOption) SubscribeOptions {
 	opt := SubscribeOptions{
 		AutoAck: true,
 	}