未验证 提交 1a92566f 编写于 作者: H He Wang 提交者: GitHub

update checkpoint for record queue (#40)

上级 7d93664d
......@@ -334,6 +334,7 @@ public class ClientHandler extends ChannelInboundHandlerAdapter {
while (true) {
try {
recordQueue.put(new StreamContext.TransferPacket(logMessage));
stream.setCheckpointString(logMessage.getTimestamp());
break;
} catch (InterruptedException e) {
// do nothing
......
......@@ -302,6 +302,15 @@ public class ClientStream {
}
}
/**
* Set checkpoint string.
*
* @param checkpointString Checkpoint string.
*/
public void setCheckpointString(String checkpointString) {
this.checkpointString = checkpointString;
}
/**
* Add a {@link RecordListener} to {@link #listeners}.
*
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册