Added a BeanstalkClient close() method.

colevscode · Jun 28, 2011 · 9bcb6cd · 9bcb6cd · jonasvp · Jun 28, 2011
1 parent a9f6be7
commit 9bcb6cd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/django_beanstalkd/__init__.py b/django_beanstalkd/__init__.py
@@ -41,6 +41,8 @@ def call(self, func, arg='', priority=DEFAULT_PRIORITY, delay=0, ttr=DEFAULT_TTR
         """
         self._beanstalk.use(func)
         self._beanstalk.put(str(arg), priority=priority, delay=delay, ttr=ttr)
+    def close(self):
+        self._beanstalk.close()
 
     def __init__(self, **kwargs):
         self._beanstalk = connect_beanstalkd()