summaryrefslogtreecommitdiff
path: root/cpp/src/IceStorm/OnewayBatchSubscriber.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceStorm/OnewayBatchSubscriber.cpp')
-rw-r--r--cpp/src/IceStorm/OnewayBatchSubscriber.cpp7
1 files changed, 3 insertions, 4 deletions
diff --git a/cpp/src/IceStorm/OnewayBatchSubscriber.cpp b/cpp/src/IceStorm/OnewayBatchSubscriber.cpp
index 0b11e624bdb..ee5dae5b6eb 100644
--- a/cpp/src/IceStorm/OnewayBatchSubscriber.cpp
+++ b/cpp/src/IceStorm/OnewayBatchSubscriber.cpp
@@ -20,8 +20,7 @@ OnewayBatchSubscriber::OnewayBatchSubscriber(const SubscriberFactoryPtr& factory
const TraceLevelsPtr& traceLevels,
const FlusherPtr& flusher,
const QueuedProxyPtr& obj) :
- OnewaySubscriber(factory, traceLevels, obj),
- _communicator(communicator),
+ OnewaySubscriber(factory, communicator, traceLevels, obj),
_flusher(flusher)
{
}
@@ -53,7 +52,7 @@ OnewayBatchSubscriber::unsubscribe()
if(_traceLevels->subscriber > 0)
{
Ice::Trace out(_traceLevels->logger, _traceLevels->subscriberCat);
- out << "Unsubscribe " << id();
+ out << "Unsubscribe " << _communicator->identityToString(id());
}
//
@@ -74,7 +73,7 @@ OnewayBatchSubscriber::replace()
if(_traceLevels->subscriber > 0)
{
Ice::Trace out(_traceLevels->logger, _traceLevels->subscriberCat);
- out << "Replace " << id();
+ out << "Replace " << _communicator->identityToString(id());
}
//