@@ -65,6 +65,8 @@ public static function provideConfigs()
65
65
'connect_timeout ' => null ,
66
66
'persisted ' => false ,
67
67
'lazy ' => true ,
68
+ 'pre_fetch_count ' => null ,
69
+ 'pre_fetch_size ' => null ,
68
70
],
69
71
];
70
72
@@ -83,6 +85,8 @@ public static function provideConfigs()
83
85
'connect_timeout ' => null ,
84
86
'persisted ' => false ,
85
87
'lazy ' => true ,
88
+ 'pre_fetch_count ' => null ,
89
+ 'pre_fetch_size ' => null ,
86
90
],
87
91
];
88
92
@@ -99,6 +103,8 @@ public static function provideConfigs()
99
103
'connect_timeout ' => null ,
100
104
'persisted ' => false ,
101
105
'lazy ' => true ,
106
+ 'pre_fetch_count ' => null ,
107
+ 'pre_fetch_size ' => null ,
102
108
],
103
109
];
104
110
@@ -115,6 +121,8 @@ public static function provideConfigs()
115
121
'connect_timeout ' => null ,
116
122
'persisted ' => false ,
117
123
'lazy ' => true ,
124
+ 'pre_fetch_count ' => null ,
125
+ 'pre_fetch_size ' => null ,
118
126
],
119
127
];
120
128
@@ -131,6 +139,8 @@ public static function provideConfigs()
131
139
'connect_timeout ' => '2 ' ,
132
140
'persisted ' => false ,
133
141
'lazy ' => '' ,
142
+ 'pre_fetch_count ' => null ,
143
+ 'pre_fetch_size ' => null ,
134
144
],
135
145
];
136
146
@@ -147,6 +157,8 @@ public static function provideConfigs()
147
157
'connect_timeout ' => null ,
148
158
'persisted ' => false ,
149
159
'lazy ' => true ,
160
+ 'pre_fetch_count ' => null ,
161
+ 'pre_fetch_size ' => null ,
150
162
],
151
163
];
152
164
@@ -163,6 +175,44 @@ public static function provideConfigs()
163
175
'connect_timeout ' => null ,
164
176
'persisted ' => false ,
165
177
'lazy ' => false ,
178
+ 'pre_fetch_count ' => null ,
179
+ 'pre_fetch_size ' => null ,
180
+ ],
181
+ ];
182
+
183
+ yield [
184
+ ['pre_fetch_count ' => 123 , 'pre_fetch_size ' => 321 ],
185
+ [
186
+ 'host ' => 'localhost ' ,
187
+ 'port ' => 5672 ,
188
+ 'vhost ' => '/ ' ,
189
+ 'user ' => 'guest ' ,
190
+ 'pass ' => 'guest ' ,
191
+ 'read_timeout ' => null ,
192
+ 'write_timeout ' => null ,
193
+ 'connect_timeout ' => null ,
194
+ 'persisted ' => false ,
195
+ 'lazy ' => true ,
196
+ 'pre_fetch_count ' => 123 ,
197
+ 'pre_fetch_size ' => 321 ,
198
+ ],
199
+ ];
200
+
201
+ yield [
202
+ 'amqp://user:pass@host:10000/vhost?pre_fetch_count=123&pre_fetch_size=321 ' ,
203
+ [
204
+ 'host ' => 'host ' ,
205
+ 'port ' => '10000 ' ,
206
+ 'vhost ' => 'vhost ' ,
207
+ 'user ' => 'user ' ,
208
+ 'pass ' => 'pass ' ,
209
+ 'read_timeout ' => null ,
210
+ 'write_timeout ' => null ,
211
+ 'connect_timeout ' => null ,
212
+ 'persisted ' => false ,
213
+ 'lazy ' => true ,
214
+ 'pre_fetch_count ' => 123 ,
215
+ 'pre_fetch_size ' => 321 ,
166
216
],
167
217
];
168
218
}
0 commit comments