- private final ThreadPoolExecutor threadPool;
-
- public SystemNotificationsListenerImpl(@Nonnull final ConnectionContext connectionContext,
- long echoReplyTimeout,
- @Nonnull final ThreadPoolExecutor threadPool) {
- this.threadPool = threadPool;
+ private final ExecutorService executorService;
+ private final NotificationPublishService notificationPublishService;
+
+ public SystemNotificationsListenerImpl(@NonNull final ConnectionContext connectionContext,
+ final long echoReplyTimeout,
+ @NonNull final ExecutorService executorService,
+ @NonNull final NotificationPublishService notificationPublishService) {
+ this.executorService = executorService;