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,