diff options
| author | Alan Conway <aconway@apache.org> | 2010-05-14 13:55:18 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-05-14 13:55:18 +0000 |
| commit | 71975bc9bca46868053cc683105f74efd550f2b0 (patch) | |
| tree | bffe7687b5bc6a36490be34b60475d2d902c175c /qpid/cpp/src/tests/MessagingFixture.h | |
| parent | f91c20c40ec882ab116aeac47b09b7c6da96a658 (diff) | |
| download | qpid-python-71975bc9bca46868053cc683105f74efd550f2b0.tar.gz | |
Initial multi-thread unit test for messaging API.
- added Receiver::isClosed() to test for local close.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@944261 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/MessagingFixture.h')
| -rw-r--r-- | qpid/cpp/src/tests/MessagingFixture.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/tests/MessagingFixture.h b/qpid/cpp/src/tests/MessagingFixture.h index 5fb3fc56b2..5546b4ef49 100644 --- a/qpid/cpp/src/tests/MessagingFixture.h +++ b/qpid/cpp/src/tests/MessagingFixture.h @@ -182,7 +182,7 @@ struct MultiQueueFixture : MessagingFixture }; -std::vector<std::string> fetch(messaging::Receiver& receiver, int count, messaging::Duration timeout=messaging::Duration::SECOND*5) +inline std::vector<std::string> fetch(messaging::Receiver& receiver, int count, messaging::Duration timeout=messaging::Duration::SECOND*5) { std::vector<std::string> data; messaging::Message message; @@ -193,7 +193,7 @@ std::vector<std::string> fetch(messaging::Receiver& receiver, int count, messagi } -void send(messaging::Sender& sender, uint count = 1, uint start = 1, +inline void send(messaging::Sender& sender, uint count = 1, uint start = 1, const std::string& base = "Message") { for (uint i = start; i < start + count; ++i) { @@ -201,7 +201,7 @@ void send(messaging::Sender& sender, uint count = 1, uint start = 1, } } -void receive(messaging::Receiver& receiver, uint count = 1, uint start = 1, +inline void receive(messaging::Receiver& receiver, uint count = 1, uint start = 1, const std::string& base = "Message", messaging::Duration timeout=messaging::Duration::SECOND*5) { |