renaming

Author: JavaSaBr

core-service/src/main/java/javasabr/mqtt/service/publish/processor/AbstractIncomingPublishProcessor.java

@@ -43,15 +43,15 @@ public final void process(NetworkMqttUser user, Publish publish) {
       return;
     }
     if (validateImpl(expectedUser, session, publish)) {
-      handleImpl(expectedUser, session, publish);
+      processImpl(expectedUser, session, publish);
     }
   }
 
   protected boolean validateImpl(U user, NetworkMqttSession session, Publish publish) {
     return true;
   }
 
-  protected void handleImpl(U user, NetworkMqttSession session, Publish publish) {
+  protected void processImpl(U user, NetworkMqttSession session, Publish publish) {
     TopicName topicName = publish.topicName();
     Array<SingleSubscriber> subscribers = subscriptionService.findSubscribers(topicName);
     if (subscribers.isEmpty()) {
@@ -77,7 +77,7 @@ protected void handleImpl(U user, NetworkMqttSession session, Publish publish) {
     handleSuccess(user, session, publish, count);
 
     for (SingleSubscriber subscriber : subscribers) {
-      startDelivering(publish, subscriber);
+      dispatchToSubscriber(publish, subscriber);
     }
   }
 
@@ -106,7 +106,7 @@ protected PublishProcessingResult checkSubscriber(
     return PublishProcessingResult.SUCCESS;
   }
 
-  protected void startDelivering(Publish publish, SingleSubscriber subscriber) {
+  protected void dispatchToSubscriber(Publish publish, SingleSubscriber subscriber) {
     publishDispatcher.dispatchToSubscriber(publish, subscriber.user(), subscriber.subscription());
   }
 

core-service/src/main/java/javasabr/mqtt/service/publish/processor/TrackableIncomingPublishProcessor.java

@@ -40,10 +40,10 @@ protected boolean validateImpl(U user, NetworkMqttSession session, Publish publi
   }
 
   @Override
-  protected void handleImpl(U user, NetworkMqttSession session, Publish publish) {
+  protected void processImpl(U user, NetworkMqttSession session, Publish publish) {
     MessageTacker messageTacker = session.inMessageTracker();
     messageTacker.add(publish.messageId(), MqttMessageType.PUBLISH);
-    super.handleImpl(user, session, publish);
+    super.processImpl(user, session, publish);
   }
 
   protected void handleMissedMessageId(U client) {

core-service/src/main/java/javasabr/mqtt/service/publish/sender/TrackableSubscriberPublishSender.java

@@ -33,7 +33,7 @@ public abstract class TrackableSubscriberPublishSender extends
   protected TrackableSubscriberPublishSender(MessageOutFactoryService messageOutFactoryService) {
     super(ExternalNetworkMqttUser.class, messageOutFactoryService);
     this.trackableMessageCallback = this::handleReceivedTrackableMessage;
-    this.publishRetryer = this::retryDelivering;
+    this.publishRetryer = this::retrySending;
   }
 
   @Nullable
@@ -77,7 +77,7 @@ protected abstract boolean handleReceivedTrackableMessageImpl(
       TrackableMqttMessage message,
       @Nullable TrackedMessageMeta trackedMessageMeta);
 
-  protected final void retryDelivering(MqttUser user, MqttSession session, Publish publish) {
+  protected final void retrySending(MqttUser user, MqttSession session, Publish publish) {
     ExternalNetworkMqttUser networkMqttUser = expectedUserType.cast(user);
     String clientId = networkMqttUser.clientId();
     int messageId = publish.messageId();