@Test public void beginBatch_shouldOpenAFileChannelAndLockTheFile() throws Exception { destination.beginBatch(); verify(provider).getChannel(); verify(channel).lock(); verifyZeroInteractions(lock); }
@Override public void beginBatch() throws Exception { closeAnyOpenBatch(); latch = new CountDownLatch(1); currentChannel = provider.getChannel(); currentLock = currentChannel.channel.lock(); }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void beginBatch() throws Exception { closeAnyOpenBatch(); latch = new CountDownLatch(1); currentChannel = provider.getChannel(); currentLock = currentChannel.channel.lock(); } }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void beginBatch() throws Exception { closeAnyOpenBatch(); latch = new CountDownLatch(1); currentChannel = provider.getChannel(); currentLock = currentChannel.channel.lock(); } PathDestination(FileChannelProvider provider, StackTraceProcessor processor, ActiveRotationRegistry registry); }
PathDestination implements Destination<T>, ActiveRotationSupport { @Override public void beginBatch() throws Exception { closeAnyOpenBatch(); latch = new CountDownLatch(1); currentChannel = provider.getChannel(); currentLock = currentChannel.channel.lock(); } 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 beginBatch() throws Exception { closeAnyOpenBatch(); latch = new CountDownLatch(1); currentChannel = provider.getChannel(); currentLock = currentChannel.channel.lock(); } 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();  }