Class PubsubService

Namespace

Virtufin.Api.Services

Assembly

Virtufin.Api.dll

Implements the Pubsub gRPC service for publish/subscribe messaging via Dapr.

public class PubsubService : Pubsub.PubsubBase

Inheritance

object

Pubsub.PubsubBase

PubsubService

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PubsubService(DaprClient, IServiceProvider, PubsubSubscriptionManager, ILogger<PubsubService>)

public PubsubService(DaprClient daprClient, IServiceProvider serviceProvider, PubsubSubscriptionManager subscriptionManager, ILogger<PubsubService> logger)

Parameters

daprClient DaprClient

serviceProvider IServiceProvider

subscriptionManager PubsubSubscriptionManager

logger ILogger<PubsubService>

Methods

PublishEvent(PublishRequest, ServerCallContext)

public override Task<PublishResponse> PublishEvent(PublishRequest request, ServerCallContext context)

Parameters

request PublishRequest

context ServerCallContext

Returns

Task<PublishResponse>

Subscribe(PubsubSubscribeRequest, IServerStreamWriter<PubsubSubscribeResponse>, ServerCallContext)

Handles a client subscribe request. Creates a Dapr subscription for the topic and streams received messages back to the client via gRPC server streaming. Messages are enhanced with correlationid from CloudEvent data and extensions.

public override Task Subscribe(PubsubSubscribeRequest request, IServerStreamWriter<PubsubSubscribeResponse> responseStream, ServerCallContext context)

Parameters

request PubsubSubscribeRequest

responseStream IServerStreamWriter<PubsubSubscribeResponse>

context ServerCallContext

Returns

Task

Unsubscribe(UnsubscribeRequest, ServerCallContext)

public override Task<UnsubscribeResponse> Unsubscribe(UnsubscribeRequest request, ServerCallContext context)

Parameters

request UnsubscribeRequest

context ServerCallContext

Returns

Task<UnsubscribeResponse>