Monitoring and running integration flows