@Test(expected = DecoderNotFoundException.class)
public void testOnCommandStartedWhenDecoderNotRegistred() {

    // Setup
    final InboundCommandStarted commandStarted = mock(InboundCommandStarted.class);
    final String subject = "subject";
    final CommandMeta meta = mock(CommandMeta.class);
    when(mockDecoderRegistry.containsKey(subject)).thenReturn(false);
    when(commandStarted.getMeta()).thenReturn(meta);
    // Run the test
    languageTranslatorImplUnderTest.onCommandStarted(commandStarted);
    // Verify the results
    verify(mockBubbleCache, never()).addBubble(anyString(), any(BubbleMessage.class));
    verify(mockPublisher, never()).publishEvent(any(BaseTransactionEvent.class));
}