summaryrefslogtreecommitdiff
path: root/cpp/src/IceStorm/Subscriber.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceStorm/Subscriber.cpp')
-rw-r--r--cpp/src/IceStorm/Subscriber.cpp12
1 files changed, 2 insertions, 10 deletions
diff --git a/cpp/src/IceStorm/Subscriber.cpp b/cpp/src/IceStorm/Subscriber.cpp
index 008c79e2725..aaa7e7a44a3 100644
--- a/cpp/src/IceStorm/Subscriber.cpp
+++ b/cpp/src/IceStorm/Subscriber.cpp
@@ -467,11 +467,7 @@ SubscriberTwowayOrdered::response()
_state = SubscriberStateOnline;
return;
}
- SubscriberPoolPtr pool = _instance->subscriberPool();
- if(pool)
- {
- pool->flush(this);
- }
+ _instance->subscriberPool()->flush(this);
}
namespace
@@ -666,11 +662,7 @@ SubscriberLink::response()
_state = SubscriberStateOnline;
return;
}
- SubscriberPoolPtr pool = _instance->subscriberPool();
- if(pool)
- {
- pool->flush(this);
- }
+ _instance->subscriberPool()->flush(this);
}
void