From cd2ce7e7435b26452ab7409970e6c02831420742 Mon Sep 17 00:00:00 2001
From: Sascha Doemer <Cf4ThQgxcnxAovOUXTNv@saschadoemer.de>
Date: Mon, 7 Mar 2022 17:01:49 +0100
Subject: [PATCH 1/2] Add more specific names for the default functions.

---
 .../api/service/messaging/http/DeleteMessageService.java  | 4 ++--
 .../api/service/messaging/http/ListEndpointsService.java  | 8 ++++----
 .../service/messaging/http/MessageHeaderQueryService.java | 4 ++--
 .../api/service/messaging/http/MessageQueryService.java   | 4 ++--
 .../api/service/messaging/mqtt/DeleteMessageService.java  | 4 ++--
 .../api/service/messaging/mqtt/ListEndpointsService.java  | 8 ++++----
 .../service/messaging/mqtt/MessageHeaderQueryService.java | 4 ++--
 .../api/service/messaging/mqtt/MessageQueryService.java   | 4 ++--
 .../impl/messaging/mqtt/DeleteMessageServiceImpl.java     | 4 ++--
 .../impl/messaging/mqtt/ListEndpointsServiceImpl.java     | 8 ++++----
 .../messaging/mqtt/MessageHeaderQueryServiceImpl.java     | 4 ++--
 .../impl/messaging/mqtt/MessageQueryServiceImpl.java      | 4 ++--
 .../impl/messaging/rest/DeleteMessageServiceImpl.java     | 4 ++--
 .../impl/messaging/rest/ListEndpointsServiceImpl.java     | 8 ++++----
 .../messaging/rest/MessageHeaderQueryServiceImpl.java     | 4 ++--
 .../impl/messaging/rest/MessageQueryServiceImpl.java      | 4 ++--
 16 files changed, 40 insertions(+), 40 deletions(-)

diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/DeleteMessageService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/DeleteMessageService.java
index e637a005..1863fa96 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/DeleteMessageService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/DeleteMessageService.java
@@ -14,7 +14,7 @@ public interface DeleteMessageService extends MessagingService<DeleteMessagePara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String deleteAll(OnboardingResponse onboardingResponse);
+  String sendMessageToDeleteAll(OnboardingResponse onboardingResponse);
 
   /**
    * Delete all messages in the feed. The function will delete all messages based on the time
@@ -24,5 +24,5 @@ public interface DeleteMessageService extends MessagingService<DeleteMessagePara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  HttpAsyncMessageSendingResult deleteAllAsync(OnboardingResponse onboardingResponse);
+  HttpAsyncMessageSendingResult sendMessageToDeleteAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/ListEndpointsService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/ListEndpointsService.java
index 2d92dd7e..e052a4cf 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/ListEndpointsService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/ListEndpointsService.java
@@ -12,7 +12,7 @@ public interface ListEndpointsService extends MessagingService<ListEndpointsPara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String listAllWithExistingRoute(OnboardingResponse onboardingResponse);
+  String sendMessageToListAllWithExistingRoute(OnboardingResponse onboardingResponse);
 
   /**
    * List all endpoints for the account, even those that do not have a route.
@@ -20,7 +20,7 @@ public interface ListEndpointsService extends MessagingService<ListEndpointsPara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String listAll(OnboardingResponse onboardingResponse);
+  String sendMessageToListAll(OnboardingResponse onboardingResponse);
 
   /**
    * List all endpoints with a route to the dedicated endpoint.
@@ -28,7 +28,7 @@ public interface ListEndpointsService extends MessagingService<ListEndpointsPara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  HttpAsyncMessageSendingResult listAllWithExistingRouteAsync(
+  HttpAsyncMessageSendingResult sendMessageToListAllWithExistingRouteAsync(
       OnboardingResponse onboardingResponse);
 
   /**
@@ -37,5 +37,5 @@ HttpAsyncMessageSendingResult listAllWithExistingRouteAsync(
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  HttpAsyncMessageSendingResult listAllAsync(OnboardingResponse onboardingResponse);
+  HttpAsyncMessageSendingResult sendMessageToListAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageHeaderQueryService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageHeaderQueryService.java
index b71467a2..8fdcbee2 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageHeaderQueryService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageHeaderQueryService.java
@@ -17,7 +17,7 @@ public interface MessageHeaderQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String queryAll(OnboardingResponse onboardingResponse);
+  String sendMessageToQueryAll(OnboardingResponse onboardingResponse);
 
   /**
    * Query all message headers as async default function. The query will be based on a time period
@@ -27,5 +27,5 @@ public interface MessageHeaderQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  HttpAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse);
+  HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageQueryService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageQueryService.java
index 33406d6f..c8a133d6 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageQueryService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/MessageQueryService.java
@@ -17,7 +17,7 @@ public interface MessageQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String queryAll(OnboardingResponse onboardingResponse);
+  String sendMessageToQueryAll(OnboardingResponse onboardingResponse);
 
   /**
    * Query all messages as async default function. The query will be based on a time period since
@@ -26,5 +26,5 @@ public interface MessageQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  HttpAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse);
+  HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/DeleteMessageService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/DeleteMessageService.java
index cb0220f8..aee24433 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/DeleteMessageService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/DeleteMessageService.java
@@ -14,7 +14,7 @@ public interface DeleteMessageService extends MessagingService<DeleteMessagePara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String deleteAll(OnboardingResponse onboardingResponse);
+  String sendMessageToDeleteAll(OnboardingResponse onboardingResponse);
 
   /**
    * Delete all messages in the feed. The function will delete all messages based on the time
@@ -24,5 +24,5 @@ public interface DeleteMessageService extends MessagingService<DeleteMessagePara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  MqttAsyncMessageSendingResult deleteAllAsync(OnboardingResponse onboardingResponse);
+  MqttAsyncMessageSendingResult sendMessageToDeleteAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/ListEndpointsService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/ListEndpointsService.java
index 2280e662..982d100e 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/ListEndpointsService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/ListEndpointsService.java
@@ -12,7 +12,7 @@ public interface ListEndpointsService extends MessagingService<ListEndpointsPara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String listAllWithExistingRoute(OnboardingResponse onboardingResponse);
+  String sendMessageToListAllWithExistingRoute(OnboardingResponse onboardingResponse);
 
   /**
    * List all endpoints for the account, even those that do not have a route.
@@ -20,7 +20,7 @@ public interface ListEndpointsService extends MessagingService<ListEndpointsPara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String listAll(OnboardingResponse onboardingResponse);
+  String sendMessageToListAll(OnboardingResponse onboardingResponse);
 
   /**
    * List all endpoints with a route to the dedicated endpoint.
@@ -28,7 +28,7 @@ public interface ListEndpointsService extends MessagingService<ListEndpointsPara
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  MqttAsyncMessageSendingResult listAllWithExistingRouteAsync(
+  MqttAsyncMessageSendingResult sendMessageToListAllWithExistingRouteAsync(
       OnboardingResponse onboardingResponse);
 
   /**
@@ -37,5 +37,5 @@ MqttAsyncMessageSendingResult listAllWithExistingRouteAsync(
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  MqttAsyncMessageSendingResult listAllAsync(OnboardingResponse onboardingResponse);
+  MqttAsyncMessageSendingResult sendMessageToListAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageHeaderQueryService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageHeaderQueryService.java
index fb08d0e8..f51cf491 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageHeaderQueryService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageHeaderQueryService.java
@@ -17,7 +17,7 @@ public interface MessageHeaderQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String queryAll(OnboardingResponse onboardingResponse);
+  String sendMessageToQueryAll(OnboardingResponse onboardingResponse);
 
   /**
    * Query all message headers as async default function. The query will be based on a time period
@@ -27,5 +27,5 @@ public interface MessageHeaderQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  MqttAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse);
+  MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageQueryService.java b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageQueryService.java
index 56e52332..a721707a 100644
--- a/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageQueryService.java
+++ b/agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/MessageQueryService.java
@@ -17,7 +17,7 @@ public interface MessageQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  String queryAll(OnboardingResponse onboardingResponse);
+  String sendMessageToQueryAll(OnboardingResponse onboardingResponse);
 
   /**
    * Query all messages as async default function. The query will be based on a time period since
@@ -26,5 +26,5 @@ public interface MessageQueryService
    * @param onboardingResponse The onboard response for the endpoint.
    * @return The message ID.
    */
-  MqttAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse);
+  MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse);
 }
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java
index 3baf0d82..a040f1c3 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java
@@ -66,14 +66,14 @@ public EncodeMessageService getEncodeMessageService() {
   }
 
   @Override
-  public String deleteAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToDeleteAll(OnboardingResponse onboardingResponse) {
     final DeleteMessageParameters deleteMessageParameters =
         createMessageParametersToDeleteAllMessages(onboardingResponse);
     return send(deleteMessageParameters);
   }
 
   @Override
-  public MqttAsyncMessageSendingResult deleteAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToDeleteAllAsync(OnboardingResponse onboardingResponse) {
     final DeleteMessageParameters deleteMessageParameters =
         createMessageParametersToDeleteAllMessages(onboardingResponse);
     return sendAsync(deleteMessageParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java
index c850eb9d..32ff72e9 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java
@@ -72,7 +72,7 @@ public EncodeMessageService getEncodeMessageService() {
   }
 
   @Override
-  public String listAllWithExistingRoute(OnboardingResponse onboardingResponse) {
+  public String sendMessageToListAllWithExistingRoute(OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
@@ -82,7 +82,7 @@ public String listAllWithExistingRoute(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public String listAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToListAll(OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
@@ -92,7 +92,7 @@ public String listAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public MqttAsyncMessageSendingResult listAllWithExistingRouteAsync(
+  public MqttAsyncMessageSendingResult sendMessageToListAllWithExistingRouteAsync(
       OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
@@ -103,7 +103,7 @@ public MqttAsyncMessageSendingResult listAllWithExistingRouteAsync(
   }
 
   @Override
-  public MqttAsyncMessageSendingResult listAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToListAllAsync(OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java
index 70c5176d..8d5528e1 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java
@@ -45,12 +45,12 @@ public FeedResponse.HeaderQueryResponse unsafeDecode(ByteString message)
   }
 
   @Override
-  public String queryAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
     return send(messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse));
   }
 
   @Override
-  public MqttAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
     return sendAsync(
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse));
   }
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java
index e28ca58b..32542118 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java
@@ -48,14 +48,14 @@ public FeedResponse.MessageQueryResponse unsafeDecode(ByteString message)
   }
 
   @Override
-  public String queryAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return send(messageQueryParameters);
   }
 
   @Override
-  public MqttAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return sendAsync(messageQueryParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java
index 71ad921f..e4ea95e6 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java
@@ -60,14 +60,14 @@ public EncodeMessageService getEncodeMessageService() {
   }
 
   @Override
-  public String deleteAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToDeleteAll(OnboardingResponse onboardingResponse) {
     final DeleteMessageParameters deleteMessageParameters =
         createMessageParametersToDeleteAllMessages(onboardingResponse);
     return send(deleteMessageParameters);
   }
 
   @Override
-  public HttpAsyncMessageSendingResult deleteAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToDeleteAllAsync(OnboardingResponse onboardingResponse) {
     final DeleteMessageParameters deleteMessageParameters =
         createMessageParametersToDeleteAllMessages(onboardingResponse);
     return sendAsync(deleteMessageParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java
index ebeba7ab..677785d8 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java
@@ -66,7 +66,7 @@ public EncodeMessageService getEncodeMessageService() {
   }
 
   @Override
-  public String listAllWithExistingRoute(OnboardingResponse onboardingResponse) {
+  public String sendMessageToListAllWithExistingRoute(OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
@@ -76,7 +76,7 @@ public String listAllWithExistingRoute(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public String listAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToListAll(OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
@@ -86,7 +86,7 @@ public String listAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public HttpAsyncMessageSendingResult listAllWithExistingRouteAsync(
+  public HttpAsyncMessageSendingResult sendMessageToListAllWithExistingRouteAsync(
       OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
@@ -97,7 +97,7 @@ public HttpAsyncMessageSendingResult listAllWithExistingRouteAsync(
   }
 
   @Override
-  public HttpAsyncMessageSendingResult listAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToListAllAsync(OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java
index 91cdfd0f..267eb753 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java
@@ -42,14 +42,14 @@ public FeedResponse.HeaderQueryResponse unsafeDecode(ByteString message)
   }
 
   @Override
-  public String queryAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return send(messageQueryParameters);
   }
 
   @Override
-  public HttpAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return sendAsync(messageQueryParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java
index e36c29e2..3392702c 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java
@@ -45,14 +45,14 @@ public FeedResponse.MessageQueryResponse unsafeDecode(ByteString message)
   }
 
   @Override
-  public String queryAll(OnboardingResponse onboardingResponse) {
+  public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return send(messageQueryParameters);
   }
 
   @Override
-  public HttpAsyncMessageSendingResult queryAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return sendAsync(messageQueryParameters);

From 919c041ba84fdc593fe2467d132c61c3606fa86f Mon Sep 17 00:00:00 2001
From: Sascha Doemer <Cf4ThQgxcnxAovOUXTNv@saschadoemer.de>
Date: Mon, 7 Mar 2022 17:04:13 +0100
Subject: [PATCH 2/2] Format.

---
 .../impl/messaging/mqtt/DeleteMessageServiceImpl.java          | 3 ++-
 .../impl/messaging/mqtt/ListEndpointsServiceImpl.java          | 3 ++-
 .../impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java     | 3 ++-
 .../impl/messaging/mqtt/MessageQueryServiceImpl.java           | 3 ++-
 .../impl/messaging/rest/DeleteMessageServiceImpl.java          | 3 ++-
 .../impl/messaging/rest/ListEndpointsServiceImpl.java          | 3 ++-
 .../impl/messaging/rest/MessageHeaderQueryServiceImpl.java     | 3 ++-
 .../impl/messaging/rest/MessageQueryServiceImpl.java           | 3 ++-
 .../impl/onboard/secured/AuthorizationRequestServiceImpl.java  | 2 +-
 9 files changed, 17 insertions(+), 9 deletions(-)

diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java
index a040f1c3..b39a4fa5 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/DeleteMessageServiceImpl.java
@@ -73,7 +73,8 @@ public String sendMessageToDeleteAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public MqttAsyncMessageSendingResult sendMessageToDeleteAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToDeleteAllAsync(
+      OnboardingResponse onboardingResponse) {
     final DeleteMessageParameters deleteMessageParameters =
         createMessageParametersToDeleteAllMessages(onboardingResponse);
     return sendAsync(deleteMessageParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java
index 32ff72e9..5e737629 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/ListEndpointsServiceImpl.java
@@ -103,7 +103,8 @@ public MqttAsyncMessageSendingResult sendMessageToListAllWithExistingRouteAsync(
   }
 
   @Override
-  public MqttAsyncMessageSendingResult sendMessageToListAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToListAllAsync(
+      OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java
index 8d5528e1..6fc6c9c1 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageHeaderQueryServiceImpl.java
@@ -50,7 +50,8 @@ public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(
+      OnboardingResponse onboardingResponse) {
     return sendAsync(
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse));
   }
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java
index 32542118..13adfbcf 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/mqtt/MessageQueryServiceImpl.java
@@ -55,7 +55,8 @@ public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
+  public MqttAsyncMessageSendingResult sendMessageToQueryAllAsync(
+      OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return sendAsync(messageQueryParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java
index e4ea95e6..afed7ca6 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/DeleteMessageServiceImpl.java
@@ -67,7 +67,8 @@ public String sendMessageToDeleteAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public HttpAsyncMessageSendingResult sendMessageToDeleteAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToDeleteAllAsync(
+      OnboardingResponse onboardingResponse) {
     final DeleteMessageParameters deleteMessageParameters =
         createMessageParametersToDeleteAllMessages(onboardingResponse);
     return sendAsync(deleteMessageParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java
index 677785d8..96055f28 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/ListEndpointsServiceImpl.java
@@ -97,7 +97,8 @@ public HttpAsyncMessageSendingResult sendMessageToListAllWithExistingRouteAsync(
   }
 
   @Override
-  public HttpAsyncMessageSendingResult sendMessageToListAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToListAllAsync(
+      OnboardingResponse onboardingResponse) {
     ListEndpointsParameters listEndpointsParameters = new ListEndpointsParameters();
     listEndpointsParameters.setDirection(Endpoints.ListEndpointsQuery.Direction.SEND_RECEIVE);
     listEndpointsParameters.setTechnicalMessageType(SystemMessageType.EMPTY);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java
index 267eb753..7d532872 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageHeaderQueryServiceImpl.java
@@ -49,7 +49,8 @@ public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(
+      OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return sendAsync(messageQueryParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java
index 3392702c..c86ff3bf 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/messaging/rest/MessageQueryServiceImpl.java
@@ -52,7 +52,8 @@ public String sendMessageToQueryAll(OnboardingResponse onboardingResponse) {
   }
 
   @Override
-  public HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(OnboardingResponse onboardingResponse) {
+  public HttpAsyncMessageSendingResult sendMessageToQueryAllAsync(
+      OnboardingResponse onboardingResponse) {
     MessageQueryParameters messageQueryParameters =
         messageQueryHelperService.createMessageParametersToQueryAll(onboardingResponse);
     return sendAsync(messageQueryParameters);
diff --git a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/onboard/secured/AuthorizationRequestServiceImpl.java b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/onboard/secured/AuthorizationRequestServiceImpl.java
index 250572c0..8faad8f9 100644
--- a/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/onboard/secured/AuthorizationRequestServiceImpl.java
+++ b/agrirouter-sdk-java-impl/src/main/java/com/dke/data/agrirouter/impl/onboard/secured/AuthorizationRequestServiceImpl.java
@@ -86,7 +86,7 @@ public AuthorizationResponse extractAuthorizationResponseFromQuery(String query)
             });
     AuthorizationResponse authorizationResponse = new AuthorizationResponse();
     if (authorizationResults.containsKey(SIGNATURE_KEY)) {
-        authorizationResponse.setSignature(authorizationResults.get(SIGNATURE_KEY));
+      authorizationResponse.setSignature(authorizationResults.get(SIGNATURE_KEY));
     }
     authorizationResponse.setState(authorizationResults.get(STATE_KEY));
     authorizationResponse.setToken(authorizationResults.get(TOKEN_KEY));