- mxBean = new RemoteRpcRegistryMXBeanImpl(rpcRegistry);
- Uninterruptibles.sleepUninterruptibly(200, TimeUnit.MILLISECONDS);
+ final Timeout timeout = Timeout.apply(10, TimeUnit.SECONDS);
+ mxBean = new RemoteRpcRegistryMXBeanImpl(new BucketStoreAccess(testActor, system.dispatcher(), timeout),
+ timeout);