@@ -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 ' )
@@ -65,6 +66,7 @@ protected function addConnections(ArrayNodeDefinition $node)
65
66
protected function addProducers (ArrayNodeDefinition $ node )
66
67
{
67
68
$ node
69
+ ->fixXmlConfig ('producer ' )
68
70
->children ()
69
71
->arrayNode ('producers ' )
70
72
->canBeUnset ()
@@ -86,6 +88,7 @@ protected function addProducers(ArrayNodeDefinition $node)
86
88
protected function addConsumers (ArrayNodeDefinition $ node )
87
89
{
88
90
$ node
91
+ ->fixXmlConfig ('consumer ' )
89
92
->children ()
90
93
->arrayNode ('consumers ' )
91
94
->canBeUnset ()
@@ -116,6 +119,7 @@ protected function addConsumers(ArrayNodeDefinition $node)
116
119
protected function addMultipleConsumers (ArrayNodeDefinition $ node )
117
120
{
118
121
$ node
122
+ ->fixXmlConfig ('multiple_consumer ' )
119
123
->children ()
120
124
->arrayNode ('multiple_consumers ' )
121
125
->canBeUnset ()
@@ -144,6 +148,7 @@ protected function addMultipleConsumers(ArrayNodeDefinition $node)
144
148
protected function addAnonConsumers (ArrayNodeDefinition $ node )
145
149
{
146
150
$ node
151
+ ->fixXmlConfig ('anon_consumer ' )
147
152
->children ()
148
153
->arrayNode ('anon_consumers ' )
149
154
->canBeUnset ()
@@ -163,6 +168,7 @@ protected function addAnonConsumers(ArrayNodeDefinition $node)
163
168
protected function addRpcClients (ArrayNodeDefinition $ node )
164
169
{
165
170
$ node
171
+ ->fixXmlConfig ('rpc_client ' )
166
172
->children ()
167
173
->arrayNode ('rpc_clients ' )
168
174
->canBeUnset ()
@@ -181,6 +187,7 @@ protected function addRpcClients(ArrayNodeDefinition $node)
181
187
protected function addRpcServers (ArrayNodeDefinition $ node )
182
188
{
183
189
$ node
190
+ ->fixXmlConfig ('rpc_server ' )
184
191
->children ()
185
192
->arrayNode ('rpc_servers ' )
186
193
->canBeUnset ()
0 commit comments