Magento 2 Documentation  2.3
Documentation for Magento 2 CMS v2.3 (December 2018)
expected_topic_config.php
Go to the documentation of this file.
1 <?php
7 return [
8  'publishers' => [
9  'amqp-ex.01' => [
10  'name' => 'amqp-ex.01',
11  'connection' => 'amqp',
12  'exchange' => 'ex.01',
13  ],
14  'db-magento' => [
15  'name' => 'db-magento',
16  'connection' => 'db',
17  'exchange' => 'magento',
18  ],
19  'amqp-magento' => [
20  'name' => 'amqp-magento',
21  'connection' => 'amqp',
22  'exchange' => 'magento',
23  ],
24  ],
25  'binds' => [
26  'top.01--ex.01--q.01' => ['queue' => 'q.01', 'exchange' => 'ex.01', 'topic' => 'top.01'],
27  'top.03--magento--q.03' => ['queue' => 'q.03', 'exchange' => 'magento', 'topic' => 'top.03'],
28  'top.04--magento--q.04' => ['queue' => 'q.04', 'exchange' => 'magento', 'topic' => 'top.04'],
29  'top.04--magento--q.05' => ['queue' => 'q.05', 'exchange' => 'magento', 'topic' => 'top.04'],
30  'top.04--magento--q.06' => ['queue' => 'q.06', 'exchange' => 'magento', 'topic' => 'top.04'],
31  'top.03--magento--q.04' => ['queue' => 'q.04', 'exchange' => 'magento', 'topic' => 'top.03'],
32  'user.created.remote--magento--q.log' => [
33  'queue' => 'q.log', 'exchange' => 'magento', 'topic' => 'user.created.remote'
34  ],
35  'product.created.local--magento--q.log' => [
36  'queue' => 'q.log', 'exchange' => 'magento', 'topic' => 'product.created.local'
37  ],
38  ],
39  'exchange_topic_to_queues_map' => [
40  'amqp-ex.01--top.01' => ['q.01'],
41  'amqp-magento--top.03' => ['q.03', 'q.04'],
42  'db-magento--top.04' => ['q.04', 'q.05', 'q.06'],
43  'amqp-magento--user.created.remote' => ['q.log'],
44  'amqp-magento--product.created.local' => ['q.log'],
45  ],
46  'consumers' => [
47  'cons.01' => [
48  'name' => 'cons.01',
49  'handlers' => [
50  'top.01' => [
51  '0' => [
52  'type' => 'Magento\Handler\Class\Name',
53  'method' => 'methodName'
54  ]
55  ]
56  ],
57  'instance_type' => 'Magento\Consumer\Instance',
58  'consumer_type' => 'async',
59  'max_messages' => '512',
60  'connection' => 'amqp',
61  'queue' => 'q.01'
62  ],
63  'cons.03' => [
64  'name' => 'cons.03',
65  'handlers' => [
66  'top.03' => [
67  '0' => [
68  'type' => \Magento\Customer\Api\CustomerRepositoryInterface::class,
69  'method' => 'save',
70  ],
71  '1' => [
72  'type' => \Magento\Customer\Api\CustomerRepositoryInterface::class,
73  'method' => 'delete',
74  ],
75  ]
76  ],
77  'instance_type' => 'Magento\Framework\MessageQueue\ConsumerInterface',
78  'consumer_type' => 'async',
79  'max_messages' => null,
80  'connection' => 'amqp',
81  'queue' => 'q.03'
82  ],
83  'cons.04' => [
84  'name' => 'cons.04',
85  'handlers' => [
86  'top.04' => [
87  '0' => [
88  'type' => 'Magento\Handler\Class\Name',
89  'method' => 'methodName'
90  ]
91  ]
92  ],
93  'instance_type' => 'Magento\Consumer\Instance',
94  'consumer_type' => 'async',
95  'max_messages' => '512',
96  'connection' => 'db',
97  'queue' => 'q.04'
98  ],
99  'cons.05' => [
100  'name' => 'cons.05',
101  'handlers' => [
102  'top.04' => [
103  '0' => [
104  'type' => 'Magento\Handler\Class\Name',
105  'method' => 'methodName'
106  ]
107  ]
108  ],
109  'instance_type' => 'Magento\Consumer\Instance',
110  'consumer_type' => 'async',
111  'max_messages' => '512',
112  'connection' => 'db',
113  'queue' => 'q.05'
114  ],
115  'cons.06' => [
116  'name' => 'cons.06',
117  'handlers' => [
118  'top.04' => [
119  '0' => [
120  'type' => 'Magento\Handler\Class\Name',
121  'method' => 'methodName'
122  ]
123  ]
124  ],
125  'instance_type' => 'Magento\Consumer\Instance',
126  'consumer_type' => 'async',
127  'max_messages' => '512',
128  'connection' => 'db',
129  'queue' => 'q.06'
130  ],
131  'cons.07' => [
132  'name' => 'cons.07',
133  'handlers' => [
134  'top.03' => [
135  '0' => [
136  'type' => \Magento\Customer\Api\CustomerRepositoryInterface::class,
137  'method' => 'save',
138  ],
139  '1' => [
140  'type' => \Magento\Customer\Api\CustomerRepositoryInterface::class,
141  'method' => 'delete',
142  ],
143  ]
144  ],
145  'instance_type' => 'Magento\Framework\MessageQueue\ConsumerInterface',
146  'consumer_type' => 'async',
147  'max_messages' => null,
148  'connection' => 'amqp',
149  'queue' => 'q.04'
150  ],
151  'cons.logger' => [
152  'name' => 'cons.logger',
153  'handlers' => [
154  'product.created.local' => [
155  '0' => [
156  'type' => 'Magento\Handler\Class\Name',
157  'method' => 'logger'
158  ]
159  ]
160  ],
161  'instance_type' => 'Magento\Framework\MessageQueue\ConsumerInterface',
162  'consumer_type' => 'async',
163  'max_messages' => null,
164  'connection' => 'amqp',
165  'queue' => 'q.log'
166  ],
167  ],
168  'topics' => [
169  'top.01' => [
170  'name' => 'top.01',
171  'schema' => [
172  'schema_type' => 'object',
173  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
174  ],
175  'response_schema' => [
176  'schema_type' => 'object',
177  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
178  ],
179  'publisher' => 'amqp-ex.01',
180  'is_synchronous' => false,
181  ],
182  'top.03' => [
183  'name' => 'top.03',
184  'schema' => [
185  'schema_type' => 'object',
186  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
187  ],
188  'response_schema' => [
189  'schema_type' => 'object',
190  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
191  ],
192  'publisher' => 'amqp-magento',
193  'is_synchronous' => false,
194  ],
195  'top.04' => [
196  'name' => 'top.04',
197  'schema' => [
198  'schema_type' => 'object',
199  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
200  ],
201  'response_schema' => [
202  'schema_type' => 'object',
203  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
204  ],
205  'publisher' => 'db-magento',
206  'is_synchronous' => false,
207  ],
208  'user.created.remote' => [
209  'name' => 'user.created.remote',
210  'schema' => [
211  'schema_type' => 'object',
212  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
213  ],
214  'response_schema' => [
215  'schema_type' => 'object',
216  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
217  ],
218  'publisher' => 'amqp-magento',
219  'is_synchronous' => false,
220  ],
221  'product.created.local' => [
222  'name' => 'product.created.local',
223  'schema' => [
224  'schema_type' => 'object',
225  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
226  ],
227  'response_schema' => [
228  'schema_type' => 'object',
229  'schema_value' => \Magento\Customer\Api\Data\CustomerInterface::class
230  ],
231  'publisher' => 'amqp-magento',
232  'is_synchronous' => false,
233  ],
234  ]
235 
236 ];