- final long lifetimeNanos = TimeUnit.MILLISECONDS.toNanos(StatisticsProvider.STATS_COLLECTION_MILLIS * NUMBER_OF_WAIT_CYCLES);
-
- if (flowStatsService != null) {
- flowStats = new FlowStatsTracker(flowStatsService, this, lifetimeNanos);
- } else {
- flowStats = null;
- }
- if (flowTableStatsService != null) {
- flowTableStats = new FlowTableStatsTracker(flowTableStatsService, this, lifetimeNanos);
- } else {
- flowTableStats = null;
- }
-
- if (groupStatsService != null) {
- groupDescStats = new GroupDescStatsTracker(groupStatsService, this, lifetimeNanos);
- groupStats = new GroupStatsTracker(groupStatsService, this, lifetimeNanos);
- } else {
- groupDescStats = null;
- groupStats = null;
- }
- if (meterStatsService != null) {
- meterConfigStats = new MeterConfigStatsTracker(meterStatsService, this, lifetimeNanos);
- meterStats = new MeterStatsTracker(meterStatsService, this, lifetimeNanos);
- } else {
- meterConfigStats = null;
- meterStats = null;
- }
- if (portStatsService != null) {
- nodeConnectorStats = new NodeConnectorStatsTracker(portStatsService, this, lifetimeNanos);
- } else {
- nodeConnectorStats = null;
- }
- if (queueStatsService != null) {
- queueStats = new QueueStatsTracker(queueStatsService, this, lifetimeNanos);
- } else {
- queueStats = null;
- }
+ final long lifetimeNanos = TimeUnit.MILLISECONDS.toNanos(STATS_COLLECTION_MILLIS * NUMBER_OF_WAIT_CYCLES);
+
+ msgManager = new MultipartMessageManager(lifetimeNanos);
+ flowTableStats = new FlowTableStatsTracker(flowTableStatsService, this);
+ flowStats = new FlowStatsTracker(flowStatsService, this, flowTableStats);
+ groupDescStats = new GroupDescStatsTracker(groupStatsService, this);
+ groupStats = new GroupStatsTracker(groupStatsService, this);
+ meterConfigStats = new MeterConfigStatsTracker(meterStatsService, this);
+ meterStats = new MeterStatsTracker(meterStatsService, this);
+ nodeConnectorStats = new NodeConnectorStatsTracker(portStatsService, this);
+ queueStats = new QueueStatsTracker(queueStatsService, this);