Imports System
Imports StackExchange.Redis

Class RedisManager

   ' connessione al server Redis
   Private m_RedisConnection As ConnectionMultiplexer
   Public ReadOnly Property RedisConnection As ConnectionMultiplexer
      Get
         Return m_RedisConnection
      End Get
   End Property

   ' gestore sottoscrizioni
   Private m_Subscriber As ISubscriber
   Public ReadOnly Property Subscriber As ISubscriber
      Get
         If m_Subscriber Is Nothing Then
            ' inizializzo sottoscrizione
            m_Subscriber = m_RedisConnection.GetSubscriber()
         End If
         Return m_Subscriber
      End Get
   End Property

   Sub New(sConnection As String)
      Try
         ' inizializzo connessione al server Redis
         m_RedisConnection = ConnectionMultiplexer.Connect(sConnection)
      Catch ex As Exception
         System.Console.WriteLine("Redis connection error!! " & Environment.NewLine & ex.Message)
      End Try
   End Sub

   Friend Sub SubscribeChannel(sName As String, Handler As Action(Of RedisChannel, RedisValue))
      Dim InputChn As New RedisChannel(sName, RedisChannel.PatternMode.Auto)
      Subscriber.Subscribe(InputChn, Handler)
   End Sub

End Class