moved connect / disconnect logic from StompProducer to StompSession