@Override
  public void error(final ErrorMessage msg) {
    inner.error(() -> throwIfNotRightSchema(msg.get(config)));
  }
@Test
  public void shouldLogError() {
    // When:
    processingLogger.error(errorMsg);

    // Then:
    final SchemaAndValue msg = verifyErrorMessage();
    assertThat(msg, is(msg));
  }