Permalink
Browse files

Added shutdown method to txrabbitmq service

  • Loading branch information...
1 parent d844cd2 commit 15c26de864c8657a9c528ced1bc5715f4e6621a3 @labisso labisso committed Oct 26, 2010
Showing with 6 additions and 0 deletions.
  1. +6 −0 txrabbitmq/service.py
View
@@ -38,6 +38,12 @@ def __init__(self, process, remote_nodename, module="rabbit_access_control"):
self.remote_nodename = remote_nodename
self.module = module
+ def shutdown(self):
+ """Close open connections and clean up"""
+ # better way to do this?
+ for epmd in self.process.oneShotEpmds.itervalues():
+ epmd.closeConnections()
+
@inlineCallbacks
def add_user(self, username, password):
"""add new user with given password"""

0 comments on commit 15c26de

Please sign in to comment.