lib/pwwka/test_handler.rb in pwwka-0.3.0 vs lib/pwwka/test_handler.rb in pwwka-0.3.1
- old
+ new
@@ -63,11 +63,13 @@
def test_teardown
test_queue.delete
channel_connector.topic_exchange.delete
# delayed messages
- channel_connector.delayed_queue.delete
- channel_connector.delayed_exchange.delete
+ unless Pwwka.configuration.allow_delayed?
+ channel_connector.delayed_queue.delete
+ channel_connector.delayed_exchange.delete
+ end
channel_connector.connection_close
end
# Simple class to hold a popped message.