Be careful everybody, the original ConfigTree of your PipelineProcessor must not be changed, since it must be reentrant / threadsafe.
I did something like
| | ConfigTree configTree = processorsConfigTree.cloneObj(); |
| | String endpointUrl = ... |
| | configTree.setAttribute("endpointUrl", endpointUrl); |
| HttpRouter r = new HttpRouter(configTree); |
| r.process(msg): |
and this has been working well for a few millions messages in the last years ;-)
Cheers, Tom.