Imported Upstream version 1.4.6
SVN-Git Migration
8 years ago
| 3 | 3 |
py-amqp is fork of amqplib used by Kombu containing additional features and improvements.
|
| 4 | 4 |
The previous amqplib changelog is here:
|
| 5 | 5 |
http://code.google.com/p/py-amqplib/source/browse/CHANGES
|
|
6 |
|
|
7 |
.. _version-1.4.6:
|
|
8 |
|
|
9 |
1.4.6
|
|
10 |
=====
|
|
11 |
:release-date: 2014-08-11 06:00 P.M UTC
|
|
12 |
:release-by: Ask Solem
|
|
13 |
|
|
14 |
- Now keeps buffer when socket times out.
|
|
15 |
|
|
16 |
Fix contributed by Artyom Koval.
|
|
17 |
|
|
18 |
- Adds ``Connection.Transport`` attribute that can be used to specify
|
|
19 |
a different transport implementation.
|
|
20 |
|
|
21 |
Contributed by Yury Selivanov.
|
| 6 | 22 |
|
| 7 | 23 |
.. _version-1.4.5:
|
| 8 | 24 |
|
|
| 231 | 247 |
|
| 232 | 248 |
1.1.0
|
| 233 | 249 |
=====
|
| 234 | |
:release-date: 2012-11-08 10:36 P.M UTC
|
|
250 |
:release-date: 2013-11-08 10:36 P.M UTC
|
| 235 | 251 |
:release-by: Ask Solem
|
| 236 | 252 |
|
| 237 | 253 |
- No longer supports Python 2.5
|
| 0 | 0 |
Metadata-Version: 1.1
|
| 1 | 1 |
Name: amqp
|
| 2 | |
Version: 1.4.5
|
|
2 |
Version: 1.4.6
|
| 3 | 3 |
Summary: Low-level AMQP client for Python (fork of amqplib)
|
| 4 | 4 |
Home-page: http://github.com/celery/py-amqp
|
| 5 | 5 |
Author: Ask Solem
|
|
| 9 | 9 |
Python AMQP 0.9.1 client library
|
| 10 | 10 |
=====================================================================
|
| 11 | 11 |
|
| 12 | |
:Version: 1.4.5
|
|
12 |
:Version: 1.4.6
|
| 13 | 13 |
:Web: http://amqp.readthedocs.org/
|
| 14 | 14 |
:Download: http://pypi.python.org/pypi/amqp/
|
| 15 | 15 |
:Source: http://github.com/celery/py-amqp/
|
| 1 | 1 |
Python AMQP 0.9.1 client library
|
| 2 | 2 |
=====================================================================
|
| 3 | 3 |
|
| 4 | |
:Version: 1.4.5
|
|
4 |
:Version: 1.4.6
|
| 5 | 5 |
:Web: http://amqp.readthedocs.org/
|
| 6 | 6 |
:Download: http://pypi.python.org/pypi/amqp/
|
| 7 | 7 |
:Source: http://github.com/celery/py-amqp/
|
| 15 | 15 |
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
|
| 16 | 16 |
from __future__ import absolute_import
|
| 17 | 17 |
|
| 18 | |
VERSION = (1, 4, 5)
|
|
18 |
VERSION = (1, 4, 6)
|
| 19 | 19 |
__version__ = '.'.join(map(str, VERSION[0:3])) + ''.join(VERSION[3:])
|
| 20 | 20 |
__author__ = 'Barry Pederson'
|
| 21 | 21 |
__maintainer__ = 'Ask Solem'
|
| 161 | 161 |
# Let the transport.py module setup the actual
|
| 162 | 162 |
# socket connection to the broker.
|
| 163 | 163 |
#
|
| 164 | |
self.transport = create_transport(host, connect_timeout, ssl)
|
|
164 |
self.transport = self.Transport(host, connect_timeout, ssl)
|
| 165 | 165 |
|
| 166 | 166 |
self.method_reader = MethodReader(self.transport)
|
| 167 | 167 |
self.method_writer = MethodWriter(self.transport, self.frame_max)
|
|
| 180 | 180 |
])
|
| 181 | 181 |
|
| 182 | 182 |
return self._x_open(virtual_host)
|
|
183 |
|
|
184 |
def Transport(self, host, connect_timeout, ssl=False):
|
|
185 |
return create_transport(host, connect_timeout, ssl)
|
| 183 | 186 |
|
| 184 | 187 |
@property
|
| 185 | 188 |
def connected(self):
|
| 148 | 148 |
|
| 149 | 149 |
def read_frame(self, unpack=unpack):
|
| 150 | 150 |
read = self._read
|
| 151 | |
try:
|
| 152 | |
frame_type, channel, size = unpack('>BHI', read(7, True))
|
|
151 |
read_frame_buffer = EMPTY_BUFFER
|
|
152 |
try:
|
|
153 |
frame_header = read(7, True)
|
|
154 |
read_frame_buffer += frame_header
|
|
155 |
frame_type, channel, size = unpack('>BHI', frame_header)
|
| 153 | 156 |
payload = read(size)
|
|
157 |
read_frame_buffer += payload
|
| 154 | 158 |
ch = ord(read(1))
|
| 155 | 159 |
except socket.timeout:
|
|
160 |
self._read_buffer = read_frame_buffer + self._read_buffer
|
| 156 | 161 |
raise
|
| 157 | 162 |
except (OSError, IOError, socket.error) as exc:
|
| 158 | 163 |
# Don't disconnect for ssl read time outs
|
| 0 | 0 |
Metadata-Version: 1.1
|
| 1 | 1 |
Name: amqp
|
| 2 | |
Version: 1.4.5
|
|
2 |
Version: 1.4.6
|
| 3 | 3 |
Summary: Low-level AMQP client for Python (fork of amqplib)
|
| 4 | 4 |
Home-page: http://github.com/celery/py-amqp
|
| 5 | 5 |
Author: Ask Solem
|
|
| 9 | 9 |
Python AMQP 0.9.1 client library
|
| 10 | 10 |
=====================================================================
|
| 11 | 11 |
|
| 12 | |
:Version: 1.4.5
|
|
12 |
:Version: 1.4.6
|
| 13 | 13 |
:Web: http://amqp.readthedocs.org/
|
| 14 | 14 |
:Download: http://pypi.python.org/pypi/amqp/
|
| 15 | 15 |
:Source: http://github.com/celery/py-amqp/
|
| 3 | 3 |
py-amqp is fork of amqplib used by Kombu containing additional features and improvements.
|
| 4 | 4 |
The previous amqplib changelog is here:
|
| 5 | 5 |
http://code.google.com/p/py-amqplib/source/browse/CHANGES
|
|
6 |
|
|
7 |
.. _version-1.4.6:
|
|
8 |
|
|
9 |
1.4.6
|
|
10 |
=====
|
|
11 |
:release-date: 2014-08-11 06:00 P.M UTC
|
|
12 |
:release-by: Ask Solem
|
|
13 |
|
|
14 |
- Now keeps buffer when socket times out.
|
|
15 |
|
|
16 |
Fix contributed by Artyom Koval.
|
|
17 |
|
|
18 |
- Adds ``Connection.Transport`` attribute that can be used to specify
|
|
19 |
a different transport implementation.
|
|
20 |
|
|
21 |
Contributed by Yury Selivanov.
|
| 6 | 22 |
|
| 7 | 23 |
.. _version-1.4.5:
|
| 8 | 24 |
|
|
| 231 | 247 |
|
| 232 | 248 |
1.1.0
|
| 233 | 249 |
=====
|
| 234 | |
:release-date: 2012-11-08 10:36 P.M UTC
|
|
250 |
:release-date: 2013-11-08 10:36 P.M UTC
|
| 235 | 251 |
:release-by: Ask Solem
|
| 236 | 252 |
|
| 237 | 253 |
- No longer supports Python 2.5
|