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.

RemoveEndpointAsync(string, CancellationToken)

Removes an endpoint by name, draining and disposing it.

StopAsync(CancellationToken)

Stop the service.