Skip to content

Commit 3821b0c

Browse files
authored
Add $dispatchAfterCommit when running via Horizon (vyuldashev#484)
Queue won't start when running with Horizon as the arguments are wrong
1 parent 5620e46 commit 3821b0c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Queue/Connectors/RabbitMQConnector.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ protected function createQueue(
104104
case 'default':
105105
return new RabbitMQQueue($connection, $queue, $dispatchAfterCommit, $options);
106106
case 'horizon':
107-
return new HorizonRabbitMQQueue($connection, $queue, $options);
107+
return new HorizonRabbitMQQueue($connection, $queue, $dispatchAfterCommit, $options);
108108
default:
109109
return new $worker($connection, $queue, $options);
110110
}

0 commit comments

Comments
 (0)