diff --git a/ofborg/src/tasks/log_message_collector.rs b/ofborg/src/tasks/log_message_collector.rs
index be4113a..64f7b8e 100644
--- a/ofborg/src/tasks/log_message_collector.rs
+++ b/ofborg/src/tasks/log_message_collector.rs
@@ -398,6 +398,7 @@ mod tests {
                 })
             );
 
+            assert!(p.path().join("routing-key-foo/attempt-id-foo").exists());
             assert_eq!(vec![worker::Action::Ack], worker.consumer(&job));
 
             logmsg.line_number = 5;