File tree 4 files changed +19
-1
lines changed
4 files changed +19
-1
lines changed Original file line number Diff line number Diff line change @@ -20,6 +20,7 @@ public function toOptionArray()
20
20
['value ' => 'sqs ' , 'label ' => __ ('Amazon AWS SQS ' )],
21
21
['value ' => 'redis ' , 'label ' => __ ('Redis ' )],
22
22
['value ' => 'dbal ' , 'label ' => __ ('Doctrine DBAL ' )],
23
+ ['value ' => 'null ' , 'label ' => __ ('Null transport ' )],
23
24
];
24
25
}
25
26
}
Original file line number Diff line number Diff line change @@ -141,6 +141,9 @@ public function buildConfig()
141
141
case 'dbal ' :
142
142
$ config ['transport ' ] = $ this ->getDbalConfig ();
143
143
break ;
144
+ case 'null ' :
145
+ $ config ['transport ' ] = $ this ->getNullConfig ();
146
+ break ;
144
147
default :
145
148
throw new \LogicException (sprintf ('Unknown transport: "%s" ' , $ name ));
146
149
}
@@ -281,4 +284,12 @@ public function getDbalConfig()
281
284
'lazy ' => (bool ) $ this ->scopeConfig ->getValue ('enqueue/dbal/lazy ' ),
282
285
]];
283
286
}
287
+
288
+ /**
289
+ * @return array
290
+ */
291
+ private function getNullConfig (): array
292
+ {
293
+ return ['null ' => []];
294
+ }
284
295
}
Original file line number Diff line number Diff line change 3
3
namespace Enqueue \Magento2 \Plugin \Model \Config ;
4
4
5
5
use \Enqueue \AmqpExt \AmqpContext ;
6
+ use Enqueue \Null \NullContext ;
6
7
use \Enqueue \Stomp \StompContext ;
7
8
use \Enqueue \Fs \FsContext ;
8
9
use \Enqueue \Sqs \SqsContext ;
@@ -55,6 +56,11 @@ class ConfigPlugin
55
56
'name ' => 'Doctrine DBAL ' ,
56
57
'package ' => 'enqueue/dbal ' ,
57
58
'class ' => DbalContext::class,
59
+ ],
60
+ 'null ' => [
61
+ 'name ' => 'Null transport ' ,
62
+ 'package ' => 'enqueue/null ' ,
63
+ 'class ' => NullContext::class
58
64
]
59
65
];
60
66
Original file line number Diff line number Diff line change 4
4
<default >
5
5
<enqueue >
6
6
<transport >
7
- <default >rabbitmq_amqp </default >
7
+ <default >null </default >
8
8
</transport >
9
9
<client >
10
10
<prefix >enqueue</prefix >
You can’t perform that action at this time.
0 commit comments