class SourceInfo extends BaseSourceInfo {

    public void opLogEvent(String replicaSetName, Document oplogEvent, Document masterEvent, long orderInTx) {
        Position position = INITIAL_POSITION;
        String namespace = "";
        if (oplogEvent != null) {
            BsonTimestamp ts = extractEventTimestamp(masterEvent);
            Long opId = masterEvent.getLong("h");
            String sessionTxnId = extractSessionTxnId(masterEvent);
            position = new Position(ts, opId, orderInTx, sessionTxnId);
            namespace = oplogEvent.getString("ns");
        }
        positionsByReplicaSetName.put(replicaSetName, position);

        onEvent(replicaSetName, CollectionId.parse(replicaSetName, namespace), position);
    }

    public  SourceInfo(MongoDbConnectorConfig connectorConfig);

}