FabricActorService 类

定义

Represents the base class for Microsoft Service Fabric based reliable actors service.

Remarks:Derive from this class to implement your own custom actor service if you want to override any service level behavior for your actors.

public class FabricActorService extends StatefulServiceBase implements ActorService
继承
java.lang.Object
FabricActorService

继承成员

构造函数

FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo)

Initializes a new instance of the ActorService class.

FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory)

Initializes a new instance of the ActorService class.

FabricActorService(StatefulServiceContext context, ActorTypeInformation actorTypeInfo, BiFunction<FabricActorService, ActorId, ActorBase> actorFactory, BiFunction<ActorBase, ActorStateProvider, ActorStateManager> stateManagerFactory, ActorStateProvider stateProvider, ActorServiceSettings settings)

Initializes a new instance of the ActorService class.

方法

createServiceReplicaListeners()

Creates Service Replica Listeners.

deleteActorAsync(ActorId actorId, CancellationToken cancellationToken)

Deletes an Actor from the Actor service.

An active actor, will be deactivated and its state will also be deleted from state provider. An in-active actor's state will be deleted from state provider. If this method is called for a non-existent actor id in the system, it will be a no-op.

getActorsAsync(ContinuationToken continuationToken, CancellationToken cancellationToken)

Gets the list of Actors by querying the actor service.

getActorTypeInformation()

Gets ActorTypeInformation for actor service.

getSettings()

Gets settings for the actor service.

getStateProvider()

Gets a ActorStateProvider that represents the state provider for the actor service.

onAbort()

Overrides onAbort()

onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Overrides onChangeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

onCloseAsync(CancellationToken cancellationToken)

Overrides onCloseAsync(CancellationToken cancellationToken)

onOpenAsync(ReplicaOpenMode openMode, CancellationToken cancellationToken)

This method is called as the final step of opening the service. Override this method to be notified that Open has completed for this replica's internal components.

runAsync(CancellationToken cancellationToken)

Overrides runAsync(CancellationToken cancellationToken)

适用于