Public bug reported:
Run simple client for send big message:
Output:
$ ./tx-err_big_semd.py
Connected to broker.
Authenticated. Ready to receive messages
Message max length: 131072
Sending message: len=262144 prop: {}
Unhandled Error
Traceback (most recent call last):
File /usr/lib/python2.7/dist-packages/twisted/internet/defer.py, line 423,
in errback
self._startRunCallbacks(fail)
File /usr/lib/python2.7/dist-packages/twisted/internet/defer.py, line 490,
in _startRunCallbacks
self._runCallbacks()
File /usr/lib/python2.7/dist-packages/twisted/internet/defer.py, line 577,
in _runCallbacks
current.result = callback(current.result, *args, **kw)
File /usr/lib/python2.7/dist-packages/twisted/internet/defer.py, line 1155,
in gotResult
_inlineCallbacks(r, g, deferred)
--- exception caught here ---
File /usr/lib/python2.7/dist-packages/twisted/internet/defer.py, line 1097,
in _inlineCallbacks
result = result.throwExceptionIntoGenerator(g)
File /usr/lib/python2.7/dist-packages/twisted/python/failure.py, line 389,
in throwExceptionIntoGenerator
return g.throw(self.type, self.value, self.tb)
File ./tx-err_big_semd.py, line 35, in gotConnection
yield chan.channel_close()
File /usr/lib/python2.7/dist-packages/twisted/internet/defer.py, line 1097,
in _inlineCallbacks
result = result.throwExceptionIntoGenerator(g)
File /usr/lib/python2.7/dist-packages/twisted/python/failure.py, line 389,
in throwExceptionIntoGenerator
return g.throw(self.type, self.value, self.tb)
File /usr/lib/python2.7/dist-packages/txamqp/protocol.py, line 86, in invoke
raise Closed(self.reason)
txamqp.client.Closed: Method(name=close, id=50) (501, 'FRAME_ERROR - type 3,
all octets = : {frame_too_large,262144,131064}', 0, 0) content = None
Client code: file tx-err_big_semd.py
from twisted.internet.defer import inlineCallbacks
from twisted.internet import reactor
from twisted.internet.protocol import ClientCreator
from twisted.python import log
from txamqp.protocol import AMQClient
from txamqp.client import TwistedDelegate
from txamqp.content import Content
import txamqp.spec
TEST_QUEUE = 'test.queue'
@inlineCallbacks
def gotConnection(conn, username, password):
print Connected to broker.
yield conn.authenticate(username, password, mechanism='PLAIN')
print Authenticated. Ready to receive messages
chan = yield conn.channel(1)
yield chan.channel_open()
yield chan.queue_declare(
queue=TEST_QUEUE, durable=True, exclusive=False, auto_delete=False)
print 'Message max length:', conn.MAX_LENGTH
msg = Content(' ' * conn.MAX_LENGTH * 2)
chan.basic_publish(exchange='', content=msg, routing_key=TEST_QUEUE)
print Sending message: len=%d prop: %s % (len(msg.body), msg.properties)
yield
yield chan.channel_close()
chan0 = yield conn.channel(0)
yield chan0.connection_close()
reactor.stop()
if __name__ == __main__:
host = 'localhost'
port = 5672
vhost = '/'
username = 'guest'
password = 'guest'
SPEC = 'https://www.rabbitmq.com/resources/specs/amqp0-9.stripped.xml'
spec = txamqp.spec.load(SPEC)
delegate = TwistedDelegate()
d = ClientCreator(reactor, AMQClient, delegate=delegate, vhost=vhost,
spec=spec).connectTCP(host, port)
d.addCallback(gotConnection, username, password)
def whoops(err):
if reactor.running:
log.err(err)
reactor.stop()
d.addErrback(whoops)
reactor.run()
ProblemType: Bug
DistroRelease: Ubuntu 14.04
Package: python-txamqp 0.6.1-0ubuntu2
ProcVersionSignature: Ubuntu 3.13.0-32.57-generic 3.13.11.4
Uname: Linux 3.13.0-32-generic x86_64
NonfreeKernelModules: fglrx wl
ApportVersion: 2.14.1-0ubuntu3.3
Architecture: amd64
CurrentDesktop: KDE
Date: Mon Aug 11 15:29:55 2014
InstallationDate: Installed on 2011-12-10 (975 days ago)
InstallationMedia: Kubuntu 11.10 Oneiric Ocelot - Release amd64 (20111012)
PackageArchitecture: all
SourcePackage: txamqp
UpgradeStatus: Upgraded to trusty on 2014-04-23 (110 days ago)
** Affects: txamqp (Ubuntu)
Importance: Undecided
Status: New
** Tags: amd64 apport-bug trusty
--
You received this bug notification because you are a member of Ubuntu
Server Team, which is subscribed to txamqp in Ubuntu.
https://bugs.launchpad.net/bugs/1355056
Title:
Error for send big message
To manage notifications about this bug go to:
https://bugs.launchpad.net/ubuntu/+source/txamqp/+bug/1355056/+subscriptions
--
Ubuntu-server-bugs mailing list
Ubuntu-server-bugs@lists.ubuntu.com
Modify settings or unsubscribe at:
https://lists.ubuntu.com/mailman/listinfo/ubuntu-server-bugs
