Feature/specify names for default functions

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);
 }

agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/http/ListEndpointsService.java

@@ -12,23 +12,23 @@ 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.
    *
    * @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.
    *
    * @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);
 }

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);
 }

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);
 }

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);
 }

agrirouter-sdk-java-api/src/main/java/com/dke/data/agrirouter/api/service/messaging/mqtt/ListEndpointsService.java

@@ -12,23 +12,23 @@ 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.
    *
    * @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.
    *
    * @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);
 }

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);
 }

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);
 }

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);

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);

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));
   }

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);

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);

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);

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);

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);

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));