private volatile CONTEXT_STATE state;
private ClusterInitializationPhaseHandler clusterInitializationPhaseHandler;
private final DeviceManager myManager;
+ private final boolean useSingleLayerSerialization;
DeviceContextImpl(
@Nonnull final ConnectionContext primaryConnectionContext,
final ConvertorExecutor convertorExecutor,
final boolean skipTableFeatures,
final HashedWheelTimer hashedWheelTimer,
- final DeviceManager myManager) {
+ final DeviceManager myManager,
+ final boolean useSingleLayerSerialization) {
this.primaryConnectionContext = primaryConnectionContext;
this.deviceInfo = primaryConnectionContext.getDeviceInfo();
this.hashedWheelTimer = hashedWheelTimer;
this.state = CONTEXT_STATE.INITIALIZATION;
this.convertorExecutor = convertorExecutor;
this.skipTableFeatures = skipTableFeatures;
+ this.useSingleLayerSerialization = useSingleLayerSerialization;
this.initialized = false;
}
this.onPublished();
}
+ @Override
+ public boolean isUseSingleLayerSerialization() {
+ return useSingleLayerSerialization;
+ }
+
@Override
public boolean isSkipTableFeatures() {
return this.skipTableFeatures;