*/
package org.opendaylight.controller.cluster.databroker.actors.dds;
+import java.util.stream.Stream;
import org.opendaylight.controller.cluster.access.client.ClientActorContext;
-import org.opendaylight.controller.cluster.datastore.utils.ActorContext;
+import org.opendaylight.controller.cluster.datastore.utils.ActorUtils;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
/**
*/
final class SimpleDataStoreClientBehavior extends AbstractDataStoreClientBehavior {
// Pre-boxed instance
- private static final Long ZERO = Long.valueOf(0);
+ private static final Long ZERO = 0L;
private SimpleDataStoreClientBehavior(final ClientActorContext context,
final SimpleShardBackendResolver resolver) {
super(context, resolver);
}
- SimpleDataStoreClientBehavior(final ClientActorContext context, final ActorContext actorContext,
+ SimpleDataStoreClientBehavior(final ClientActorContext context, final ActorUtils actorUtils,
final String shardName) {
- this(context, new SimpleShardBackendResolver(context.getIdentifier(), actorContext, shardName));
+ this(context, new SimpleShardBackendResolver(context.getIdentifier(), actorUtils, shardName));
}
@Override
Long resolveShardForPath(final YangInstanceIdentifier path) {
return ZERO;
}
+
+ @Override
+ Stream<Long> resolveAllShards() {
+ return Stream.of(ZERO);
+ }
}