Qpid
  1. Qpid
  2. QPID-4115

qpid-send and qpid-receive for Python client

    Details

    • Type: Improvement Improvement
    • Status: Resolved
    • Priority: Minor Minor
    • Resolution: Fixed
    • Affects Version/s: 0.16
    • Fix Version/s: 0.21
    • Component/s: Python Test Suite
    • Labels:
      None

      Description

      I am proposing qpid-send and qpid-receive for Python client, as an equivalent of C++ qpid-send.cpp / qpid-receive.cpp programs.

      The aim was to have an equivalent copy of the C++ programs to be able to compare performance of C++ vs. Python clients.

      Base qpid version of C++ programs I used is 0.16.

      1. statistics.py
        4 kB
        Pavel Moravec
      2. qpid-send
        12 kB
        Pavel Moravec
      3. qpid-receive
        9 kB
        Pavel Moravec

        Activity

        Hide
        Pavel Moravec added a comment -

        qpid-receive - Python equivalent of qpid-receive.cpp

        Show
        Pavel Moravec added a comment - qpid-receive - Python equivalent of qpid-receive.cpp
        Hide
        Pavel Moravec added a comment -

        qpid-send - Python equivalent of qpid-send.cpp

        Show
        Pavel Moravec added a comment - qpid-send - Python equivalent of qpid-send.cpp
        Hide
        Pavel Moravec added a comment -

        statistics.py - auxiliary class for computing statistics (throughput and latency) of qpid-send and qpid-receive

        Show
        Pavel Moravec added a comment - statistics.py - auxiliary class for computing statistics (throughput and latency) of qpid-send and qpid-receive
        Hide
        Pavel Moravec added a comment -

        It is worth applying patch from QPID-4576 also to Python client:

        — qpid-receive.orig 2013-02-11 09:24:05.463276868 +0100
        +++ qpid-receive.new 2013-02-11 09:24:56.420331928 +0100
        @@ -110,6 +110,8 @@ def main():

        if opts.ready_address is not None:
        session.sender(opts.ready_address).send(msg)
        + if opts.tx > 0:
        + session.commit()

        1. For receive rate calculation
          start = time.time()*TIME_SEC
          interval = 0
        Show
        Pavel Moravec added a comment - It is worth applying patch from QPID-4576 also to Python client: — qpid-receive.orig 2013-02-11 09:24:05.463276868 +0100 +++ qpid-receive.new 2013-02-11 09:24:56.420331928 +0100 @@ -110,6 +110,8 @@ def main(): if opts.ready_address is not None: session.sender(opts.ready_address).send(msg) + if opts.tx > 0: + session.commit() For receive rate calculation start = time.time()*TIME_SEC interval = 0
        Hide
        Darryl L. Pierce added a comment -

        This has been committed to qpid/python/examples/api.

        Show
        Darryl L. Pierce added a comment - This has been committed to qpid/python/examples/api.
        Hide
        Darryl L. Pierce added a comment -

        Moved the files to qpid/tools/src/py/

        Show
        Darryl L. Pierce added a comment - Moved the files to qpid/tools/src/py/

          People

          • Assignee:
            Darryl L. Pierce
            Reporter:
            Pavel Moravec
          • Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development