Skip to content
This repository was archived by the owner on Dec 24, 2022. It is now read-only.

Commit cf29ba5

Browse files
committed
Added IMessageService.RegisteredTypes
1 parent 09598cf commit cf29ba5

9 files changed

+11
-0
lines changed

lib/ServiceStack.Common.dll

512 Bytes
Binary file not shown.

lib/ServiceStack.Interfaces.dll

512 Bytes
Binary file not shown.
512 Bytes
Binary file not shown.
2 KB
Binary file not shown.
0 Bytes
Binary file not shown.
0 Bytes
Binary file not shown.

src/ServiceStack.Redis/Messaging/RedisMqHost.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -91,6 +91,11 @@ public RedisMqHost(IRedisClientsManager clientsManager,
9191
private readonly Dictionary<Type, IMessageHandlerFactory> handlerMap
9292
= new Dictionary<Type, IMessageHandlerFactory>();
9393

94+
public List<Type> RegisteredTypes
95+
{
96+
get { return handlerMap.Keys.ToList(); }
97+
}
98+
9499
private IMessageHandler[] messageHandlers;
95100
private string[] inQueueNames;
96101

src/ServiceStack.Redis/Messaging/RedisMqHostPool.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,8 @@ public virtual void Stop()
161161
}
162162

163163
public IMessageFactory MessageFactory { get; set; }
164+
165+
public List<Type> RegisteredTypes { get; private set; }
164166

165167
public virtual void Dispose()
166168
{

src/ServiceStack.Redis/Messaging/RedisMqServer.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,10 @@ private readonly Dictionary<Type, int> handlerThreadCountMap
115115
private MessageHandlerWorker[] workers;
116116
private Dictionary<string, int[]> queueWorkerIndexMap;
117117

118+
public List<Type> RegisteredTypes
119+
{
120+
get { return handlerMap.Keys.ToList(); }
121+
}
118122

119123
public RedisMqServer(IRedisClientsManager clientsManager,
120124
int retryCount = DefaultRetryCount, TimeSpan? requestTimeOut = null)

0 commit comments

Comments
 (0)