/**
* Util class to access package private members in cds-access-client for test purposes.
*/
-public class AccessClientUtil {
+public final class AccessClientUtil {
+ private AccessClientUtil() {
+ throw new UnsupportedOperationException();
+ }
public static ClientActorContext createClientActorContext(final ActorSystem system, final ActorRef actor,
final ClientIdentifier id, final String persistenceId) {
- return spy(new ClientActorContext(actor, system.scheduler(), system.dispatcher(), persistenceId, id,
- newMockClientActorConfig()));
+ return spy(new ClientActorContext(actor, persistenceId, system, id, newMockClientActorConfig()));
}
public static ClientActorConfig newMockClientActorConfig() {
ClientActorConfig mockConfig = mock(ClientActorConfig.class);
doReturn(2_000_000).when(mockConfig).getMaximumMessageSliceSize();
doReturn(1_000_000_000).when(mockConfig).getFileBackedStreamingThreshold();
+ doReturn(AbstractClientConnection.DEFAULT_BACKEND_ALIVE_TIMEOUT_NANOS)
+ .when(mockConfig).getBackendAlivenessTimerInterval();
+ doReturn(AbstractClientConnection.DEFAULT_REQUEST_TIMEOUT_NANOS).when(mockConfig).getRequestTimeout();
+ doReturn(AbstractClientConnection.DEFAULT_NO_PROGRESS_TIMEOUT_NANOS)
+ .when(mockConfig).getNoProgressTimeout();
return mockConfig;
}
public static <T extends BackendInfo> ConnectedClientConnection<T> createConnectedConnection(
final ClientActorContext context, final Long cookie, final T backend) {
- return new ConnectedClientConnection<>(context, cookie, backend);
+ return new ConnectedClientConnection<>(new ConnectingClientConnection<>(context, cookie, backend.getName()),
+ backend);
}
public static void completeRequest(final AbstractClientConnection<? extends BackendInfo> connection,