### Question:
DefaultSubscriptionService implements SubscriptionService { @Override public void unsubscribeToAllSubscriptions(String nodeName) { filterSubscriptions .entrySet() .removeIf(entry -> entry.getValue().getNode().equals(nodeName)); } @Autowired  DefaultSubscriptionService(ChainServicesContainer chainServices,
                                      ContractEventFilterRepository eventFilterRepository,
                                      EventeumEventBroadcaster eventeumEventBroadcaster,
                                      List<BlockListener> blockListeners,
                                      @Qualifier("eternalRetryTemplate") RetryTemplate retryTemplate,
                                      EventSyncService eventSyncService); void init(List<ContractEventFilter> initFilters); @Override ContractEventFilter registerContractEventFilter(ContractEventFilter filter, boolean broadcast); @Override @Async ContractEventFilter registerContractEventFilterWithRetries(ContractEventFilter filter, boolean broadcast); @Override List<ContractEventFilter> listContractEventFilters(); @Override void unregisterContractEventFilter(String filterId); @Override void unregisterContractEventFilter(String filterId, boolean broadcast); @Override void unsubscribeToAllSubscriptions(String nodeName); @Override SubscriptionServiceState getState();  }### Answer:
@Test public void testUnsubscribeToAllSubscriptions() { final ContractEventFilter filter1 = createEventFilter("filter1", Constants.DEFAULT_NODE_NAME); final ContractEventFilter filter2 = createEventFilter(); underTest.registerContractEventFilter(filter1, false); underTest.registerContractEventFilter(filter2, false); underTest.unsubscribeToAllSubscriptions(Constants.DEFAULT_NODE_NAME); assertEquals(0, underTest.listContractEventFilters().size()); }