@Test public void close_shouldRemoveThePathDestinationFromTheActiveRotationRegistry() throws Exception { destination.close(); verify(registry).remove(destination); }
@Override public void close() throws Exception { closeAnyOpenBatch(); registry.remove(this); }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void close() throws Exception { closeAnyOpenBatch(); registry.remove(this); } }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void close() throws Exception { closeAnyOpenBatch(); registry.remove(this); } PathDestination(FileChannelProvider provider, StackTraceProcessor processor, ActiveRotationRegistry registry); }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void close() throws Exception { closeAnyOpenBatch(); registry.remove(this); } PathDestination(FileChannelProvider provider, StackTraceProcessor processor, ActiveRotationRegistry registry); @Override void beginBatch(); @Override void publish(LogicalLogRecord<T> record); @Override void endBatch(); @Override void close(); @Override void refreshFileHandles(); FileChannelProvider getProvider(); @Override StackTraceProcessor getStackTraceProcessor(); ActiveRotationRegistry getActiveRotationRegistry(); }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void close() throws Exception { closeAnyOpenBatch(); registry.remove(this); } PathDestination(FileChannelProvider provider, StackTraceProcessor processor, ActiveRotationRegistry registry); @Override void beginBatch(); @Override void publish(LogicalLogRecord<T> record); @Override void endBatch(); @Override void close(); @Override void refreshFileHandles(); FileChannelProvider getProvider(); @Override StackTraceProcessor getStackTraceProcessor(); ActiveRotationRegistry getActiveRotationRegistry();  }