public void checkProducerTransactionState(//
final Channel channel,//
final CheckTransactionStateRequestHeader requestHeader,//
final SelectMapedBufferResult selectMapedBufferResult//
) {
RemotingCommand request =
RemotingCommand.createRequestCommand(RequestCode.CHECK_TRANSACTION_STATE, requestHeader);
request.markOnewayRPC();
try {
FileRegion fileRegion =
new OneMessageTransfer(request.encodeHeader(selectMapedBufferResult.getSize()),
selectMapedBufferResult);
channel.writeAndFlush(fileRegion).addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
selectMapedBufferResult.release();
if (!future.isSuccess()) {
log.error("invokeProducer failed,", future.cause());
}
}
});
}
catch (Throwable e) {
log.error("invokeProducer exception", e);
selectMapedBufferResult.release();
}
}
Broker2Client.java 文件源码
java
阅读 30
收藏 0
点赞 0
评论 0
项目:reading-and-annotate-rocketmq-3.4.6
作者:
评论列表
文章目录