You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/06/26 03:29:07 UTC
[james-project] 27/28: JAMES-2774 Remove an useless counter field
in EventDispatcher
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 <dt...@linagora.com>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org