Skip to content

Commit 9058f58

Browse files
author
David Kamphausen
committed
add function to get predefined exchange
1 parent 160866c commit 9058f58

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

src/FintechFab/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,13 @@ public function getChannel()
160160
return new AMQPChannel($this->connection);
161161
}
162162

163+
/**
164+
* @return AMQPExchange
165+
*/
166+
public function getCurrentExchange() {
167+
return $this->exchange;
168+
}
169+
163170
/**
164171
* @param AMQPChannel $channel
165172
*
@@ -227,4 +234,4 @@ public function declareDelayedQueue($destination, $delay)
227234
return $queue;
228235
}
229236

230-
}
237+
}

0 commit comments

Comments
 (0)