http://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=28

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);