From decef80a3fdbca581802c603e56e9ee38c2f288e Mon Sep 17 00:00:00 2001
From: hpitkeathly <hpitkeathly@thoughtmachine.net>
Date: Thu, 26 Oct 2023 13:56:40 +0100
Subject: [PATCH] Fix bug in api server

---
 ChangeLog         | 6 +++++-
 VERSION           | 2 +-
 mettle/api/api.go | 7 ++++---
 3 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/ChangeLog b/ChangeLog
index 44222a14..4234d689 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,4 +1,8 @@
-Version 11.4.1
+Version 11.4.2
+--------------
+    * Fix bug in api server 
+
+Version 11.4.2
 --------------
     * Fix bug in api server 
 
diff --git a/VERSION b/VERSION
index a6e5b12f..3a3e396b 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-11.4.1
+11.4.2
diff --git a/mettle/api/api.go b/mettle/api/api.go
index f54bbc2d..5541d5cf 100644
--- a/mettle/api/api.go
+++ b/mettle/api/api.go
@@ -148,12 +148,13 @@ func serve(opts grpcutil.Opts, name string, queueOpts PubSubOpts, apiURL string,
 	if queueOpts.NumPollers < 1 {
 		return nil, nil, fmt.Errorf("too few pollers specified: %d", queueOpts.NumPollers)
 	}
-	preResponseURL := queueOpts.PreResponseQueue + queueOpts.ResponseQueueSuffix
+	// The subscription url is made up of the response queue url and the response queue suffix
+	subscriptionURL := queueOpts.ResponseQueue + queueOpts.ResponseQueueSuffix
 	srv := &server{
 		name:         name,
 		requests:     common.MustOpenTopic(queueOpts.RequestQueue),
-		responses:    common.MustOpenSubscription(preResponseURL, queueOpts.SubscriptionBatchSize),
-		preResponses: common.MustOpenTopic(queueOpts.ResponseQueue),
+		responses:    common.MustOpenSubscription(subscriptionURL, queueOpts.SubscriptionBatchSize),
+		preResponses: common.MustOpenTopic(queueOpts.PreResponseQueue),
 		jobs:         map[string]*job{},
 		platform:     allowedPlatform,
 		client:       client,