DefaultMuteableConnectionLogger implements MuteableConnectionLogger { @Override public void success(final ConnectionMonitor.InfoProvider infoProvider) { if (active) { delegate.success(infoProvider); } else { logTraceWithCorrelationId("Not logging success since logger is muted.", infoProvider); } } DefaultMuteableConnectionLogger(final ConnectionId connectionId, final ConnectionLogger delegate); @Override void mute(); @Override void unmute(); @Override boolean isMuted(); @Override void success(final ConnectionMonitor.InfoProvider infoProvider); @Override void success(final ConnectionMonitor.InfoProvider infoProvider, final String message,
            final Object... messageArguments); @Override void failure(final ConnectionMonitor.InfoProvider infoProvider, @Nullable final DittoRuntimeException exception); @Override void failure(final ConnectionMonitor.InfoProvider infoProvider, final String message,
            final Object... messageArguments); @Override void exception(final ConnectionMonitor.InfoProvider infoProvider, @Nullable final Exception exception); @Override void exception(final ConnectionMonitor.InfoProvider infoProvider, final String message,
            final Object... messageArguments); @Override void clear(); @Override Collection<LogEntry> getLogs(); @Override boolean equals(@Nullable final Object o); @Override int hashCode(); @Override String toString();  }
@Test public void success() { final DefaultMuteableConnectionLogger unmuted = unmuted(); unmuted.success(INFO_PROVIDER); verify(delegate).success(INFO_PROVIDER); }
@Test public void success1() { final DefaultMuteableConnectionLogger unmuted = unmuted(); unmuted.success(INFO_PROVIDER, MESSAGE, THING_ID); verify(delegate).success(INFO_PROVIDER, MESSAGE, THING_ID); }