Error when using 'BROKER_HEARTBEAT' about py-amqp

[aknapp]

Sorry, I should also say, these are the versions I'm using:

celery==3.0.6
django-celery==3.0.6
amqp==0.9.2
kombu==2.4.0
amqplib==1.0.2

[ask]

I'm not able to reproduce here :(
What value are you specifying for the heartbeat?

Could you dump out what the value is when it crashes (see cf06eba)?

[aknapp]

So, I upgraded amqp, and I'm still seeing the same error. The 'BROKER_HEARTBEAT' setting is set to '10' in this traceback, but it happens with any value.

(tapp-deps)andrew@cronus:~/code/mxml/lanai/tapp (master)$ manage celery worker -c2
/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/djcelery/loaders.py:116: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
  warnings.warn("Using settings.DEBUG leads to a memory leak, never "

 -------------- celery@cronus v3.0.7 (Chiastic Slide)
---- **** ----- 
--- * ***  * -- [Configuration]
-- * - **** --- . broker:      pyamqp://[e-mail]:5672/tapp_dev
- ** ---------- . app:         default:0x2370a10 (djcelery.loaders.DjangoLoader)
- ** ---------- . concurrency: 2 (processes)
- ** ---------- . events:      OFF (enable -E to monitor this worker)
- ** ---------- 
- *** --- * --- [Queues]
-- ******* ---- . barracuda:   exchange:tasks(topic) binding:barracuda.#
--- ***** ----- . crawl:       exchange:tasks(topic) binding:crawl.#
 -------------- . low_priority: exchange:tasks(topic) binding:low_priority.#
                . mixpanel:    exchange:tasks(topic) binding:mixpanel.#
                . tasks:       exchange:tasks(topic) binding:task.#

2012-08-29 17:58:11,114 cronus.int.sfo01.mml WARNING stdout: celery@cronus has started.
2012-08-29 17:58:11,124 cronus.int.sfo01.mml DEBUG amqp: Start from server, version: 0.9, properties: {u'information': u'Licensed under the MPL.  See http://www.rabbitmq.com/', u'product': u'RabbitMQ', u'copyright': u'Copyright (C) 2007-2011 VMware, Inc.', u'capabilities': {u'exchange_exchange_bindings': True, u'consumer_cancel_notify': True, u'publisher_confirms': True, u'basic.nack': True}, u'platform': u'Erlang/OTP', u'version': u'2.7.1'}, mechanisms: [u'PLAIN', u'AMQPLAIN'], locales: [u'en_US']
2012-08-29 17:58:11,125 cronus.int.sfo01.mml ERROR celery.worker: Unrecoverable error: ValueError("Octet '10' out of range 0..65535",)
Traceback (most recent call last):
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/celery/worker/__init__.py", line 353, in start
    component.start()
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/celery/worker/consumer.py", line 368, in start
    self.reset_connection()
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/celery/worker/consumer.py", line 703, in reset_connection
    self.connection = self._open_connection()
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/celery/worker/consumer.py", line 766, in _open_connection
    callback=self.maybe_shutdown)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/kombu/connection.py", line 272, in ensure_connection
    interval_start, interval_step, interval_max, callback)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/kombu/utils/__init__.py", line 158, in retry_over_time
    return fun(*args, **kwargs)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/kombu/connection.py", line 162, in connect
    return self.connection
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/kombu/connection.py", line 617, in connection
    self._connection = self._establish_connection()
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/kombu/connection.py", line 576, in _establish_connection
    conn = self.transport.establish_connection()
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/kombu/transport/pyamqp.py", line 102, in establish_connection
    heartbeat=conninfo.heartbeat)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/amqp/connection.py", line 157, in __init__
    (10, 30),  # tune
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/amqp/abstract_channel.py", line 70, in wait
    return self.dispatch_method(method_sig, args, content)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/amqp/abstract_channel.py", line 87, in dispatch_method
    return amqp_method(self, args)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/amqp/connection.py", line 808, in _tune
    self._x_tune_ok(self.channel_max, self.frame_max, self.heartbeat)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/amqp/connection.py", line 890, in _x_tune_ok
    args.write_short(heartbeat or 0)
  File "/home/andrew/.env/tapp-deps/local/lib/python2.7/site-packages/amqp/serialization.py", line 231, in write_short
    raise ValueError('Octet %r out of range 0..65535' % (n, ))
ValueError: Octet '10' out of range 0..65535

One question I have is should amqplib be installed? It's pulled in via requirements by something.

All my dependencies are the same as I noted above except celery (3.0.7) and amqp (0.9.3). Let me know if you need anything else from me.

[aknapp]

Hahahahaha, wow, stupid mistake on my part. I was quoting the BROKER_HEARTBEAT value...once I stopped doing that, everything works as expected. Sorry about that.