@@ -69,13 +69,13 @@ public function pop($queue = null)
69
69
$ queueId = explode ('/ ' , $ queue );
70
70
$ queueId = array_pop ($ queueId );
71
71
72
- $ count = (array_key_exists ($ queue , Config::get ('sqs-queue-reader.handlers ' )))
73
- ? Config::get ('sqs-queue-reader.handlers ' )[$ queue ]['count ' ]
72
+ $ count = (array_key_exists ($ queueId , Config::get ('sqs-queue-reader.handlers ' )))
73
+ ? Config::get ('sqs-queue-reader.handlers ' )[$ queueId ]['count ' ]
74
74
: Config::get ('sqs-queue-reader.default-handler ' )['count ' ];
75
75
76
76
try {
77
77
$ response = $ this ->sqs ->receiveMessage ([
78
- 'QueueUrl ' => $ queue ,
78
+ 'QueueUrl ' => $ queueId ,
79
79
'AttributeNames ' => ['ApproximateReceiveCount ' ],
80
80
'MaxNumberOfMessages ' => $ count ,
81
81
'MessageAttributeNames ' => ['All ' ],
@@ -95,7 +95,7 @@ public function pop($queue = null)
95
95
}
96
96
Log::debug ('New $responseV2== ' , [$ response ]);
97
97
98
- return new SqsJob ($ this ->container , $ this ->sqs , $ response , $ this ->connectionName , $ queue );
98
+ return new SqsJob ($ this ->container , $ this ->sqs , $ response , $ this ->connectionName , $ queueId );
99
99
}
100
100
} catch (AwsException $ e ) {
101
101
$ msg = 'Line: ' . $ e ->getLine () .', ' . $ e ->getFile () . ', ' . $ e ->getMessage ();
0 commit comments