diff --git a/connection.go b/connection.go
index <HASH>..<HASH> 100644
--- a/connection.go
+++ b/connection.go
@@ -16,6 +16,7 @@ const heartbeatDuration = time.Minute
 type Connection interface {
 	OpenQueue(name string) Queue
 	CollectStats() Stats
+	GetOpenQueues() []string
 }
 
 // Connection is the entry point. Use a connection to access queues, consumers and deliveries
diff --git a/test_connection.go b/test_connection.go
index <HASH>..<HASH> 100644
--- a/test_connection.go
+++ b/test_connection.go
@@ -49,3 +49,7 @@ func (connection TestConnection) Reset() {
 		queue.Reset()
 	}
 }
+
+func (connection TestConnection) GetOpenQueues() []string {
+	return []string{}
+}
matching queue name with regexp and return reject for all matches