Skip to content
Snippets Groups Projects
Commit 99034ac7 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

py3

parent cd64dd93
No related branches found
No related tags found
No related merge requests found
......@@ -9,5 +9,6 @@ import logging
logger = logging.getLogger(__name__)
__all__ = ('Cluster')
from coolamqp.clustering.cluster import Cluster
......@@ -6,25 +6,6 @@ class CoolAMQPError(Exception):
"""Base class for CoolAMQP errors"""
class ConsumerError(CoolAMQPError):
"""
Exceptions passed to consumer callables.
"""
class UplinkLost(ConsumerError):
"""
Uplink to the network has been lost, I am working on regaining connectivity
right now.
"""
class ConsumerCancelled(CoolAMQPError):
"""
The consumer has been cancelled
"""
class AMQPError(CoolAMQPError):
"""
Base class for errors received from AMQP server
......
......@@ -89,12 +89,12 @@ def _compile_particular_content_property_list_class(zpf, fields):
mod.append(u'\n def write_to(self, buf):\n')
mod.append(u' buf.write(')
repred_zpf = repr(zpf)
if not zpf.startswith(u'b'):
if not repred_zpf.startswith(u'b'):
repred_zpf = u'b' + repred_zpf
mod.append(repred_zpf)
mod.append(u')\n')
mod.append(get_serializer(present_fields, prefix='self.', indent_level=2))
mod.append(get_serializer(present_fields, prefix=u'self.', indent_level=2))
# from_buffer
# note that non-bit values
......@@ -109,7 +109,7 @@ def _compile_particular_content_property_list_class(zpf, fields):
# get_size
mod.append(u'\n def get_size(self):\n')
mod.append(get_counter(present_fields, prefix='self.', indent_level=2)[:-1]) # skip eol
mod.append(get_counter(present_fields, prefix=u'self.', indent_level=2)[:-1]) # skip eol
mod.append(u' + %s\n' % (zpf_length, )) # account for pf length
return u''.join(mod)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment