summaryrefslogtreecommitdiff
path: root/cpp/src/IceStorm/OnewayBatchSubscriber.h
diff options
context:
space:
mode:
authorMichi Henning <michi@zeroc.com>2003-08-29 06:51:58 +0000
committerMichi Henning <michi@zeroc.com>2003-08-29 06:51:58 +0000
commit14e46bc24e79df49bd603c08d293c17245b9ca93 (patch)
treec7fc6f422c2a0706ed5e3926a091aa715ee41021 /cpp/src/IceStorm/OnewayBatchSubscriber.h
parentconnection closure timeout (diff)
downloadice-14e46bc24e79df49bd603c08d293c17245b9ca93.tar.bz2
ice-14e46bc24e79df49bd603c08d293c17245b9ca93.tar.xz
ice-14e46bc24e79df49bd603c08d293c17245b9ca93.zip
Removed ice_flush() from proxy base class and implemented
Communicator::flushBatchRequests().
Diffstat (limited to 'cpp/src/IceStorm/OnewayBatchSubscriber.h')
-rw-r--r--cpp/src/IceStorm/OnewayBatchSubscriber.h4
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/IceStorm/OnewayBatchSubscriber.h b/cpp/src/IceStorm/OnewayBatchSubscriber.h
index 2c209551f80..4aef9f36a35 100644
--- a/cpp/src/IceStorm/OnewayBatchSubscriber.h
+++ b/cpp/src/IceStorm/OnewayBatchSubscriber.h
@@ -32,7 +32,8 @@ class OnewayBatchSubscriber : public OnewaySubscriber, public Flushable
{
public:
- OnewayBatchSubscriber(const SubscriberFactoryPtr&, const TraceLevelsPtr&, const FlusherPtr&, const QueuedProxyPtr&);
+ OnewayBatchSubscriber(const SubscriberFactoryPtr&, const Ice::CommunicatorPtr&,
+ const TraceLevelsPtr&, const FlusherPtr&, const QueuedProxyPtr&);
~OnewayBatchSubscriber();
virtual void unsubscribe();
@@ -45,6 +46,7 @@ public:
private:
+ Ice::CommunicatorPtr _communicator;
FlusherPtr _flusher;
};