Add new doctrine processors

You should put this code before the process call, as explain by @stof 

With this implementation, if your connection timed out between 2 messages, you don't reopen it before calling the processor.