summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJohn Wu <webmaster@leapoahead.com>2016-04-19 16:54:13 +0800
committerJohn Wu <webmaster@leapoahead.com>2016-04-19 16:54:13 +0800
commit5188e096809b0b9c0b94e498b51159ffebec2a70 (patch)
tree1f969849a7050ba28151391b5cbf46cad3308c02
parent0cf26f86ea5dc60c70850fb99b5633d0f6638247 (diff)
downloadpymemcache-5188e096809b0b9c0b94e498b51159ffebec2a70.tar.gz
Add default_noreply property to PooledClient
-rw-r--r--pymemcache/client/base.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/pymemcache/client/base.py b/pymemcache/client/base.py
index ad845d1..88b177a 100644
--- a/pymemcache/client/base.py
+++ b/pymemcache/client/base.py
@@ -818,7 +818,8 @@ class PooledClient(object):
socket_module=socket,
key_prefix=b'',
max_pool_size=None,
- lock_generator=None):
+ lock_generator=None,
+ default_noreply=True):
self.server = server
self.serializer = serializer
self.deserializer = deserializer
@@ -827,6 +828,7 @@ class PooledClient(object):
self.no_delay = no_delay
self.ignore_exc = ignore_exc
self.socket_module = socket_module
+ self.default_noreply = default_noreply
if isinstance(key_prefix, six.text_type):
key_prefix = key_prefix.encode('ascii')
if not isinstance(key_prefix, bytes):
@@ -853,7 +855,8 @@ class PooledClient(object):
# can remove/destroy it from the pool...
ignore_exc=False,
socket_module=self.socket_module,
- key_prefix=self.key_prefix)
+ key_prefix=self.key_prefix,
+ default_noreply=self.default_noreply)
return client
def close(self):