DBZ-8135 InProcessSignalChannel#read() returns empty list when channel is closed
This commit is contained in:
parent
9965835e15
commit
fe5196ac47
@ -49,6 +49,9 @@ public void init(CommonConnectorConfig connectorConfig) {
|
||||
|
||||
@Override
|
||||
public List<SignalRecord> read() {
|
||||
if (!open.get()) {
|
||||
return List.of();
|
||||
}
|
||||
return Stream.ofNullable(signals.poll()).toList();
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user