Updated pub/publish

vishr · vishr · commit ba034fb3ef73 · 2018-06-02T17:56:15.000-07:00
Signed-off-by: Vishal Rana &lt;vr@labstack.com&gt;
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/Gopkg.toml b/Gopkg.toml
@@ -25,9 +25,13 @@
 #   unused-packages = true
 
 
+[[constraint]]
+  name = "github.com/eclipse/paho.mqtt.golang"
+  version = "1.1.1"
+
 [[constraint]]
   name = "github.com/go-resty/resty"
-  version = "1.5.0"
+  version = "1.6.0"
 
 [[constraint]]
   name = "github.com/labstack/echo"
@@ -44,7 +48,3 @@
 [prune]
   go-tests = true
   unused-packages = true
-
-[[constraint]]
-  name = "github.com/eclipse/paho.mqtt.golang"
-  version = "1.1.1"
diff --git a/hub/hub.go b/hub/hub.go
@@ -70,7 +70,7 @@ func (h *Hub) ConnectWithHandler(handler ConnectHandler) error {
 	return t.Error()
 }
 
-func (h *Hub) Publish(topic string, message []byte) error {
+func (h *Hub) Publish(topic string, message interface{}) error {
 	t := h.client.Publish(h.normalizeTopic(topic), 0, false, message)
 	t.Wait()
 	return t.Error()

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,7 @@ func (h *Hub) ConnectWithHandler(handler ConnectHandler) error {`
`70`	`70`	`return t.Error()`
`71`	`71`	`}`
`72`	`72`
`73`		`-func (h *Hub) Publish(topic string, message []byte) error {`
	`73`	`+func (h *Hub) Publish(topic string, message interface{}) error {`
`74`	`74`	`t := h.client.Publish(h.normalizeTopic(topic), 0, false, message)`
`75`	`75`	`t.Wait()`
`76`	`76`	`return t.Error()`