I've sorted this... I was trying to cluster rabbitmq on 2 different servers and had managed to delete the baruwa vhost. Added it and all started working again.
I think from the errors I've seen in trying to cluster that you need exactly the same version of rabbitmq installed on all nodes? Jason From: [email protected] [mailto:[email protected]] On Behalf Of Jason Ede Sent: 25 July 2011 17:47 To: Baruwa users list ([email protected]) Subject: [Baruwa] Error starting appearing when restarted baruwa process... I've run yum update and it updated Baruwa to 1.1.0-5.el5... Then after restarting the Baruwa process I'm getting this in the celeryd.log file.. I'm wondering if this could be related to the problem I'm seeing in releasing messages This is on CentOS5 ---- **** ----- --- * *** * -- [Configuration] -- * - **** --- . broker: amqplib://baruwa@localhost:5672/baruwa - ** ---------- . loader: djcelery.loaders.DjangoLoader - ** ---------- . logfile: /var/log/baruwa/celeryd.log@INFO<mailto:/var/log/baruwa/celeryd.log@INFO> - ** ---------- . concurrency: 4 - ** ---------- . events: ON - *** --- * --- . beat: ON -- ******* ---- --- ***** ----- [Queues] -------------- . default: exchange:default (direct) binding:default . gateway2.birchenallhowden.com: exchange:default (direct) binding:gateway2.birchenall howden.com [Tasks] . preview-message . process-quarantine . process-quarantined-msg . release-message . test-smtp-server [2011-07-25 17:40:24,787: INFO/PoolWorker-2] child process calling self.run() [2011-07-25 17:40:24,790: INFO/PoolWorker-3] child process calling self.run() [2011-07-25 17:40:24,795: INFO/PoolWorker-4] child process calling self.run() [2011-07-25 17:40:24,797: INFO/PoolWorker-5] child process calling self.run() [2011-07-25 17:40:24,807: INFO/Beat] child process calling self.run() [2011-07-25 17:40:24,808: INFO/Beat] Celerybeat: Starting... [2011-07-25 17:40:24,809: WARNING/MainProcess] [email protected]<mailto:[email protected]> has started. [2011-07-25 17:40:27,813: ERROR/MainProcess] Consumer: Connection Error: Socket closed. Trying again in 2 seconds... [2011-07-25 17:40:27,857: INFO/Beat] process shutting down [2011-07-25 17:40:27,857: WARNING/Beat] Process Beat: [2011-07-25 17:40:27,857: WARNING/Beat] Traceback (most recent call last): [2011-07-25 17:40:27,857: WARNING/Beat] File "/usr/lib64/python2.4/site-packages/multiprocessing/process .py", line 237, in _bootstrap [2011-07-25 17:40:27,858: WARNING/Beat] self.run() [2011-07-25 17:40:27,858: WARNING/Beat] File "/usr/lib/python2.4/site-packages/celery/beat.py", line 437 , in run [2011-07-25 17:40:27,858: WARNING/Beat] self.service.start(embedded_process=True) [2011-07-25 17:40:27,858: WARNING/Beat] File "/usr/lib/python2.4/site-packages/celery/beat.py", line 377 , in start [2011-07-25 17:40:27,858: WARNING/Beat] interval = self.scheduler.tick() [2011-07-25 17:40:27,858: WARNING/Beat] File "/usr/lib/python2.4/site-packages/celery/beat.py", line 184 , in tick [2011-07-25 17:40:27,859: WARNING/Beat] next_time_to_run = self.maybe_due(entry, self.publisher) [2011-07-25 17:40:27,859: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/utils/__init__.py", line 221, in __get__ [2011-07-25 17:40:27,859: WARNING/Beat] value = obj.__dict__[self.__name__] = self.__get(obj) [2011-07-25 17:40:27,859: WARNING/Beat] File "/usr/lib/python2.4/site-packages/celery/beat.py", line 275 , in publisher [2011-07-25 17:40:27,859: WARNING/Beat] return self.Publisher(connection=self.connection) [2011-07-25 17:40:27,859: WARNING/Beat] File "/usr/lib/python2.4/site-packages/celery/app/amqp.py", line 328, in TaskPublisher [2011-07-25 17:40:27,860: WARNING/Beat] return TaskPublisher(*args, **self.app.merge(defaults, kwargs)) [2011-07-25 17:40:27,860: WARNING/Beat] File "/usr/lib/python2.4/site-packages/celery/app/amqp.py", line 156, in __init__ [2011-07-25 17:40:27,860: WARNING/Beat] super(TaskPublisher, self).__init__(*args, **kwargs) [2011-07-25 17:40:27,860: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/compat.py", line 79 , in __init__ [2011-07-25 17:40:27,860: WARNING/Beat] self.backend = connection.channel() [2011-07-25 17:40:27,860: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/connection.py", lin e 124, in channel [2011-07-25 17:40:27,861: WARNING/Beat] chan = self.transport.create_channel(self.connection) [2011-07-25 17:40:27,861: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/connection.py", lin e 439, in connection [2011-07-25 17:40:27,861: WARNING/Beat] self._connection = self._establish_connection() [2011-07-25 17:40:27,861: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/connection.py", lin e 405, in _establish_connection [2011-07-25 17:40:27,861: WARNING/Beat] conn = self.transport.establish_connection() [2011-07-25 17:40:27,861: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/transport/pyamqplib .py", line 245, in establish_connection [2011-07-25 17:40:27,862: WARNING/Beat] connect_timeout=conninfo.connect_timeout) [2011-07-25 17:40:27,862: WARNING/Beat] File "/usr/lib/python2.4/site-packages/kombu/transport/pyamqplib .py", line 51, in __init__ [2011-07-25 17:40:27,862: WARNING/Beat] super(Connection, self).__init__(*args, **kwargs) [2011-07-25 17:40:27,862: WARNING/Beat] File "/usr/lib/python2.4/site-packages/amqplib/client_0_8/connec tion.py", line 138, in __init__ [2011-07-25 17:40:27,862: WARNING/Beat] self.wait(allowed_methods=[ [2011-07-25 17:40:27,862: WARNING/Beat] File "/usr/lib/python2.4/site-packages/amqplib/client_0_8/abstra ct_channel.py", line 88, in wait [2011-07-25 17:40:27,863: WARNING/Beat] method_sig, args, content = self.connection._wait_method( [2011-07-25 17:40:27,863: WARNING/Beat] File "/usr/lib/python2.4/site-packages/amqplib/client_0_8/connec tion.py", line 197, in _wait_method [2011-07-25 17:40:27,863: WARNING/Beat] channel, method_sig, args, content = \ [2011-07-25 17:40:27,863: WARNING/Beat] File "/usr/lib/python2.4/site-packages/amqplib/client_0_8/method _framing.py", line 215, in read_method [2011-07-25 17:40:27,863: WARNING/Beat] raise m [2011-07-25 17:40:27,863: WARNING/Beat] IOError: Socket closed [2011-07-25 17:40:27,864: INFO/Beat] process exiting with exitcode 1
_______________________________________________ Baruwa mailing list [email protected] http://lists.baruwa.org/mailman/listinfo/baruwa Keep Baruwa FREE - http://pledgie.com/campaigns/12056
