Class NatsSvcServer

Namespace

NATS.Client.Services

Assembly

NATS.Client.Services.dll

NATS service server.

public class NatsSvcServer : INatsSvcServer, IAsyncDisposable

Inheritance

object

NatsSvcServer

Implements

INatsSvcServer

IAsyncDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NatsSvcServer(INatsConnection, NatsSvcConfig, CancellationToken)

Creates a new instance of NatsSvcServer.

Methods

AddEndpointAsync<T>(Func<NatsSvcMsg<T>, ValueTask>, string?, string?, string?, IDictionary<string, string>?, INatsDeserialize<T>?, CancellationToken)

Adds a new endpoint.

AddGroupAsync(string, string?, CancellationToken)

Adds a new service group with optional queue group.

DisposeAsync()

Stop the service.

GetInfo()

Get current info for the service.

GetStats()

Get current stats for the service.

StopAsync(CancellationToken)

Stop the service.