Permalink
Browse files

Delete celery and djcelery

  • Loading branch information...
1 parent aa2e597 commit b05889bcbb9d3b04d5224fff96f0affbc8284f1f @glogiotatidis glogiotatidis committed Dec 24, 2012
Showing 1,099 changed files with 0 additions and 102,228 deletions.
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','camqadm'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'camqadm')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','celery'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'celery')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','celerybeat'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'celerybeat')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','celeryctl'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'celeryctl')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','celeryd'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'celeryd')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','celeryd-multi'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'celeryd-multi')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'celery==3.0.12','console_scripts','celeryev'
-__requires__ = 'celery==3.0.12'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('celery==3.0.12', 'console_scripts', 'celeryev')()
- )
View
@@ -1,10 +0,0 @@
-#!/usr/bin/python
-# EASY-INSTALL-ENTRY-SCRIPT: 'django-celery==3.0.11','console_scripts','djcelerymon'
-__requires__ = 'django-celery==3.0.11'
-import sys
-from pkg_resources import load_entry_point
-
-if __name__ == '__main__':
- sys.exit(
- load_entry_point('django-celery==3.0.11', 'console_scripts', 'djcelerymon')()
- )
View
Binary file not shown.
@@ -1,50 +0,0 @@
-"""Low-level AMQP client for Python (fork of amqplib)"""
-# Copyright (C) 2007-2008 Barry Pederson <bp@barryp.org>
-#
-# This library is free software; you can redistribute it and/or
-# modify it under the terms of the GNU Lesser General Public
-# License as published by the Free Software Foundation; either
-# version 2.1 of the License, or (at your option) any later version.
-#
-# This library is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-# Lesser General Public License for more details.
-#
-# You should have received a copy of the GNU Lesser General Public
-# License along with this library; if not, write to the Free Software
-# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
-from __future__ import absolute_import
-
-VERSION = (1, 0, 6)
-__version__ = '.'.join(map(str, VERSION[0:3])) + ''.join(VERSION[3:])
-__author__ = 'Barry Pederson'
-__maintainer__ = 'Ask Solem'
-__contact__ = 'pyamqp@celeryproject.org'
-__homepage__ = 'http://github.com/celery/py-amqp'
-__docformat__ = 'restructuredtext'
-
-# -eof meta-
-
-#
-# Pull in the public items from the various sub-modules
-#
-from .basic_message import Message
-from .channel import Channel
-from .connection import Connection
-from .exceptions import (
- AMQPError,
- ConnectionError,
- ChannelError,
- ConsumerCancel,
-)
-
-__all__ = [
- 'Connection',
- 'Channel',
- 'Message',
- 'AMQPError',
- 'ConnectionError',
- 'ChannelError',
- 'ConsumerCancel',
-]
@@ -1,93 +0,0 @@
-"""Code common to Connection and Channel objects."""
-# Copyright (C) 2007-2008 Barry Pederson <bp@barryp.org>
-#
-# This library is free software; you can redistribute it and/or
-# modify it under the terms of the GNU Lesser General Public
-# License as published by the Free Software Foundation; either
-# version 2.1 of the License, or (at your option) any later version.
-#
-# This library is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-# Lesser General Public License for more details.
-#
-# You should have received a copy of the GNU Lesser General Public
-# License along with this library; if not, write to the Free Software
-# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
-from __future__ import absolute_import
-
-from .exceptions import AMQPError
-from .serialization import AMQPWriter
-
-try:
- bytes
-except NameError:
- # Python 2.5 and lower
- bytes = str
-
-__all__ = ['AbstractChannel']
-
-
-class AbstractChannel(object):
- """Superclass for both the Connection, which is treated
- as channel 0, and other user-created Channel objects.
-
- The subclasses must have a _METHOD_MAP class property, mapping
- between AMQP method signatures and Python methods.
-
- """
- def __init__(self, connection, channel_id):
- self.connection = connection
- self.channel_id = channel_id
- connection.channels[channel_id] = self
- self.method_queue = [] # Higher level queue for methods
- self.auto_decode = False
-
- def __enter__(self):
- return self
-
- def __exit__(self, *exc_info):
- self.close()
-
- def _send_method(self, method_sig, args=bytes(), content=None):
- """Send a method for our channel."""
- if isinstance(args, AMQPWriter):
- args = args.getvalue()
-
- self.connection.method_writer.write_method(
- self.channel_id, method_sig, args, content)
-
- def close(self):
- """Close this Channel or Connection"""
- raise NotImplementedError('Must be overriden in subclass')
-
- def wait(self, allowed_methods=None):
- """Wait for a method that matches our allowed_methods parameter (the
- default value of None means match any method), and dispatch to it."""
- method_sig, args, content = self.connection._wait_method(
- self.channel_id, allowed_methods)
-
- return self.dispatch_method(method_sig, args, content)
-
- def dispatch_method(self, method_sig, args, content):
- if content and \
- self.auto_decode and \
- hasattr(content, 'content_encoding'):
- try:
- content.body = content.body.decode(content.content_encoding)
- except Exception:
- pass
-
- try:
- amqp_method = self._METHOD_MAP[method_sig]
- except KeyError:
- raise AMQPError('Unknown AMQP method %r' % method_sig)
-
- if content is None:
- return amqp_method(self, args)
- else:
- return amqp_method(self, args, content)
-
- #: Placeholder, the concrete implementations will have to
- #: supply their own versions of _METHOD_MAP
- _METHOD_MAP = {}
@@ -1,123 +0,0 @@
-"""Messages for AMQP"""
-# Copyright (C) 2007-2008 Barry Pederson <bp@barryp.org>
-#
-# This library is free software; you can redistribute it and/or
-# modify it under the terms of the GNU Lesser General Public
-# License as published by the Free Software Foundation; either
-# version 2.1 of the License, or (at your option) any later version.
-#
-# This library is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-# Lesser General Public License for more details.
-#
-# You should have received a copy of the GNU Lesser General Public
-# License along with this library; if not, write to the Free Software
-# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
-from __future__ import absolute_import
-
-from .serialization import GenericContent
-
-__all__ = ['Message']
-
-
-class Message(GenericContent):
- """A Message for use with the Channnel.basic_* methods."""
-
- #: Instances of this class have these attributes, which
- #: are passed back and forth as message properties between
- #: client and server
- PROPERTIES = [
- ('content_type', 'shortstr'),
- ('content_encoding', 'shortstr'),
- ('application_headers', 'table'),
- ('delivery_mode', 'octet'),
- ('priority', 'octet'),
- ('correlation_id', 'shortstr'),
- ('reply_to', 'shortstr'),
- ('expiration', 'shortstr'),
- ('message_id', 'shortstr'),
- ('timestamp', 'timestamp'),
- ('type', 'shortstr'),
- ('user_id', 'shortstr'),
- ('app_id', 'shortstr'),
- ('cluster_id', 'shortstr')
- ]
-
- def __init__(self, body='', children=None, **properties):
- """Expected arg types
-
- body: string
- children: (not supported)
-
- Keyword properties may include:
-
- content_type: shortstr
- MIME content type
-
- content_encoding: shortstr
- MIME content encoding
-
- application_headers: table
- Message header field table, a dict with string keys,
- and string | int | Decimal | datetime | dict values.
-
- delivery_mode: octet
- Non-persistent (1) or persistent (2)
-
- priority: octet
- The message priority, 0 to 9
-
- correlation_id: shortstr
- The application correlation identifier
-
- reply_to: shortstr
- The destination to reply to
-
- expiration: shortstr
- Message expiration specification
-
- message_id: shortstr
- The application message identifier
-
- timestamp: datetime.datetime
- The message timestamp
-
- type: shortstr
- The message type name
-
- user_id: shortstr
- The creating user id
-
- app_id: shortstr
- The creating application id
-
- cluster_id: shortstr
- Intra-cluster routing identifier
-
- Unicode bodies are encoded according to the 'content_encoding'
- argument. If that's None, it's set to 'UTF-8' automatically.
-
- example::
-
- msg = Message('hello world',
- content_type='text/plain',
- application_headers={'foo': 7})
-
- """
- super(Message, self).__init__(**properties)
- self.body = body
-
- def __eq__(self, other):
- """Check if the properties and bodies of this Message and another
- Message are the same.
-
- Received messages may contain a 'delivery_info' attribute,
- which isn't compared.
-
- """
- try:
- return (super(Message, self).__eq__(other) and
- self.body == other.body)
- except AttributeError:
- return NotImplemented
Oops, something went wrong.

0 comments on commit b05889b

Please sign in to comment.