() -> pushServiceSocket = new PushServiceSocket(serviceEnvironmentConfig.signalServiceConfiguration(),
credentialsProvider,
userAgent,
- getClientZkProfileOperations(),
ServiceConfig.AUTOMATIC_NETWORK_RETRY));
}
Optional.of(credentialsProvider),
userAgent,
healthMonitor,
- allowStories), timer, TimeUnit.SECONDS.toMillis(10));
+ allowStories), () -> true, timer, TimeUnit.SECONDS.toMillis(10));
healthMonitor.monitor(authenticatedSignalWebSocket);
});
}
Optional.empty(),
userAgent,
healthMonitor,
- allowStories), timer, TimeUnit.SECONDS.toMillis(10));
+ allowStories), () -> true, timer, TimeUnit.SECONDS.toMillis(10));
healthMonitor.monitor(unauthenticatedSignalWebSocket);
});
}
getKeysApi(),
Optional.empty(),
executor,
- ServiceConfig.MAX_ENVELOPE_SIZE));
+ ServiceConfig.MAX_ENVELOPE_SIZE,
+ () -> true));
}
public List<SecureValueRecovery> getSecureValueRecovery() {