Fix tests if producer

common/cpp/include/asapo/unittests/MockBrokerRequest.h

+#ifndef ASAPO_MOCKBROKERREQUEST_H
+#define ASAPO_MOCKBROKERREQUEST_H
+
+#include <gmock/gmock.h>
+#include "asapo/request/broker_request.h"
+
+namespace asapo {
+
+class MockServiceRequest : public ServiceRequest {
+public:
+    MockServiceRequest(const std::string& server_uri, const SourceCredentials& source)
+        : ServiceRequest(server_uri, source) {}
+
+    MOCK_METHOD(std::string, BrokerRequestWithTimeout, (RequestInfo request, Error *err, uint64_t timeout_ms, std::atomic<bool>& interrupt_flag));
+    MOCK_METHOD(std::string, BrokerRequestWithTimeout, (RequestInfo request, Error *err, uint64_t timeout_ms));
+    MOCK_METHOD(RequestInfo, CreateBrokerApiRequest, (std::string stream, std::string group, std::string suffix), (const));
+    MOCK_METHOD(Error, ServiceRequestWithTimeout, (const std::string& service_name, std::string* service_uri, RequestInfo request,
+                                    RequestOutput* response, uint64_t timeout_ms, std::atomic<bool>& interrupt_flag));
+    MOCK_METHOD(Error, ProcessRequest, (RequestOutput *response, const RequestInfo &request, std::string *service_uri));
+    MOCK_METHOD(Error, DiscoverService, (const std::string& service_name, std::string* uri_to_set));
+};
+}
+
+#endif //ASAPO_MOCKBROKERREQUEST_H

producer/api/cpp/src/producer_impl.h

@@ -101,7 +101,6 @@ class ProducerImpl : public Producer {
     std::string endpoint_;
     Error RefreshSourceCredentialString(SourceCredentials source_cred);
 
-    ServiceRequest* service_request_;
     std::string current_broker_uri_;
 };