This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 6884456e2e5374b2f6a7c4c1c17ddffeea2bc264 Author: Tran Tien Duc <[email protected]> AuthorDate: Mon Jun 17 11:08:49 2019 +0700 JAMES-2774 Remove an useless counter field in EventDispatcher --- .../src/main/java/org/apache/james/mailbox/events/EventDispatcher.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java index 8f31102..311d6ed 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java @@ -26,7 +26,6 @@ import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT_EXC import java.nio.charset.StandardCharsets; import java.util.Set; -import java.util.concurrent.atomic.AtomicInteger; import java.util.stream.Stream; import org.apache.james.event.json.EventSerializer; @@ -58,7 +57,6 @@ class EventDispatcher { private final LocalListenerRegistry localListenerRegistry; private final AMQP.BasicProperties basicProperties; private final MailboxListenerExecutor mailboxListenerExecutor; - final AtomicInteger dispatchCount = new AtomicInteger(); EventDispatcher(EventBusId eventBusId, EventSerializer eventSerializer, Sender sender, LocalListenerRegistry localListenerRegistry, MailboxListenerExecutor mailboxListenerExecutor) { this.eventSerializer = eventSerializer; @@ -84,7 +82,6 @@ class EventDispatcher { dispatchToRemoteListeners(serializeEvent(event), keys)) .subscribeOn(Schedulers.elastic()) .then() - .doOnSuccess(any -> dispatchCount.incrementAndGet()) .subscribeWith(MonoProcessor.create()); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
