diff --git a/src/Queue/Connectors/SqsFifoConnector.php b/src/Queue/Connectors/SqsFifoConnector.php index de28266..6b58872 100644 --- a/src/Queue/Connectors/SqsFifoConnector.php +++ b/src/Queue/Connectors/SqsFifoConnector.php @@ -22,7 +22,7 @@ public function connect(array $config) { $config = $this->getDefaultConfiguration($config); - if (!Str::endsWith($config['queue'], '.fifo')) { + if (!empty($config['queue']) && !Str::endsWith($config['queue'], '.fifo')) { throw new InvalidArgumentException('FIFO queue name must end in ".fifo"'); }