@Test
public void test() {

    final Connection connection =
            ConnectivityModelFactory.newConnectionBuilder(CONNECTION_ID,
                    ConnectionType.AMQP_10,
                    ConnectivityStatus.OPEN,
                    URI).targets(targets).build();
    final SignalFilter signalFilter = new SignalFilter(connection, connectionMonitorRegistry);
    final List<Target> filteredTargets = signalFilter.filter(signal(signalTopic, readSubjects));
    Assertions.assertThat(filteredTargets)
            .isEqualTo(expectedTargets);
}