public Set<MessageOutput> getOutputsForMessage(final Message msg) {
        final Set<MessageOutput> result = getStreamOutputsForMessage(msg);
        result.add(defaultMessageOutput);

        return result;
    }
@Test
    public void testAlwaysIncludeDefaultOutput() throws Exception {
        final Message message = mock(Message.class);
        final OutputRouter outputRouter = new OutputRouter(defaultMessageOutput, outputRegistry);

        final Collection<MessageOutput> messageOutputs = outputRouter.getOutputsForMessage(message);

        assertEquals(1, messageOutputs.size());
        assertTrue(messageOutputs.contains(defaultMessageOutput));
    }