This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
SignalR.SqlMessageBus Information: 0 : Start installing SignalR SQL objects | |
SignalR.SqlMessageBus Information: 0 : Start installing SignalR SQL objects | |
SignalR.SqlMessageBus Information: 0 : SignalR SQL objects installed | |
SignalR.SqlMessageBus Information: 0 : SignalR SQL objects installed | |
SignalR.ScaleoutMessageBus Information: 0 : Stream(0) - Changed state from Initial to Open | |
SignalR.SqlMessageBus Verbose: 0 : Stream 0 : Starting SQL notification listener | |
SignalR.SqlMessageBus Verbose: 0 : Stream 0 : Starting SQL notification listener | |
SignalR.SqlMessageBus Verbose: 0 : Stream 0 : SQL notification listener started | |
SignalR.SqlMessageBus Verbose: 0 : Stream 0 : SQL notification listener started | |
SignalR.SqlMessageBus Verbose: 0 : Stream 0 : No records received |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public class RedisMessageBus : ScaleoutMessageBus | |
{ | |
private readonly string _server; | |
private readonly int _port; | |
private readonly string _password; | |
private readonly int _db; | |
private readonly string[] _keys; | |
private RedisConnection _connection; | |
private RedisSubscriberConnection _channel; | |
private Task _connectTask; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// This class is actually in a different assembly & namespace fro ServiceHost in my solution, | |
// you may or may not need that. | |
namespace ServiceHost | |
{ | |
public class ServiceBusEndpoint | |
{ | |
public static void ConfigureNewInstanceForAppDomain() | |
{ | |
// Call NSB configuration | |
Configure.With() |