From 0075477df0679734a64c10b31069f7d65bec8419 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Wed, 4 Sep 2019 12:18:31 +0100 Subject: [PATCH] make tunnel broker use multicast --- tunnel/broker/broker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tunnel/broker/broker.go b/tunnel/broker/broker.go index 0a33c610..6778dfaa 100644 --- a/tunnel/broker/broker.go +++ b/tunnel/broker/broker.go @@ -58,7 +58,7 @@ func (t *tunBroker) Disconnect() error { func (t *tunBroker) Publish(topic string, m *broker.Message, opts ...broker.PublishOption) error { // TODO: this is probably inefficient, we might want to just maintain an open connection // it may be easier to add broadcast to the tunnel - c, err := t.tunnel.Dial(topic) + c, err := t.tunnel.Dial(topic, tunnel.DialMulticast()) if err != nil { return err }