Uploaded image for project: 'Qpid Proton'
  1. Qpid Proton
  2. PROTON-561

Using the java broker, messenger apparently doesn't propagate error back from broker to messenger

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: proton-0.6, proton-0.7
    • Fix Version/s: None
    • Component/s: proton-c
    • Labels:

      Description

      (The java broker logging for AMQP 1.0 is minimal; I'll mention that in another jira.)

      The test program below simply hangs. It didn't seem to want to time out, either.

      from proton import Message, Messenger
      
      msgr = Messenger()
      msgr.start()
      
      try:
          msg = Message()
          msg.address = "amqp://0.0.0.0:5672/test"
          msg.body = "test"
      
          msgr.put(msg)
          msgr.send()
      finally:
          msgr.stop()
      

      By contrast, the same operation rendered in the qpid_messaging API produces the expected error:

      import sys
      
      # You will need to build the swig python binding and point at it
      sys.path.append("/home/jross/code/qpid/cpp/build/bindings/qpid/python")
      
      from qpid_messaging import Connection
      
      conn = Connection("0.0.0.0:5672", protocol="amqp1.0")
      
      conn.open()
      try:
          session = conn.session()
          sender = session.sender("test")
          message = Message("test")
      
          sender.send(message)
      finally:
          conn.close()
      

      Error:

      Traceback (most recent call last):
        File "/home/jross/test2.py", line 13, in <module>
          sender = session.sender("test")
        File "/home/jross/code/qpid/cpp/build/bindings/qpid/python/qpid_messaging.py", line 560, in sender
          s = self._sender(target)
        File "/home/jross/code/qpid/cpp/build/bindings/qpid/python/qpid_messaging.py", line 532, in _sender
          def _sender(self, *args): return _qpid_messaging.Session__sender(self, *args)
      _qpid_messaging.NotFound: No such target : test
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                justi9 Justin Ross
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: