Skip to content
Browse files

Add missing serializer to one of the publish calls

  • Loading branch information...
1 parent f93fbc6 commit 5f25c30df89680eb9f52cd06cb4e06acb00d7f25 @priteau priteau committed Jan 20, 2012
Showing with 2 additions and 2 deletions.
  1. +2 −2 dashi/
4 dashi/
@@ -62,7 +62,7 @@ def fire(self, name, operation, args=None, **kwargs):
with producers[self._conn].acquire(block=True) as producer:
producer.publish(d, routing_key=name, exchange=self._exchange_name,
- headers=headers)
+ headers=headers, serializer=self._serializer)
def call(self, name, operation, timeout=5, args=None, **kwargs):
"""Send a message and wait for reply
@@ -372,4 +372,4 @@ class UnknownOperationError(DashiError):
ERROR_PREFIX = "dashi."
ERROR_TYPES = (BadRequestError, UnknownOperationError)
-ERROR_TYPE_MAP = dict((cls.__name__, cls) for cls in ERROR_TYPES)
+ERROR_TYPE_MAP = dict((cls.__name__, cls) for cls in ERROR_TYPES)

0 comments on commit 5f25c30

Please sign in to comment.
Something went wrong with that request. Please try again.