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..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
@@ -66,14 +66,15 @@ 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..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
@@ -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,8 @@ 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..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
@@ -45,12 +45,13 @@ 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..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
@@ -48,14 +48,15 @@ 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..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
@@ -60,14 +60,15 @@ 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..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
@@ -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,8 @@ 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..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
@@ -42,14 +42,15 @@ 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..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
@@ -45,14 +45,15 @@ 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);
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));