Refacotoring for usage with new RMC + MQ protocol

* Switch sample processor to stateful
* Refactor for usage with new persistence container functionality