Infrastructure

The hazelcast event listener implemented by ReplicationEventListener basically does:

ReplicationEventListener.entryUpdated()
  if isAuthoritativeReplicaValid()
    createReplicationTask()

isAuthoritativeReplicaValid() checks whether the replication status for the Authoritative MN is complete.

Hence, any update or add event on the systemmetadata map in Hazelcast will trigger addition of a replication task if the authoritative MN has a completed replica, even if replication is not allowed for the object. This causes a significant number of entries to be added to the replication task queue even though those tasks will never do anything as they will be later rejected.

It would be appropriate in entryUpdated() to also check whether replication of the object is allowed. The overhead would be minimal since a copy of the system metadata is already available in entryUpdated(). The same logic should also be added to entryAdded().

ReplicationManager implements boolean isAllowed(SystemMetadata sysmeta) which should do the job.