We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2db889c commit d99370eCopy full SHA for d99370e
src/groups/bmq/bmqimp/bmqimp_brokersession.cpp
@@ -3490,7 +3490,7 @@ void BrokerSession::processPushEvent(const bmqp::Event& event)
3490
// Update stats
3491
bdlma::LocalSequentialAllocator<1024> iteratorLsa(d_allocator_p);
3492
bmqp::PushMessageIterator msgIterator(d_bufferFactory_p, &iteratorLsa);
3493
- event.loadPushMessageIterator(&msgIterator);
+ event.loadPushMessageIterator(&msgIterator, true);
3494
if (BSLS_PERFORMANCEHINT_PREDICT_UNLIKELY(!msgIterator.isValid())) {
3495
BSLS_PERFORMANCEHINT_UNLIKELY_HINT;
3496
BALL_LOG_ERROR << id() << "Unable to process PUSH event "
0 commit comments