File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
src/Transports/SseAdapters Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 1717final class RedisAdapter implements SseAdapterInterface
1818{
1919 const FAILED_TO_INITIALIZE = 'Failed to initialize Redis SSE Adapter: ' ;
20+
2021 /**
2122 * Redis connection instance
2223 */
@@ -38,13 +39,13 @@ public function __construct(
3839 ) {
3940 try {
4041 $ this ->keyPrefix = $ this ->config ['prefix ' ] ?? 'mcp_sse_ ' ;
41- $ this ->messageTtl = (int )$ this ->config ['ttl ' ] ?: 100 ;
42+ $ this ->messageTtl = (int ) $ this ->config ['ttl ' ] ?: 100 ;
4243 $ this ->redis = new Redis ;
4344 $ this ->redis ->connect ($ this ->config ['connection ' ], 6379 );
4445 $ this ->redis ->setOption (Redis::OPT_PREFIX , $ this ->keyPrefix );
4546 } catch (Exception $ e ) {
46- $ this ->logger ?->error(self ::FAILED_TO_INITIALIZE .$ e ->getMessage ());
47- throw new \Exception (self ::FAILED_TO_INITIALIZE .$ e ->getMessage ());
47+ $ this ->logger ?->error(self ::FAILED_TO_INITIALIZE .$ e ->getMessage ());
48+ throw new \Exception (self ::FAILED_TO_INITIALIZE .$ e ->getMessage ());
4849 }
4950 }
5051
You can’t perform that action at this time.
0 commit comments