From 86984a8a8a2e37d6ae4de6bd3d6b0422361d9cf2 Mon Sep 17 00:00:00 2001
From: Asim Aslam <asim@aslam.me>
Date: Fri, 4 Oct 2019 16:44:21 +0100
Subject: [PATCH] Extend the stream timeout

---
 broker/service/service.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/broker/service/service.go b/broker/service/service.go
index b2fb1bd1..fff207fd 100644
--- a/broker/service/service.go
+++ b/broker/service/service.go
@@ -65,7 +65,7 @@ func (b *serviceBroker) Subscribe(topic string, handler broker.Handler, opts ...
 	stream, err := b.Client.Subscribe(context.TODO(), &pb.SubscribeRequest{
 		Topic: topic,
 		Queue: options.Queue,
-	}, client.WithAddress(b.Addrs...))
+	}, client.WithAddress(b.Addrs...), client.WithRequestTimeout(time.Hour))
 	if err != nil {
 		return nil, err
 	}
@@ -93,7 +93,7 @@ func (b *serviceBroker) Subscribe(topic string, handler broker.Handler, opts ...
 					stream, err := b.Client.Subscribe(context.TODO(), &pb.SubscribeRequest{
 						Topic: topic,
 						Queue: options.Queue,
-					}, client.WithAddress(b.Addrs...))
+					}, client.WithAddress(b.Addrs...), client.WithRequestTimeout(time.Hour))
 					if err != nil {
 						log.Debugf("Failed to resubscribe to topic %s: %v", topic, err)
 						time.Sleep(time.Second)