diff options
Diffstat (limited to 'cpp/src/IceStorm/SubscriberFactory.cpp')
-rw-r--r-- | cpp/src/IceStorm/SubscriberFactory.cpp | 14 |
1 files changed, 5 insertions, 9 deletions
diff --git a/cpp/src/IceStorm/SubscriberFactory.cpp b/cpp/src/IceStorm/SubscriberFactory.cpp index 3b2c820827c..9a2350aca50 100644 --- a/cpp/src/IceStorm/SubscriberFactory.cpp +++ b/cpp/src/IceStorm/SubscriberFactory.cpp @@ -36,26 +36,22 @@ SubscriberFactory::createLinkSubscriber(const TopicLinkPrx& obj, Ice::Int cost) IceUtil::RecMutex::Lock sync(_proxiesMutex); // - // Delivery to links is done in batch mode. - // - TopicLinkPrx newObj = TopicLinkPrx::uncheckedCast(obj->ice_batchOneway()); - - // - // Check if a queued proxy already exists, or create one if necessary. + // Check if a queued proxy already exists, or create one if + // necessary. // QueuedProxyPtr proxy; - map<Ice::ObjectPrx, ProxyInfo>::iterator p = _proxies.find(newObj); + map<Ice::ObjectPrx, ProxyInfo>::iterator p = _proxies.find(obj); if(p != _proxies.end()) { proxy = p->second.proxy; } else { - proxy = new LinkProxy(newObj); + proxy = new LinkProxy(obj); ProxyInfo info; info.proxy = proxy; info.count = 0; - _proxies.insert(pair<Ice::ObjectPrx, ProxyInfo>(newObj, info)); + _proxies.insert(pair<Ice::ObjectPrx, ProxyInfo>(obj, info)); } return new LinkSubscriber(this, _communicator, _traceLevels, proxy, cost); |