qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nico Maas (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (PROTON-1465) amqp:decode-error Could not process AMQP commands
Date Thu, 20 Apr 2017 09:30:04 GMT

    [ https://issues.apache.org/jira/browse/PROTON-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976365#comment-15976365
] 

Nico Maas commented on PROTON-1465:
-----------------------------------

These are additional logs:

{code}
File Chunk 746 processed
File Chunk 747 processed
File Chunk 748 processed
File Chunk 749 processed
File Chunk 750 processed
Traceback (most recent call last):
  File "./send_activemq.py", line 323, in <module>
    mq_send(data.read())
  File "./send_activemq.py", line 272, in mq_send
    activemq_sender.send(Message(body=data))
  File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 78, in send
    self.connection.wait(lambda: _is_settled(delivery), msg="Sending on sender %s" % self.link.name,
timeout=timeout)
  File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 267, in wait
    self.container.process()
  File "/usr/local/lib/python2.7/dist-packages/proton/reactor.py", line 159, in process
    self._check_errors()
  File "/usr/local/lib/python2.7/dist-packages/proton/reactor.py", line 155, in _check_errors
    _compat.raise_(exc, value, tb)
  File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 4050, in dispatch
    ev.dispatch(self.handler)
  File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 3959, in dispatch
    result = dispatch(handler, type.method, self)
  File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 3837, in dispatch
    return m(*args)
  File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 289, in on_connection_remote_close
    raise ConnectionClosed(event.connection)
proton.utils.ConnectionClosed: Connection MYSERVERIP closed due to: Condition('amqp:decode-error',
'Could not decode AMQP frame: hex: e1c2ac665688edac4fcc8a3afd1f83d722e85b188ccbfbd32cc04746ee362fc2378d533bc088bf18e6b06d77bfeca69cdb4caeae0d1267747a1e6b44b866502df1754f7a98e2cbf249df2fc155f6e687b6126b36e1e7d52e43421bc7dd85156916a8d1cfe12ef357fc05ee')

veMQ Transport: tcp:///MYIP:43269@1883
2017-04-20 09:23:57,247 | DEBUG | Publishing: amqp://5268c3466792:5672 for broker transport
URI: amqp://5268c3466792:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600
| org.apache.activemq.broker.TransportConnector | ActiveMQ BrokerService[localhost] Task-16
2017-04-20 09:23:57,248 | DEBUG | Transport Connection to: tcp://MYIP:43269 failed: java.io.EOFException
| org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///MYIP:43269@1883
java.io.EOFException
        at java.io.DataInputStream.readByte(DataInputStream.java:267)[:1.8.0_121]
        at org.apache.activemq.transport.mqtt.MQTTWireFormat.unmarshal(MQTTWireFormat.java:86)[activemq-mqtt-5.14.4.jar:5.14.4]
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)[activemq-client-5.14.4.jar:5.14.4]
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)[activemq-client-5.14.4.jar:5.14.4]
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.14.4.jar:5.14.4]
        at java.lang.Thread.run(Thread.java:745)[:1.8.0_121]
2017-04-20 09:23:57,250 | DEBUG | Publishing: amqp://5268c3466792:5672 for broker transport
URI: amqp://5268c3466792:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600
| org.apache.activemq.broker.TransportConnector | ActiveMQ BrokerService[localhost] Task-16




Traceback (most recent call last):
  File "./send_activemq.py", line 323, in <module>
    mq_send(data.read())
  File "./send_activemq.py", line 272, in mq_send
    activemq_sender.send(Message(body=data))
  File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 78, in send
    self.connection.wait(lambda: _is_settled(delivery), msg="Sending on sender %s" % self.link.name,
timeout=timeout)
  File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 267, in wait
    self.container.process()
  File "/usr/local/lib/python2.7/dist-packages/proton/reactor.py", line 159, in process
    self._check_errors()
  File "/usr/local/lib/python2.7/dist-packages/proton/reactor.py", line 155, in _check_errors
    _compat.raise_(exc, value, tb)
  File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 4050, in dispatch
    ev.dispatch(self.handler)
  File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 3959, in dispatch
    result = dispatch(handler, type.method, self)
  File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 3837, in dispatch
    return m(*args)
  File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 289, in on_connection_remote_close
    raise ConnectionClosed(event.connection)
proton.utils.ConnectionClosed: Connection MYSERVERIP closed due to: Condition('amqp:decode-error',
'Unexpected error occurred: java.lang.OutOfMemoryError: GC overhead limit exceeded')
{code}

> amqp:decode-error Could not process AMQP commands
> -------------------------------------------------
>
>                 Key: PROTON-1465
>                 URL: https://issues.apache.org/jira/browse/PROTON-1465
>             Project: Qpid Proton
>          Issue Type: Bug
>          Components: python-binding
>    Affects Versions: 0.17.0
>         Environment: Ubuntu 14.04
>            Reporter: Nico Maas
>
> I use Qpid in Python to send files and do it this way:
> {code}
> from __future__ import print_function, unicode_literals
> # qpid-proton
> from proton import Message
> from proton.utils import BlockingConnection
> from proton.handlers import IncomingMessageHandler
> activemq_channel = ""
> activemq_connection = ""
> activemq_session = ""
> activemq_sender = ""
> def mq_connect(ip, username, password):
>   global activemq_channel
>   global activemq_connection
>   global activemq_session
>   global activemq_sender
>   activemq_connection = BlockingConnection(username + ":" + password + "@" + ip + ":5672")
>   activemq_sender = activemq_connection.create_sender("file")
> def mq_send(data):
>   global activemq_sender
>   #activemq_sender.send(Message(bytearray(data)))
>   activemq_sender.send(Message(durable=True,body=data))
> def mq_close():
>   global activemq_connection
>   activemq_connection.close()
> mq_connect(server_ip,'admin','admin')
> for i in file_list:
>   data = open(i, 'rb')
>   mq_send(data.read())
>   data.close()
> mq_close.close()
> {code}
> Sadly I could not send the files as bytearrays as I normally do.. but it should work
(Is there any better way to send binary files via proton?). However, on random, following
problem arises:
> {code}
> Traceback (most recent call last):
>   File "./send_activemq.py", line 323, in <module>
>     mq_send(data.read())
>   File "./send_activemq.py", line 271, in mq_send
>     activemq_sender.send(Message(body=data))
>   File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 78, in send
>     self.connection.wait(lambda: _is_settled(delivery), msg="Sending on sender %s" %
self.link.name, timeout=timeout)
>   File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 267, in wait
>     self.container.process()
>   File "/usr/local/lib/python2.7/dist-packages/proton/reactor.py", line 159, in process
>     self._check_errors()
>   File "/usr/local/lib/python2.7/dist-packages/proton/reactor.py", line 155, in _check_errors
>     _compat.raise_(exc, value, tb)
>   File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 4050, in dispatch
>     ev.dispatch(self.handler)
>   File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 3959, in dispatch
>     result = dispatch(handler, type.method, self)
>   File "/usr/local/lib/python2.7/dist-packages/proton/__init__.py", line 3837, in dispatch
>     return m(*args)
>   File "/usr/local/lib/python2.7/dist-packages/proton/utils.py", line 289, in on_connection_remote_close
>     raise ConnectionClosed(event.connection)
> proton.utils.ConnectionClosed: Connection x closed due to: Condition('amqp:decode-error',
'Could not process AMQP commands')
> {code}
> ActiveMQ tells me following:
> {code}
>  WARN | Transport Connection to: tcp://x:59158 failed: org.apache.activemq.transport.amqp.AmqpProtocolException:
Could not process AMQP commands
>  WARN | Transport Connection to: tcp://x:55804 failed: java.io.EOFException
> {code}
> However, it always happens at random - without any clue on the file, size or time..
> What can I do? Python crashes at this point... So it is a blocker for me. Thanks a lot
for your help.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message