}
@Test
- @SuppressWarnings("unchecked")
public void testStartReconnect() throws Exception {
// cookie and shard are the same
final Long cookie = 0L;
final ShardBackendInfo info = new ShardBackendInfo(clientActorContext().self(), 0L, ABIVersion.current(),
SHARD_NAME, UnsignedLong.ZERO, Optional.of(tree), 10);
- final ConnectedClientConnection newConn = AccessClientUtil.createConnectedConnection(
+ final ConnectedClientConnection<ShardBackendInfo> newConn = AccessClientUtil.createConnectedConnection(
clientActorContext(), cookie, info);
object().createSnapshotProxy(TRANSACTION_ID, shard);
}
@Test
- @SuppressWarnings("unchecked")
public void testStartReconnectMissingOldProxy() throws Exception {
// cookie and shard are different
final Long cookie = 1L;
final ShardBackendInfo info = new ShardBackendInfo(clientActorContext().self(), 0L, ABIVersion.current(),
SHARD_NAME, UnsignedLong.ZERO, Optional.of(tree), 10);
- final ConnectedClientConnection newConn = AccessClientUtil.createConnectedConnection(
+ final ConnectedClientConnection<ShardBackendInfo> newConn = AccessClientUtil.createConnectedConnection(
clientActorContext(), cookie, info);
object().createSnapshotProxy(TRANSACTION_ID, shard);