diff options
author | wilson_d <wilson_d@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-10-29 16:10:47 +0000 |
---|---|---|
committer | wilson_d <wilson_d@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-10-29 16:10:47 +0000 |
commit | 50e18994616f637b3d5444594da771f2318cc0d1 (patch) | |
tree | 19f0ddc17f1db668d1c60dd7b7fade30a7b53e7c /TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp | |
parent | 6b91b5bcda830a14261024b894a483d28b290328 (diff) | |
download | ATCD-pnotify_branch.tar.gz |
ChangeLogTag: Fri Oct 29 10:53:56 2004 Dale Wilson <wilson_d@ociweb.com>pnotify_branch
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp b/TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp index f7b23e7d7b6..ff9b0a58e60 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/Consumer.cpp @@ -58,14 +58,14 @@ TAO_Notify_Consumer::proxy (void) return this->proxy_supplier (); } -//@@ todo: consider buffering strategy void TAO_Notify_Consumer::qos_changed (const TAO_Notify_QoSProperties& qos_properties) { this->max_batch_size_ = qos_properties.maximum_batch_size (); /* -if (this->max_batch_size_.is_valid ()) +//@@ todo: consider buffering strategy + if (this->max_batch_size_.is_valid ()) {// set the max batch size. this->buffering_strategy_->batch_size (this->max_batch_size_.value ()); } @@ -346,6 +346,7 @@ TAO_Notify_Consumer::dispatch_batch (const CosNotification::EventBatch& batch) ex._info ().c_str () )); // @@todo what to return here? + return DISPATCH_RETRY; } ACE_CATCHANY { |