@@ -41,6 +41,7 @@ public function getConfigTreeBuilder()
41
41
protected function addConnections (ArrayNodeDefinition $ node )
42
42
{
43
43
$ node
44
+ ->fixXmlConfig ('connection ' )
44
45
->children ()
45
46
->arrayNode ('connections ' )
46
47
->useAttributeAsKey ('key ' )
@@ -63,6 +64,7 @@ protected function addConnections(ArrayNodeDefinition $node)
63
64
protected function addProducers (ArrayNodeDefinition $ node )
64
65
{
65
66
$ node
67
+ ->fixXmlConfig ('producer ' )
66
68
->children ()
67
69
->arrayNode ('producers ' )
68
70
->canBeUnset ()
@@ -84,6 +86,7 @@ protected function addProducers(ArrayNodeDefinition $node)
84
86
protected function addConsumers (ArrayNodeDefinition $ node )
85
87
{
86
88
$ node
89
+ ->fixXmlConfig ('consumer ' )
87
90
->children ()
88
91
->arrayNode ('consumers ' )
89
92
->canBeUnset ()
@@ -114,6 +117,7 @@ protected function addConsumers(ArrayNodeDefinition $node)
114
117
protected function addMultipleConsumers (ArrayNodeDefinition $ node )
115
118
{
116
119
$ node
120
+ ->fixXmlConfig ('multiple_consumer ' )
117
121
->children ()
118
122
->arrayNode ('multiple_consumers ' )
119
123
->canBeUnset ()
@@ -142,6 +146,7 @@ protected function addMultipleConsumers(ArrayNodeDefinition $node)
142
146
protected function addAnonConsumers (ArrayNodeDefinition $ node )
143
147
{
144
148
$ node
149
+ ->fixXmlConfig ('anon_consumer ' )
145
150
->children ()
146
151
->arrayNode ('anon_consumers ' )
147
152
->canBeUnset ()
@@ -161,6 +166,7 @@ protected function addAnonConsumers(ArrayNodeDefinition $node)
161
166
protected function addRpcClients (ArrayNodeDefinition $ node )
162
167
{
163
168
$ node
169
+ ->fixXmlConfig ('rpc_client ' )
164
170
->children ()
165
171
->arrayNode ('rpc_clients ' )
166
172
->canBeUnset ()
@@ -179,6 +185,7 @@ protected function addRpcClients(ArrayNodeDefinition $node)
179
185
protected function addRpcServers (ArrayNodeDefinition $ node )
180
186
{
181
187
$ node
188
+ ->fixXmlConfig ('rpc_server ' )
182
189
->children ()
183
190
->arrayNode ('rpc_servers ' )
184
191
->canBeUnset ()
0 commit comments