Error for send big message

Bug #1355056 reported by Tonal
6
This bug affects 1 person
Affects Status Importance Assigned to Milestone
txamqp (Ubuntu)
New
Undecided
Unassigned

Bug Description

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)

Revision history for this message
Tonal (tonal-promsoft) wrote :
Revision history for this message
Tonal (tonal-promsoft) wrote :
To post a comment you must log in.
This report contains Public information  
Everyone can see this information.

Other bug subscribers

Remote bug watches

Bug watches keep track of this bug in other bug trackers.