SourceQueue cleanup

[longshorej]

• Add a test ensuring that queue actor is stopped in all scenarios
• Make this test pass (as it won't right now)