Skip to main content

ServerEventsFeature

Assembly: ServiceStack.dll​
View Source​
Declaration
public class ServerEventsFeature : IPlugin, IHasStringId, IHasId<string>

Properties​

Id​

View Source​
Declaration
public string Id { get; set; }

StreamPath​

View Source​
Declaration
public string StreamPath { get; set; }

HeartbeatPath​

View Source​
Declaration
public string HeartbeatPath { get; set; }

SubscribersPath​

View Source​
Declaration
public string SubscribersPath { get; set; }

UnRegisterPath​

View Source​
Declaration
public string UnRegisterPath { get; set; }

IdleTimeout​

View Source​
Declaration
public TimeSpan IdleTimeout { get; set; }

HeartbeatInterval​

View Source​
Declaration
public TimeSpan HeartbeatInterval { get; set; }

HouseKeepingInterval​

View Source​
Declaration
public TimeSpan HouseKeepingInterval { get; set; }

OnInit​

View Source​
Declaration
public Action<IRequest> OnInit { get; set; }

OnHeartbeatInit​

View Source​
Declaration
public Action<IRequest> OnHeartbeatInit { get; set; }

OnCreated​

View Source​
Declaration
public Action<IEventSubscription, IRequest> OnCreated { get; set; }

OnConnect​

View Source​
Declaration
public Action<IEventSubscription, Dictionary<string, string>> OnConnect { get; set; }

OnSubscribe​

View Source​
Declaration
public Action<IEventSubscription> OnSubscribe { get; set; }

OnDispose​

View Source​
Declaration
public Action<IEventSubscription, IRequest> OnDispose { get; set; }

OnSubscribeAsync​

Calls sync OnSubscribe if exists by default

View Source​
Declaration
public Func<IEventSubscription, Task> OnSubscribeAsync { get; set; }

OnUnsubscribe​

View Source​
Declaration
public Action<IEventSubscription> OnUnsubscribe { get; set; }

OnUnsubscribeAsync​

Calls sync OnUnsubscribe if exists by default

View Source​
Declaration
public Func<IEventSubscription, Task> OnUnsubscribeAsync { get; set; }

OnPublish​

Fired for both Sync/Async Notifications

View Source​
Declaration
public Action<IEventSubscription, IResponse, string> OnPublish { get; set; }

OnPublishAsync​

Only fired for async notifications. Calls sync OnPublish if exists by default.

View Source​
Declaration
public Func<IEventSubscription, IResponse, string, Task> OnPublishAsync { get; set; }

OnUpdateAsync​

Fired when a subscription is updated

View Source​
Declaration
public Func<IEventSubscription, Task> OnUpdateAsync { get; set; }

Serialize​

Replace the default ServiceStack.Text JSON Serializer with an alternative JSON Serializer

View Source​
Declaration
public Func<object, string> Serialize { get; set; }

WriteEvent​

View Source​
Declaration
public Action<IResponse, string> WriteEvent { get; }

WriteEventAsync​

View Source​
Declaration
public Func<IResponse, string, CancellationToken, Task> WriteEventAsync { get; }

OnHungConnection​

Invoked when a connection

View Source​
Declaration
public Action<IEventSubscription> OnHungConnection { get; set; }

OnError​

View Source​
Declaration
public Action<IEventSubscription, Exception> OnError { get; set; }

NotifyChannelOfSubscriptions​

View Source​
Declaration
public bool NotifyChannelOfSubscriptions { get; set; }

LimitToAuthenticatedUsers​

View Source​
Declaration
public bool LimitToAuthenticatedUsers { get; set; }

ValidateUserAddress​

View Source​
Declaration
public bool ValidateUserAddress { get; set; }

ThrottlePublisherAfterBufferExceedsBytes​

View Source​
Declaration
public int ThrottlePublisherAfterBufferExceedsBytes { get; set; }

Methods​

IncrementCounter(String)​

View Source​
Declaration
public void IncrementCounter(string name)
Parameters​
TypeName
System.Stringname

Register(IAppHost)​

View Source​
Declaration
public void Register(IAppHost appHost)
Parameters​
TypeName
ServiceStack.IAppHostappHost

Implements​