msarchet

public static TResult Retry(this IRedisClient client, Func<TResult> Retry)
{
  try
  {
    return (TResult)Retry.Invoke(); 
  }
  catch(RedisException RedisException)
  {
    //Do Something Here To Wait
    return (TResult)Retry.Invoke();

msarchet

var oldUser = User;
User.UserStatus = (UserStatuses)Status;
var newUser = User;

using(var client = ClientManager.GetClient())
{
    client.Replace<UserModel>(UsersKey, oldUser, newUser);
}

return User;

msarchet

/*
  Sometimes you need to just udpate something and assure that it happens
*/
public static class GenericReplaceLock
{
  public static void Replace<T>(this IRedisClient Client, string key, T old, T newer)
  {
    using (var redis = Client.As<T>())
    using (var transaction = redis.CreateTransaction())
    {

msarchet

/// <summary>
/// Joins the chat.
/// </summary>
/// <param name="UserName">Name of the user.</param>
/// <param name="authguid">The authguid.</param>
/// <exception cref="System.Exception">
/// Unable to find user
/// or
/// Unable to authorize user
/// </exception>

msarchet

public async void CheckForRooms() 
{
  var getRooms = new Task<IList<RoomModel>>(() => { return _roomRepo.Rooms();  });
  var Rooms = await getRooms;
  var emptyRooms = new List<RoomModel>();
  foreach (var room in Rooms)
  {
      if (_userRoomRepo.GetUsersForRoom(room.RoomName).Any())
      {
          emptyRooms.Add(room);

msarchet

using Microsoft.AspNet.SignalR;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;

namespace noproxySignalR
{
    //This is the code required for the hub

msarchet

//This is the code required for the hub

public class TestHub :Hub
    {
        public void joinGroup()
        {
            Groups.Add(Context.ConnectionId, "base");
        }

        public void Send()

msarchet

var TinyChat = TinyChat || {};
TinyChat.ConnectionID = '';
TinyChat.Connection = null;
TinyChat.Proxy = null;


TinyChat.StartChat = function () {

    TinyChat.Connection = $.hubConnection();
    TinyChat.Connection.logging = true;

msarchet

    public class MvcApplication : System.Web.HttpApplication
    {
        protected void Application_Start()
        {
            System.Diagnostics.Debugger.Launch();
            AreaRegistration.RegisterAllAreas();
            WebApiConfig.Register(GlobalConfiguration.Configuration);
            FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
            RouteConfig.RegisterRoutes(RouteTable.Routes);
            BundleConfig.RegisterBundles(BundleTable.Bundles);

msarchet

$.connection.hub.start().done(function() { 
  $.connection.myHub.server.test(['1', '2', '3']);
});