From 618becbf534cde4948426a35ad66cf32f4e88f04 Mon Sep 17 00:00:00 2001
From: deadprogram <ron@hybridgroup.com>
Date: Mon, 3 Nov 2014 23:27:21 -0800
Subject: [PATCH] Keep it simple, validate later

---
 platforms/mqtt/mqtt_adaptor.go | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/platforms/mqtt/mqtt_adaptor.go b/platforms/mqtt/mqtt_adaptor.go
index 6da8f0ac..56d8021a 100644
--- a/platforms/mqtt/mqtt_adaptor.go
+++ b/platforms/mqtt/mqtt_adaptor.go
@@ -1,10 +1,8 @@
 package mqtt
 
 import (
-	"fmt"
 	"git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git"
 	"github.com/hybridgroup/gobot"
-	"net/url"
 )
 
 type MqttAdaptor struct {
@@ -51,10 +49,9 @@ func (a *MqttAdaptor) Finalize() bool {
 	return true
 }
 
-func (a *MqttAdaptor) Publish(topic string, message []byte) int {
+func (a *MqttAdaptor) Publish(topic string, message []byte) {
 	m := mqtt.NewMessage(message)
 	a.client.PublishMessage(topic, m)
-	return 0
 }
 
 func (a *MqttAdaptor) On(event string, f func(s interface{})) {
@@ -65,9 +62,8 @@ func (a *MqttAdaptor) On(event string, f func(s interface{})) {
 }
 
 func createClientOptions(clientId, raw string) *mqtt.ClientOptions {
-	uri, _ := url.Parse(raw)
 	opts := mqtt.NewClientOptions()
-	opts.AddBroker(fmt.Sprintf("tcp://%s", uri.Host))
+	opts.AddBroker(raw)
 	opts.SetClientId(clientId)
 
 	return opts