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
 	}