May 25, 2022 11:57 · November 17, 2025 18:46 · December 15, 2025 09:49 · March 10, 2015 07:41 · August 29, 2015 14:15 · September 15, 2021 11:17
diff --git a/Introducing Incremental DOM — Google Developers — Medium b/Introducing Incremental DOM — Google Developers — Medium
 #https://github.com/gevent/gevent/issues/477#issuecomment-56292848                                                                                                              
 # # Re-add sslwrap to Python 2.7.9                                                                                                                                              
 import inspect
 __ssl__ = __import__('ssl')

 try:
    _ssl = __ssl__._ssl
 except AttributeError:
    _ssl = __ssl__._ssl2
 def http_connection_send():
    import httplib
    def patch_send():
        old_send= httplib.HTTPConnection.send
        def new_send(self, data, *args, **kwargs):
            print(data)
            body = old_send(self, data, *args, **kwargs)
            return body
        httplib.HTTPConnection.send = new_send
    patch_send()
 """
 This module adds Redis Sentinel transport support to Celery.
 Current version of celery doesn't support Redis sentinel client, which is must have for automatic failover.

 To use it::

    import register_celery_alias
    register_celery_alias("redis-sentinel")

    celery = Celery(..., broker="redis-sentinel://...", backend="redis-sentinel://...")
	#https://github.com/gevent/gevent/issues/477#issuecomment-56292848
	# # Re-add sslwrap to Python 2.7.9
	import inspect
	__ssl__ = __import__('ssl')

	try:
	_ssl = __ssl__._ssl
	except AttributeError:
	_ssl = __ssl__._ssl2
	def http_connection_send():
	import httplib
	def patch_send():
	old_send= httplib.HTTPConnection.send
	def new_send(self, data, args, *kwargs):
	print(data)
	body = old_send(self, data, args, *kwargs)
	return body
	httplib.HTTPConnection.send = new_send
	patch_send()
	"""
	This module adds Redis Sentinel transport support to Celery.
	Current version of celery doesn't support Redis sentinel client, which is must have for automatic failover.

	To use it::

	import register_celery_alias
	register_celery_alias("redis-sentinel")

	celery = Celery(..., broker="redis-sentinel://...", backend="redis-sentinel://...")