fix problem when no responseBody is provided

IBM · Feb 20, 2020 · 9ef5c3b · 9ef5c3b
1 parent 1cf58af
commit 9ef5c3b
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/broker.go b/broker.go
@@ -765,7 +765,13 @@ func (b *Broker) send(rb protocolBody, promiseResponse bool, responseHeaderVersi
 }
 
 func (b *Broker) sendAndReceive(req protocolBody, res protocolBody) error {
-	promise, err := b.send(req, res != nil, res.headerVersion())
+
+	responseHeaderVersion := int16(-1)
+	if res != nil {
+		responseHeaderVersion = res.headerVersion()
+	}
+
+	promise, err := b.send(req, res != nil, responseHeaderVersion)
 	if err != nil {
 		return err
 	}