File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -52,8 +52,8 @@ private function getClass($queue = null): string
52
52
$ queue = end ($ queueArray );
53
53
54
54
return (array_key_exists ($ queue , Config::get ('sqs-queue-reader.handlers ' )))
55
- ? Config::get ('sqs-queue-reader.handlers ' )[$ queue ]
56
- : Config::get ('sqs-queue-reader.default-handler ' );
55
+ ? Config::get ('sqs-queue-reader.handlers ' )[$ queue ][ ' class ' ]
56
+ : Config::get ('sqs-queue-reader.default-handler ' )[ ' class ' ] ;
57
57
}
58
58
59
59
/**
@@ -83,8 +83,8 @@ public function pop($queue = null)
83
83
$ queueId = array_pop ($ queueId );
84
84
85
85
$ class = (array_key_exists ($ queueId , $ this ->container ['config ' ]->get ('sqs-queue-reader.handlers ' )))
86
- ? $ this ->container ['config ' ]->get ('sqs-queue-reader.handlers ' )[$ queueId ]
87
- : $ this ->container ['config ' ]->get ('sqs-queue-reader.default-handler ' );
86
+ ? $ this ->container ['config ' ]->get ('sqs-queue-reader.handlers ' )[$ queueId ][ ' class ' ]
87
+ : $ this ->container ['config ' ]->get ('sqs-queue-reader.default-handler ' )[ ' class ' ] ;
88
88
89
89
if ($ count === 1 ) {
90
90
$ response = $ this ->modifySinglePayload ($ response ['Messages ' ][0 ], $ class );
You can’t perform that action at this time.
0 commit comments