Skip to content

Commit ac36c16

Browse files
author
Jack C Hong
committed
Temporarily disable deleting exchange due to amqp bug
Seems like if exchange deleted multiple times of same topic, it would disconnect all other queues and exchanges.
1 parent 4fcc5e0 commit ac36c16

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

omf_common/lib/omf_common/comm/amqp/amqp_topic.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ def on_subscribed(&block)
3939

4040
def unsubscribe(key)
4141
super
42-
@exchange.delete
42+
#@exchange.delete
4343
end
4444

4545

0 commit comments

Comments
 (0)