FilterSubscriptionImpl filterSubscriptionImpl = (FilterSubscriptionImpl) filterSubscription;
filterSubscriptions.remove(filterSubscriptionImpl);
for (BENode node : filterSubscriptionImpl.getBETree().getNodes()) {
if (node instanceof PredicateNode) {
PredicateNode predicateNode = (PredicateNode) node;
predicateNode.unsubscribe();
}
}
}
}