diff options
author | Stephen D. Huston <shuston@apache.org> | 2009-09-04 15:15:31 +0000 |
---|---|---|
committer | Stephen D. Huston <shuston@apache.org> | 2009-09-04 15:15:31 +0000 |
commit | 349e2a820ab87a89ec694753456a84970fd986b9 (patch) | |
tree | 67c0ac1c5e1e23b0b1cc6b9ce738e66a0f4f3e04 /wcf/src | |
parent | efc2197fd5ca7425f415306443936b98edf3a1b7 (diff) | |
download | qpid-python-349e2a820ab87a89ec694753456a84970fd986b9.tar.gz |
Apply patches from QPID-2079
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@811441 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'wcf/src')
-rw-r--r-- | wcf/src/Apache/Qpid/Interop/CompletionWaiter.cpp | 6 | ||||
-rw-r--r-- | wcf/src/Apache/Qpid/Interop/MessageWaiter.cpp | 7 |
2 files changed, 9 insertions, 4 deletions
diff --git a/wcf/src/Apache/Qpid/Interop/CompletionWaiter.cpp b/wcf/src/Apache/Qpid/Interop/CompletionWaiter.cpp index 4f6746828d..e39ee1b1ae 100644 --- a/wcf/src/Apache/Qpid/Interop/CompletionWaiter.cpp +++ b/wcf/src/Apache/Qpid/Interop/CompletionWaiter.cpp @@ -53,11 +53,13 @@ CompletionWaiter::CompletionWaiter(AmqpSession^ parent, TimeSpan timeSpan, IntPt this->qpidFuture = future; this->asyncCallback = callback; this->state = state; + this->parent = parent; + this->thisLock = gcnew Object(); + // do this after the Completion Waiter is fully initialized, in case of + // very small timespan if (timeSpan != TimeSpan::MaxValue) { this->timer = gcnew Timer(timeoutCallback, this, timeSpan, TimeSpan::FromMilliseconds(-1)); } - this->parent = parent; - this->thisLock = gcnew Object(); } diff --git a/wcf/src/Apache/Qpid/Interop/MessageWaiter.cpp b/wcf/src/Apache/Qpid/Interop/MessageWaiter.cpp index 4868b9efce..f7a28b0692 100644 --- a/wcf/src/Apache/Qpid/Interop/MessageWaiter.cpp +++ b/wcf/src/Apache/Qpid/Interop/MessageWaiter.cpp @@ -60,11 +60,14 @@ MessageWaiter::MessageWaiter(InputLink^ parent, TimeSpan timeSpan, bool consumin else { this->assigned = true; } + this->parent = parent; + this->thisLock = gcnew Object(); + + // do this after the Message Waiter is fully initialized, in case of + // very small timespan if (timeSpan != TimeSpan::MaxValue) { this->timer = gcnew Timer(timeoutCallback, this, timeSpan, TimeSpan::FromMilliseconds(-1)); } - this->parent = parent; - this->thisLock = gcnew Object(); } MessageWaiter::~MessageWaiter() |