huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add prefix to redis channel names

This commit is contained in:
BrennanConroy 2016-11-15 16:07:56 -08:00
parent 4aa65cf0bf
commit 35a1c4fae7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Microsoft.AspNetCore.SignalR.Redis/RedisHubLifetimeManager.cs
View File

@ -87,7 +87,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
Arguments = args Arguments = args
}; };
return PublishAsync(typeof(THub).FullName + "." + groupName, message); return PublishAsync(typeof(THub).FullName + ".group." + groupName, message);
} }
public override Task InvokeUserAsync(string userId, string methodName, object[] args) public override Task InvokeUserAsync(string userId, string methodName, object[] args)
@ -98,7 +98,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
Arguments = args Arguments = args
}; };
return PublishAsync(typeof(THub).FullName + "." + userId, message); return PublishAsync(typeof(THub).FullName + ".user." + userId, message);
} }
private async Task PublishAsync(string channel, InvocationDescriptor message) private async Task PublishAsync(string channel, InvocationDescriptor message)
@ -138,7 +138,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
if (connection.User.Identity.IsAuthenticated) if (connection.User.Identity.IsAuthenticated)
{ {
var userChannel = typeof(THub).FullName + "." + connection.User.Identity.Name; var userChannel = typeof(THub).FullName + ".user." + connection.User.Identity.Name;
redisSubscriptions.Add(userChannel); redisSubscriptions.Add(userChannel);
var previousUserTask = Task.CompletedTask; var previousUserTask = Task.CompletedTask;
@ -187,7 +187,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
public override async Task AddGroupAsync(Connection connection, string groupName) public override async Task AddGroupAsync(Connection connection, string groupName)
{ {
var groupChannel = typeof(THub).FullName + "." + groupName; var groupChannel = typeof(THub).FullName + ".group." + groupName;
var groupNames = connection.Metadata.GetOrAdd("group", _ => new HashSet<string>()); var groupNames = connection.Metadata.GetOrAdd("group", _ => new HashSet<string>());
@ -235,7 +235,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
public override async Task RemoveGroupAsync(Connection connection, string groupName) public override async Task RemoveGroupAsync(Connection connection, string groupName)
{ {
var groupChannel = typeof(THub).FullName + "." + groupName; var groupChannel = typeof(THub).FullName + ".group." + groupName;
GroupData group; GroupData group;
if (!_groups.TryGetValue(groupChannel, out group)) if (!_groups.TryGetValue(groupChannel, out group))