() -> 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);
});
}