x/stacktach
Code Issues Proposed changes

Revert "force message buffers to strings before decoding"

Browse Source 
This reverts commit 7c47c360c3.

Conflicts:
	worker/worker.py
This commit is contained in:
Anuj Mathur
2014-02-12 17:39:50 +05:30
parent 53de1451f7
commit e7195f5404
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
worker/worker.py
View File

@@ -19,7 +19,6 @@
import datetime import datetime
import sys import sys
import time import time
import anyjson
import signal import signal
import kombu import kombu
@@ -40,7 +39,6 @@ from stacktach import db
from stacktach import message_service from stacktach import message_service
from stacktach import stacklog from stacktach import stacklog
from stacktach import views from stacktach import views
from kombu.serialization import BytesIO, register
stacklog.set_default_logger_name('worker') stacklog.set_default_logger_name('worker')
shutdown_soon = False shutdown_soon = False
@@ -66,13 +64,6 @@ class Consumer(kombu.mixins.ConsumerMixin):
self.exchange = exchange self.exchange = exchange
signal.signal(signal.SIGTERM, self._shutdown) signal.signal(signal.SIGTERM, self._shutdown)
register('bufferjson', self.loads, anyjson.dumps,
content_type='application/json',
content_encoding='binary')
def loads(s):
return anyjson.loads(BytesIO(s))
def _create_exchange(self, name, type, exclusive=False, auto_delete=False): def _create_exchange(self, name, type, exclusive=False, auto_delete=False):
return message_service.create_exchange(name, exchange_type=type, return message_service.create_exchange(name, exchange_type=type,
exclusive=exclusive, exclusive=exclusive,