diff --git a/springql-core/src/connection.rs b/springql-core/src/connection.rs
index eb4efb4e..d743e6e8 100644
--- a/springql-core/src/connection.rs
+++ b/springql-core/src/connection.rs
@@ -4,7 +4,7 @@ use std::{sync::Once, thread, time::Duration};
 
 use crate::{
     api::{error::Result, SpringConfig},
-    pipeline::name::QueueName,
+    pipeline::QueueName,
     sql_processor::SqlProcessor,
     stream_engine::{command::Command, EngineMutex, Row},
 };