private static final long TICK_DURATION = 500; // 0.5 sec.
- private final RpcManager rpcManager;
private final DataBroker dataBroker;
private final HashedWheelTimer hashedWheelTimer;
private RequestContextStack dummyRequestContextStack;
private DeviceInitializationPhaseHandler deviceInitPhaseHandler;
- public DeviceManagerImpl(@Nonnull final RpcManager rpcManager, @Nonnull final DataBroker dataBroker) {
- this.rpcManager = Preconditions.checkNotNull(rpcManager);
+ public DeviceManagerImpl(@Nonnull final DataBroker dataBroker) {
this.dataBroker = Preconditions.checkNotNull(dataBroker);
hashedWheelTimer = new HashedWheelTimer(TICK_DURATION, TimeUnit.MILLISECONDS, 10);
final Xid xid = deviceContext.getNextXid();
final RequestContext<List<MultipartReply>> requestContext = dummyRequestContextStack.createRequestContext();
multiMsgCollector.registerMultipartXid(xid.getValue());
- deviceContext.hookRequestCtx(xid, requestContext);
Futures.addCallback(requestContext.getFuture(), new FutureCallback<RpcResult<List<MultipartReply>>>() {
@Override
public void onSuccess(final RpcResult<List<MultipartReply>> rpcResult) {