File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed
Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -7,6 +7,7 @@ import { eventStrategyFactory } from './event-strategy-factory'
77import { IEventRepository } from '../@types/repositories'
88import { isDelegatedEvent } from '../utils/event'
99import { IWebSocketAdapter } from '../@types/adapters'
10+ import { slidingWindowRateLimiterFactory } from './rate-limiter-factory'
1011import { SubscribeMessageHandler } from '../handlers/subscribe-message-handler'
1112import { UnsubscribeMessageHandler } from '../handlers/unsubscribe-message-handler'
1213
@@ -20,11 +21,17 @@ export const messageHandlerFactory = (
2021 return new DelegatedEventMessageHandler (
2122 adapter ,
2223 delegatedEventStrategyFactory ( eventRepository ) ,
23- createSettings
24+ createSettings ,
25+ slidingWindowRateLimiterFactory ,
2426 )
2527 }
2628
27- return new EventMessageHandler ( adapter , eventStrategyFactory ( eventRepository ) , createSettings )
29+ return new EventMessageHandler (
30+ adapter ,
31+ eventStrategyFactory ( eventRepository ) ,
32+ createSettings ,
33+ slidingWindowRateLimiterFactory ,
34+ )
2835 }
2936 case MessageType . REQ :
3037 return new SubscribeMessageHandler ( adapter , eventRepository , createSettings )
You can’t perform that action at this time.
0 commit comments