diff options
Diffstat (limited to 'cpp/src/IceStorm/OnewaySubscriber.cpp')
| -rw-r--r-- | cpp/src/IceStorm/OnewaySubscriber.cpp | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/cpp/src/IceStorm/OnewaySubscriber.cpp b/cpp/src/IceStorm/OnewaySubscriber.cpp index b1007792355..5c547ad4f8f 100644 --- a/cpp/src/IceStorm/OnewaySubscriber.cpp +++ b/cpp/src/IceStorm/OnewaySubscriber.cpp @@ -46,6 +46,19 @@ OnewaySubscriber::unsubscribe() } void +OnewaySubscriber::replace() +{ + IceUtil::Mutex::Lock sync(_stateMutex); + _state = StateReplaced; + + if (_traceLevels->subscriber > 0) + { + Ice::Trace out(_traceLevels->logger, _traceLevels->subscriberCat); + out << "Replace " << _obj->ice_getIdentity(); + } +} + +void OnewaySubscriber::publish(const Event& event) { try |