Author: aconway
Date: Tue May 27 10:46:27 2008
New Revision: 660625
URL: http://svn.apache.org/viewvc?rev=660625&view=rev
Log:
Use symbolic constants for message flow values.
Modified:
incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp
incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp
incubator/qpid/trunk/qpid/cpp/src/qpid/client/SessionBase_0_10.h
Modified:
incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp?rev=660625&r1=660624&r2=660625&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp
(original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp
Tue May 27 10:46:27 2008
@@ -79,8 +79,8 @@
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);
Modified:
incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp?rev=660625&r1=660624&r2=660625&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp
(original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp
Tue May 27 10:46:27 2008
@@ -82,9 +82,8 @@
session.messageSubscribe(arg::queue=destination_name,
arg::destination=destination_name);
- // ##### Should not be needed. Sigh.
- 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);
}
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/SessionBase_0_10.h
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/SessionBase_0_10.h?rev=660625&r1=660624&r2=660625&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/SessionBase_0_10.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/SessionBase_0_10.h Tue May 27
10:46:27 2008
@@ -48,7 +48,7 @@
using qpid::SessionId;
using framing::Xid;
-enum CreditUnit { MESSAGE=0, BYTE=1 };
+enum CreditUnit { MESSAGE_CREDIT=0, BYTE_CREDIT=1, UNLIMITED_CREDIT=0xFFFFFFFF
};
/**
* Base class for handles to an AMQP session.
