File tree Expand file tree Collapse file tree 1 file changed +9
-5
lines changed Expand file tree Collapse file tree 1 file changed +9
-5
lines changed Original file line number Diff line number Diff line change 154
154
#include < mqbi_cluster.h>
155
155
#include < mqbi_queue.h>
156
156
#include < mqbnet_tcpsessionfactory.h>
157
+ #include < mqbs_datastore.h>
157
158
#include < mqbstat_brokerstats.h>
158
159
#include < mqbstat_clusterstats.h>
159
160
#include < mqbu_messageguidutil.h>
@@ -1672,11 +1673,14 @@ void ClientSession::onAckEvent(const mqbi::DispatcherAckEvent& event)
1672
1673
queue_p->stats ()
1673
1674
->onEvent <mqbstat::QueueStatsDomain::EventType::e_ACK_TIME>(
1674
1675
timeDelta);
1675
- queue_p->domain ()->cluster ()->stats ().onPartitionEvent (
1676
- mqbstat::ClusterStats::PartitionEventType::
1677
- e_PARTITION_REPLICATION,
1678
- queue_p->partitionId (),
1679
- timeDelta);
1676
+ if (queue_p->partitionId () !=
1677
+ mqbs::DataStore::k_INVALID_PARTITION_ID) {
1678
+ queue_p->domain ()->cluster ()->stats ().onPartitionEvent (
1679
+ mqbstat::ClusterStats::PartitionEventType::
1680
+ e_PARTITION_REPLICATION,
1681
+ queue_p->partitionId (),
1682
+ timeDelta);
1683
+ }
1680
1684
1681
1685
if (!d_isClientGeneratingGUIDs) {
1682
1686
// Legacy client.
You can’t perform that action at this time.
0 commit comments