rename MessagesProcessor to MessageDispatcher

pongad · pongad · commit 8048d020b08f · 2017-01-19T11:55:11.000+11:00
Fixes #1546
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/MessageDispatcher.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/MessageDispatcher.java
@@ -52,8 +52,8 @@
  * Dispatches messages to a message receiver while handling the messages acking and lease
  * extensions.
  */
-class MessagesProcessor {
-  private static final Logger logger = LoggerFactory.getLogger(MessagesProcessor.class);
+class MessageDispatcher {
+  private static final Logger logger = LoggerFactory.getLogger(MessageDispatcher.class);
 
   private static final int INITIAL_ACK_DEADLINE_EXTENSION_SECONDS = 2;
   @VisibleForTesting static final Duration PENDING_ACKS_SEND_DELAY = Duration.millis(100);
@@ -202,7 +202,7 @@ void sendAckOperations(
         List<String> acksToSend, List<PendingModifyAckDeadline> ackDeadlineExtensions);
   }
 
-  MessagesProcessor(
+  MessageDispatcher(
       MessageReceiver receiver,
       AcksProcessor acksProcessor,
       Duration ackExpirationPadding,
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/PollingSubscriberConnection.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/PollingSubscriberConnection.java
@@ -22,8 +22,8 @@
 import com.google.api.stats.Distribution;
 import com.google.auth.Credentials;
 import com.google.cloud.Clock;
-import com.google.cloud.pubsub.MessagesProcessor.AcksProcessor;
-import com.google.cloud.pubsub.MessagesProcessor.PendingModifyAckDeadline;
+import com.google.cloud.pubsub.MessageDispatcher.AcksProcessor;
+import com.google.cloud.pubsub.MessageDispatcher.PendingModifyAckDeadline;
 import com.google.cloud.pubsub.Subscriber.MessageReceiver;
 import com.google.common.collect.Lists;
 import com.google.common.util.concurrent.AbstractService;
@@ -64,7 +64,7 @@ final class PollingSubscriberConnection extends AbstractService implements AcksP
   private final String subscription;
   private final ScheduledExecutorService executor;
   private final SubscriberFutureStub stub;
-  private final MessagesProcessor messagesProcessor;
+  private final MessageDispatcher messagesProcessor;
 
   public PollingSubscriberConnection(
       String subscription,
@@ -82,7 +82,7 @@ public PollingSubscriberConnection(
         SubscriberGrpc.newFutureStub(channel)
             .withCallCredentials(MoreCallCredentials.from(credentials));
     messagesProcessor =
-        new MessagesProcessor(
+        new MessageDispatcher(
             receiver,
             this,
             ackExpirationPadding,
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/StreamingSubscriberConnection.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/StreamingSubscriberConnection.java
@@ -22,8 +22,8 @@
 import com.google.api.stats.Distribution;
 import com.google.auth.Credentials;
 import com.google.cloud.Clock;
-import com.google.cloud.pubsub.MessagesProcessor.AcksProcessor;
-import com.google.cloud.pubsub.MessagesProcessor.PendingModifyAckDeadline;
+import com.google.cloud.pubsub.MessageDispatcher.AcksProcessor;
+import com.google.cloud.pubsub.MessageDispatcher.PendingModifyAckDeadline;
 import com.google.cloud.pubsub.Subscriber.MessageReceiver;
 import com.google.common.collect.Lists;
 import com.google.common.util.concurrent.AbstractService;
@@ -63,7 +63,7 @@ final class StreamingSubscriberConnection extends AbstractService implements Ack
 
   private final String subscription;
   private final ScheduledExecutorService executor;
-  private final MessagesProcessor messagesProcessor;
+  private final MessageDispatcher messagesProcessor;
   private ClientCallStreamObserver<StreamingPullRequest> requestObserver;
 
   public StreamingSubscriberConnection(
@@ -82,7 +82,7 @@ public StreamingSubscriberConnection(
     this.credentials = credentials;
     this.channel = channel;
     this.messagesProcessor =
-        new MessagesProcessor(
+        new MessageDispatcher(
             receiver,
             this,
             ackExpirationPadding,
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/SubscriberImplTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/SubscriberImplTest.java
@@ -16,7 +16,7 @@
 
 package com.google.cloud.pubsub;
 
-import static com.google.cloud.pubsub.MessagesProcessor.PENDING_ACKS_SEND_DELAY;
+import static com.google.cloud.pubsub.MessageDispatcher.PENDING_ACKS_SEND_DELAY;
 import static org.junit.Assert.assertEquals;
 
 import com.google.cloud.pubsub.FakeSubscriberServiceImpl.ModifyAckDeadline;
