Share via

ActorEventProxy Class

  • Reference
Package:
microsoft.servicefabric.actors.runtime
  • java.lang.Object
    • ProxyBase
      • microsoft.servicefabric.actors.runtime.ActorEventProxy

public class ActorEventProxy extends ProxyBase

Provides the base implementation for the proxy to invoke methods on actor event subscribers.

Constructor Summary

Constructor Description
ActorEventProxy()

Initializes a new instance of the ActorEventProxy class.

Method Summary

Modifier and Type Method and Description
Object createRequestMessageBody(Object requestMessageBodyValue)
Object deserializeMessage(byte[] msgBodyValue)
Object getResponseMessageBodyValue(Object responseMessageBody)
void invoke(int interfaceId, int methodId, byte[] requestMsgBodyBytes)
CompletableFuture<byte[]> invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes)
byte [] serializeMessage(Object msgBodyValue)

Inherited Members

ProxyBase.continueWith(CompletableFuture<Object> future) ProxyBase.getReturnValue(int interfaceId, int methodId, Object responseBody) ProxyBase.invoke(int interfaceId, int methodId, Object requestMsgBodyValue) ProxyBase.invokeAsync(int interfaceId, int methodId, Object requestMsgBodyValue, CancellationToken cancellationToken) ProxyBase.invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes, CancellationToken cancellationToken) ProxyBase.ProxyBase()

Constructor Details

ActorEventProxy

protected ActorEventProxy()

Initializes a new instance of the ActorEventProxy class.

Method Details

createRequestMessageBody

protected Object createRequestMessageBody(Object requestMessageBodyValue)

Parameters:

requestMessageBodyValue

deserializeMessage

protected Object deserializeMessage(byte[] msgBodyValue)

Parameters:

msgBodyValue

getResponseMessageBodyValue

protected Object getResponseMessageBodyValue(Object responseMessageBody)

Parameters:

responseMessageBody

invoke

protected void invoke(int interfaceId, int methodId, byte[] requestMsgBodyBytes)

Parameters:

interfaceId
methodId
requestMsgBodyBytes

invokeAsync

protected CompletableFuture invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes)

Parameters:

interfaceId
methodId
requestMsgBodyBytes

serializeMessage

protected byte [] serializeMessage(Object msgBodyValue)

Parameters:

msgBodyValue

Applies to