- Make SubjectMessageHandler a SmartLifecycle and assign it to phase 0, allowing it to be started after the outputs are bound and before the inputs are bound; - Setup Rx in the start() method; - Set the ServiceActivator associated with the handler to phase 0 as well;