import java.util.List;
import java.util.concurrent.TimeUnit;
-import org.opendaylight.controller.md.statistics.manager.MultipartMessageManager.StatsRequestType;
import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
}
@Override
- public void registerTransaction(final ListenableFuture<TransactionId> future, final StatsRequestType type) {
+ public void registerTransaction(final ListenableFuture<TransactionId> future) {
Futures.addCallback(future, new FutureCallback<TransactionId>() {
@Override
public void onSuccess(TransactionId result) {
- msgManager.recordExpectedTransaction(result, type);
+ msgManager.recordExpectedTransaction(result);
logger.debug("Transaction {} for node {} sent successfully", result, targetNodeKey);
}
Futures.addCallback(future, new FutureCallback<TransactionId>() {
@Override
public void onSuccess(TransactionId result) {
- msgManager.recordExpectedTableTransaction(result, StatsRequestType.AGGR_FLOW, id);
+ msgManager.recordExpectedTableTransaction(result, id);
logger.debug("Transaction {} for node {} table {} sent successfully", result, targetNodeKey, id);
}