fix amqp+bunny dsn

makasim · makasim · commit ea93f2b0bf47 · 2017-10-11T13:49:37.000+03:00
diff --git a/pkg/enqueue/functions.php b/pkg/enqueue/functions.php
@@ -38,7 +38,7 @@ function dsn_to_connection_factory($dsn)
     if (class_exists(AmqpBunnyConnectionFactory::class)) {
         $map['amqp+lib'] = AmqpLibConnectionFactory::class;
     }
-    if (class_exists(AmqpLibConnectionFactory::class)) {
+    if (class_exists(AmqpBunnyConnectionFactory::class)) {
         $map['amqp+bunny'] = AmqpBunnyConnectionFactory::class;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ function dsn_to_connection_factory($dsn)`
`38`	`38`	`if (class_exists(AmqpBunnyConnectionFactory::class)) {`
`39`	`39`	`$map['amqp+lib'] = AmqpLibConnectionFactory::class;`
`40`	`40`	`}`
`41`		`- if (class_exists(AmqpLibConnectionFactory::class)) {`
	`41`	`+ if (class_exists(AmqpBunnyConnectionFactory::class)) {`
`42`	`42`	`$map['amqp+bunny'] = AmqpBunnyConnectionFactory::class;`
`43`	`43`	`}`
`44`	`44`