public synchronized void destinationFailed(Integer destinationId) {
        ArrayList<Integer> newDestinationIds = new ArrayList<>(activeDestinationIds);
        newDestinationIds.remove(destinationId);
        activeDestinationIds = newDestinationIds;
    }
Remove a given destination from available set of destination IDs. Once this method is called for a given
destination ID, that particular destination ID will not included in the return value of subsequent
getDestinationsToPublish() is calls

@param destinationId the ID of the destination to be removed
modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/sink/distributed/DistributionStrategy.java