- private final ExecutorService executor = Executors.newFixedThreadPool(THREAD_POOL_SIZE);
- private final Map<BigInteger, BundleDetails> bundleIdMap = new ConcurrentHashMap<>();
-
- public ArbitratorReconciliationManagerImpl(final RpcProviderRegistry rpcRegistry,
- final ReconciliationManager reconciliationManager, final UpgradeState upgradeState) {
+ private final ListeningExecutorService executor = MoreExecutors.listeningDecorator(
+ Executors.newFixedThreadPool(THREAD_POOL_SIZE));
+ private final Map<Uint64, BundleDetails> bundleIdMap = new ConcurrentHashMap<>();
+ private final ConcurrentMap<String,
+ ObjectRegistration<? extends RpcService>> rpcRegistrations = new ConcurrentHashMap<>();
+
+ @Inject
+ public ArbitratorReconciliationManagerImpl(final ReconciliationManager reconciliationManager,
+ final RpcProviderService rpcProviderService, final RpcConsumerRegistry rpcRegistry,
+ final UpgradeState upgradeState) {