|
7 | 7 | use Aws\Sqs\SqsClient;
|
8 | 8 | use BadMethodCallException;
|
9 | 9 | use InvalidArgumentException;
|
| 10 | +use Illuminate\Support\Collection; |
10 | 11 | use Illuminate\Mail\SendQueuedMailable;
|
11 | 12 | use Illuminate\Queue\CallQueuedHandler;
|
12 | 13 | use ShiftOneLabs\LaravelSqsFifoQueue\SqsFifoQueue;
|
@@ -72,7 +73,7 @@ public function test_queue_sends_message_group_id_from_notification()
|
72 | 73 | $group = 'job-group';
|
73 | 74 | $notification = new Notification();
|
74 | 75 | $notification->onMessageGroup($group);
|
75 |
| - $job = new SendQueuedNotifications('notifiables', $notification); |
| 76 | + $job = new SendQueuedNotifications(new Collection(['notifiables']), $notification); |
76 | 77 | $closure = function ($message) use ($group) {
|
77 | 78 | if ($message['MessageGroupId'] != $group) {
|
78 | 79 | return false;
|
@@ -233,7 +234,7 @@ public function test_queue_uses_deduplicator_from_notification()
|
233 | 234 | $deduplication = 'content';
|
234 | 235 | $notification = new Notification();
|
235 | 236 | $notification->withDeduplicator($deduplication);
|
236 |
| - $job = new SendQueuedNotifications('notifiables', $notification); |
| 237 | + $job = new SendQueuedNotifications(new Collection(['notifiables']), $notification); |
237 | 238 | $closure = function ($message) use ($deduplication) {
|
238 | 239 | $deduplicator = $this->app->make('queue.sqs-fifo.deduplicator.'.$deduplication);
|
239 | 240 | $deduplicationId = $deduplicator->generate($message['MessageBody'], null);
|
|
0 commit comments