github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

Remove redundant null check from DeadLetterQueueReader

Browse source 
Fixes #7948
This commit is contained in:
Rob Bavey 2017-08-09 09:21:25 -04:00
parent edbb1e021f
commit b231036f87
2 changed files with 0 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

3
logstash-core/src/main/java/org/logstash/common/io/DeadLetterQueueReader.java
View file

@ -65,9 +65,6 @@ public final class DeadLetterQueueReader implements Closeable {
currentReader = new RecordIOReader(segment); currentReader = new RecordIOReader(segment);
byte[] event = currentReader.seekToNextEventPosition(timestamp, (b) -> { byte[] event = currentReader.seekToNextEventPosition(timestamp, (b) -> {
try { try {
if (b == null){
return null;
}
return DLQEntry.deserialize(b).getEntryTime(); return DLQEntry.deserialize(b).getEntryTime();
} catch (IOException e) { } catch (IOException e) {
return null; return null;

1
logstash-core/src/main/java/org/logstash/common/io/RecordIOReader.java
View file

@ -263,7 +263,6 @@ public final class RecordIOReader implements Closeable {
this.channel.position(bufferState.channelPosition); this.channel.position(bufferState.channelPosition);
this.channelPosition = channel.position(); this.channelPosition = channel.position();
this.currentBlockSizeReadFromChannel = bufferState.currentBlockSizeReadFromChannel; this.currentBlockSizeReadFromChannel = bufferState.currentBlockSizeReadFromChannel;
} }
final static class BufferState { final static class BufferState {