diff options
Diffstat (limited to 'qpid/cpp/examples/examples/request-response/client.cpp')
| -rw-r--r-- | qpid/cpp/examples/examples/request-response/client.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/cpp/examples/examples/request-response/client.cpp b/qpid/cpp/examples/examples/request-response/client.cpp index 7540de30ff..79bc88c6ae 100644 --- a/qpid/cpp/examples/examples/request-response/client.cpp +++ b/qpid/cpp/examples/examples/request-response/client.cpp @@ -79,8 +79,8 @@ void Listener::listen() { session.messageSubscribe(arg::queue=destination_name, arg::destination=destination_name); - session.messageFlow(arg::destination=destination_name, arg::unit=0, arg::value=1);//messages ### Define a constant? - session.messageFlow(arg::destination=destination_name, arg::unit=1, arg::value=0xFFFFFFFF);//bytes ###### Define a constant? + session.messageFlow(arg::destination=destination_name, arg::unit=MESSAGE_CREDIT, arg::value=1); + session.messageFlow(arg::destination=destination_name, arg::unit=BYTE_CREDIT, arg::value=UNLIMITED_CREDIT); dispatcher.listen(destination_name, this); |