Skip to main content

RedisPubSubServer

Assembly: ServiceStack.Redis.dll
View Source
Declaration
public class RedisPubSubServer : IRedisPubSubServer, IDisposable

Properties

OnInit

View Source
Declaration
public Action OnInit { get; set; }

OnStart

View Source
Declaration
public Action OnStart { get; set; }

OnHeartbeatSent

View Source
Declaration
public Action OnHeartbeatSent { get; set; }

OnHeartbeatReceived

View Source
Declaration
public Action OnHeartbeatReceived { get; set; }

OnStop

View Source
Declaration
public Action OnStop { get; set; }

OnDispose

View Source
Declaration
public Action OnDispose { get; set; }

OnMessage

Callback fired on each message received, handle with (channel, msg) => ...

View Source
Declaration
public Action<string, string> OnMessage { get; set; }

OnMessageBytes

View Source
Declaration
public Action<string, byte[]> OnMessageBytes { get; set; }

OnControlCommand

View Source
Declaration
public Action<string> OnControlCommand { get; set; }

OnUnSubscribe

View Source
Declaration
public Action<string> OnUnSubscribe { get; set; }

OnEvent

View Source
Declaration
public Action<string> OnEvent { get; set; }

OnError

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

OnFailover

View Source
Declaration
public Action<IRedisPubSubServer> OnFailover { get; set; }

IsSentinelSubscription

View Source
Declaration
public bool IsSentinelSubscription { get; set; }

AutoRestart

View Source
Declaration
public bool AutoRestart { get; set; }

CurrentServerTime

View Source
Declaration
public DateTime CurrentServerTime { get; }

BgThreadCount

View Source
Declaration
public long BgThreadCount { get; }

ClientsManager

View Source
Declaration
public IRedisClientsManager ClientsManager { get; set; }

Channels

View Source
Declaration
public string[] Channels { get; set; }

ChannelsMatching

View Source
Declaration
public string[] ChannelsMatching { get; set; }

WaitBeforeNextRestart

View Source
Declaration
public TimeSpan? WaitBeforeNextRestart { get; set; }

Fields

HeartbeatInterval

View Source
Declaration
public TimeSpan? HeartbeatInterval

HeartbeatTimeout

View Source
Declaration
public TimeSpan HeartbeatTimeout

AllChannelsWildCard

View Source
Declaration
public const string AllChannelsWildCard = "*"

Methods

Start()

View Source
Declaration
public IRedisPubSubServer Start()
Returns

ServiceStack.Redis.IRedisPubSubServer

Stop()

View Source
Declaration
public void Stop()

Restart()

View Source
Declaration
public void Restart()

GetStatus()

View Source
Declaration
public string GetStatus()
Returns

System.String

GetStatsDescription()

View Source
Declaration
public string GetStatsDescription()
Returns

System.String

Dispose()

View Source
Declaration
public virtual void Dispose()

Implements