opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] Use CompletableFuture

Browse Source
This commit is contained in:
zhouxiang
2022-07-13 11:29:08 +08:00
parent 4059688c76
commit 38ab97cc31
3 changed files with 53 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/service/ClusterGrpcService.java
+18 -18
View File
@@ -52,7 +52,7 @@ import apache.rocketmq.v1.ReportThreadStackTraceResponse;
import apache.rocketmq.v1.SendMessageRequest;
import apache.rocketmq.v1.SendMessageResponse;
import io.grpc.Context;
import io.netty.util.concurrent.CompleteFuture;
import java.util.concurrent.CompletableFuture;
import org.apache.rocketmq.common.constant.LoggerName;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -65,80 +65,80 @@ public class ClusterGrpcService implements GrpcService {
}
@Override
public CompleteFuture<QueryRouteResponse> queryRoute(Context ctx, QueryRouteRequest request) {
public CompletableFuture<QueryRouteResponse> queryRoute(Context ctx, QueryRouteRequest request) {
return null;
}
@Override
public CompleteFuture<HeartbeatResponse> heartbeat(Context ctx, HeartbeatRequest request) {
public CompletableFuture<HeartbeatResponse> heartbeat(Context ctx, HeartbeatRequest request) {
return null;
}
@Override
public CompleteFuture<HealthCheckResponse> healthCheck(Context ctx, HealthCheckRequest request) {
public CompletableFuture<HealthCheckResponse> healthCheck(Context ctx, HealthCheckRequest request) {
return null;
}
@Override
public CompleteFuture<SendMessageResponse> sendMessage(Context ctx, SendMessageRequest request) {
public CompletableFuture<SendMessageResponse> sendMessage(Context ctx, SendMessageRequest request) {
return null;
}
@Override
public CompleteFuture<QueryAssignmentResponse> queryAssignment(Context ctx, QueryAssignmentRequest request) {
public CompletableFuture<QueryAssignmentResponse> queryAssignment(Context ctx, QueryAssignmentRequest request) {
return null;
}
@Override public CompleteFuture<ReceiveMessageResponse> receiveMessage(Context ctx, ReceiveMessageRequest request) {
@Override public CompletableFuture<ReceiveMessageResponse> receiveMessage(Context ctx, ReceiveMessageRequest request) {
return null;
}
@Override public CompleteFuture<AckMessageResponse> ackMessage(Context ctx, AckMessageRequest request) {
@Override public CompletableFuture<AckMessageResponse> ackMessage(Context ctx, AckMessageRequest request) {
return null;
}
@Override public CompleteFuture<NackMessageResponse> nackMessage(Context ctx, NackMessageRequest request) {
@Override public CompletableFuture<NackMessageResponse> nackMessage(Context ctx, NackMessageRequest request) {
return null;
}
@Override
public CompleteFuture<ForwardMessageToDeadLetterQueueResponse> forwardMessageToDeadLetterQueue(Context ctx,
public CompletableFuture<ForwardMessageToDeadLetterQueueResponse> forwardMessageToDeadLetterQueue(Context ctx,
ForwardMessageToDeadLetterQueueRequest request) {
return null;
}
@Override public CompleteFuture<EndTransactionResponse> endTransaction(Context ctx, EndTransactionRequest request) {
@Override public CompletableFuture<EndTransactionResponse> endTransaction(Context ctx, EndTransactionRequest request) {
return null;
}
@Override public CompleteFuture<QueryOffsetResponse> queryOffset(Context ctx, QueryOffsetRequest request) {
@Override public CompletableFuture<QueryOffsetResponse> queryOffset(Context ctx, QueryOffsetRequest request) {
return null;
}
@Override public CompleteFuture<PullMessageResponse> pullMessage(Context ctx, PullMessageRequest request) {
@Override public CompletableFuture<PullMessageResponse> pullMessage(Context ctx, PullMessageRequest request) {
return null;
}
@Override public CompleteFuture<PollCommandResponse> pollCommand(Context ctx, PollCommandRequest request) {
@Override public CompletableFuture<PollCommandResponse> pollCommand(Context ctx, PollCommandRequest request) {
return null;
}
@Override public CompleteFuture<ReportThreadStackTraceResponse> reportThreadStackTrace(Context ctx,
@Override public CompletableFuture<ReportThreadStackTraceResponse> reportThreadStackTrace(Context ctx,
ReportThreadStackTraceRequest request) {
return null;
}
@Override public CompleteFuture<ReportMessageConsumptionResultResponse> reportMessageConsumptionResult(Context ctx,
@Override public CompletableFuture<ReportMessageConsumptionResultResponse> reportMessageConsumptionResult(Context ctx,
ReportMessageConsumptionResultRequest request) {
return null;
}
@Override public CompleteFuture<NotifyClientTerminationResponse> notifyClientTermination(Context ctx,
@Override public CompletableFuture<NotifyClientTerminationResponse> notifyClientTermination(Context ctx,
NotifyClientTerminationRequest request) {
return null;
}
@Override public CompleteFuture<ChangeInvisibleDurationResponse> changeInvisibleDuration(Context ctx,
@Override public CompletableFuture<ChangeInvisibleDurationResponse> changeInvisibleDuration(Context ctx,
ChangeInvisibleDurationRequest request) {
return null;
}
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/service/GrpcService.java
+18 -18
View File
@@ -52,46 +52,46 @@ import apache.rocketmq.v1.ReportThreadStackTraceResponse;
import apache.rocketmq.v1.SendMessageRequest;
import apache.rocketmq.v1.SendMessageResponse;
import io.grpc.Context;
import io.netty.util.concurrent.CompleteFuture;
import org.apache.rocketmq.proxy.common.StartAndShutdown;
import java.util.concurrent.CompletableFuture;
public interface GrpcService extends StartAndShutdown {
CompleteFuture<QueryRouteResponse> queryRoute(Context ctx, QueryRouteRequest request);
CompletableFuture<QueryRouteResponse> queryRoute(Context ctx, QueryRouteRequest request);
CompleteFuture<HeartbeatResponse> heartbeat(Context ctx, HeartbeatRequest request);
CompletableFuture<HeartbeatResponse> heartbeat(Context ctx, HeartbeatRequest request);
CompleteFuture<HealthCheckResponse> healthCheck(Context ctx, HealthCheckRequest request);
CompletableFuture<HealthCheckResponse> healthCheck(Context ctx, HealthCheckRequest request);
CompleteFuture<SendMessageResponse> sendMessage(Context ctx, SendMessageRequest request);
CompletableFuture<SendMessageResponse> sendMessage(Context ctx, SendMessageRequest request);
CompleteFuture<QueryAssignmentResponse> queryAssignment(Context ctx, QueryAssignmentRequest request);
CompletableFuture<QueryAssignmentResponse> queryAssignment(Context ctx, QueryAssignmentRequest request);
CompleteFuture<ReceiveMessageResponse> receiveMessage(Context ctx, ReceiveMessageRequest request);
CompletableFuture<ReceiveMessageResponse> receiveMessage(Context ctx, ReceiveMessageRequest request);
CompleteFuture<AckMessageResponse> ackMessage(Context ctx, AckMessageRequest request);
CompletableFuture<AckMessageResponse> ackMessage(Context ctx, AckMessageRequest request);
CompleteFuture<NackMessageResponse> nackMessage(Context ctx, NackMessageRequest request);
CompletableFuture<NackMessageResponse> nackMessage(Context ctx, NackMessageRequest request);
CompleteFuture<ForwardMessageToDeadLetterQueueResponse> forwardMessageToDeadLetterQueue(Context ctx,
CompletableFuture<ForwardMessageToDeadLetterQueueResponse> forwardMessageToDeadLetterQueue(Context ctx,
ForwardMessageToDeadLetterQueueRequest request);
CompleteFuture<EndTransactionResponse> endTransaction(Context ctx, EndTransactionRequest request);
CompletableFuture<EndTransactionResponse> endTransaction(Context ctx, EndTransactionRequest request);
CompleteFuture<QueryOffsetResponse> queryOffset(Context ctx, QueryOffsetRequest request);
CompletableFuture<QueryOffsetResponse> queryOffset(Context ctx, QueryOffsetRequest request);
CompleteFuture<PullMessageResponse> pullMessage(Context ctx, PullMessageRequest request);
CompletableFuture<PullMessageResponse> pullMessage(Context ctx, PullMessageRequest request);
CompleteFuture<PollCommandResponse> pollCommand(Context ctx, PollCommandRequest request);
CompletableFuture<PollCommandResponse> pollCommand(Context ctx, PollCommandRequest request);
CompleteFuture<ReportThreadStackTraceResponse> reportThreadStackTrace(Context ctx,
CompletableFuture<ReportThreadStackTraceResponse> reportThreadStackTrace(Context ctx,
ReportThreadStackTraceRequest request);
CompleteFuture<ReportMessageConsumptionResultResponse> reportMessageConsumptionResult(Context ctx,
CompletableFuture<ReportMessageConsumptionResultResponse> reportMessageConsumptionResult(Context ctx,
ReportMessageConsumptionResultRequest request);
CompleteFuture<NotifyClientTerminationResponse> notifyClientTermination(Context ctx,
CompletableFuture<NotifyClientTerminationResponse> notifyClientTermination(Context ctx,
NotifyClientTerminationRequest request);
CompleteFuture<ChangeInvisibleDurationResponse> changeInvisibleDuration(Context ctx,
CompletableFuture<ChangeInvisibleDurationResponse> changeInvisibleDuration(Context ctx,
ChangeInvisibleDurationRequest request);
}
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/service/LocalGrpcService.java
+17 -18
View File
@@ -53,7 +53,6 @@ import apache.rocketmq.v1.ReportThreadStackTraceResponse;
import apache.rocketmq.v1.SendMessageRequest;
import apache.rocketmq.v1.SendMessageResponse;
import io.grpc.Context;
import io.netty.util.concurrent.CompleteFuture;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
@@ -86,19 +85,19 @@ public class LocalGrpcService implements GrpcService {
this.sendChannelManager = new ChannelManager<>();
}
@Override public CompleteFuture<QueryRouteResponse> queryRoute(Context ctx, QueryRouteRequest request) {
@Override public CompletableFuture<QueryRouteResponse> queryRoute(Context ctx, QueryRouteRequest request) {
return null;
}
@Override public CompleteFuture<HeartbeatResponse> heartbeat(Context ctx, HeartbeatRequest request) {
@Override public CompletableFuture<HeartbeatResponse> heartbeat(Context ctx, HeartbeatRequest request) {
return null;
}
@Override public CompleteFuture<HealthCheckResponse> healthCheck(Context ctx, HealthCheckRequest request) {
@Override public CompletableFuture<HealthCheckResponse> healthCheck(Context ctx, HealthCheckRequest request) {
return null;
}
@Override public CompleteFuture<SendMessageResponse> sendMessage(Context ctx, SendMessageRequest request) {
@Override public CompletableFuture<SendMessageResponse> sendMessage(Context ctx, SendMessageRequest request) {
SendMessageRequestHeader requestHeader = Converter.buildSendMessageRequestHeader(request);
RemotingCommand command = RemotingCommand.createRequestCommand(RequestCode.SEND_MESSAGE, requestHeader);
Message message = request.getMessage();
@@ -128,60 +127,60 @@ public class LocalGrpcService implements GrpcService {
}
@Override
public CompleteFuture<QueryAssignmentResponse> queryAssignment(Context ctx, QueryAssignmentRequest request) {
public CompletableFuture<QueryAssignmentResponse> queryAssignment(Context ctx, QueryAssignmentRequest request) {
return null;
}
@Override public CompleteFuture<ReceiveMessageResponse> receiveMessage(Context ctx, ReceiveMessageRequest request) {
@Override public CompletableFuture<ReceiveMessageResponse> receiveMessage(Context ctx, ReceiveMessageRequest request) {
return null;
}
@Override public CompleteFuture<AckMessageResponse> ackMessage(Context ctx, AckMessageRequest request) {
@Override public CompletableFuture<AckMessageResponse> ackMessage(Context ctx, AckMessageRequest request) {
return null;
}
@Override public CompleteFuture<NackMessageResponse> nackMessage(Context ctx, NackMessageRequest request) {
@Override public CompletableFuture<NackMessageResponse> nackMessage(Context ctx, NackMessageRequest request) {
return null;
}
@Override
public CompleteFuture<ForwardMessageToDeadLetterQueueResponse> forwardMessageToDeadLetterQueue(Context ctx,
public CompletableFuture<ForwardMessageToDeadLetterQueueResponse> forwardMessageToDeadLetterQueue(Context ctx,
ForwardMessageToDeadLetterQueueRequest request) {
return null;
}
@Override public CompleteFuture<EndTransactionResponse> endTransaction(Context ctx, EndTransactionRequest request) {
@Override public CompletableFuture<EndTransactionResponse> endTransaction(Context ctx, EndTransactionRequest request) {
return null;
}
@Override public CompleteFuture<QueryOffsetResponse> queryOffset(Context ctx, QueryOffsetRequest request) {
@Override public CompletableFuture<QueryOffsetResponse> queryOffset(Context ctx, QueryOffsetRequest request) {
return null;
}
@Override public CompleteFuture<PullMessageResponse> pullMessage(Context ctx, PullMessageRequest request) {
@Override public CompletableFuture<PullMessageResponse> pullMessage(Context ctx, PullMessageRequest request) {
return null;
}
@Override public CompleteFuture<PollCommandResponse> pollCommand(Context ctx, PollCommandRequest request) {
@Override public CompletableFuture<PollCommandResponse> pollCommand(Context ctx, PollCommandRequest request) {
return null;
}
@Override public CompleteFuture<ReportThreadStackTraceResponse> reportThreadStackTrace(Context ctx,
@Override public CompletableFuture<ReportThreadStackTraceResponse> reportThreadStackTrace(Context ctx,
ReportThreadStackTraceRequest request) {
return null;
}
@Override public CompleteFuture<ReportMessageConsumptionResultResponse> reportMessageConsumptionResult(Context ctx,
@Override public CompletableFuture<ReportMessageConsumptionResultResponse> reportMessageConsumptionResult(Context ctx,
ReportMessageConsumptionResultRequest request) {
return null;
}
@Override public CompleteFuture<NotifyClientTerminationResponse> notifyClientTermination(Context ctx,
@Override public CompletableFuture<NotifyClientTerminationResponse> notifyClientTermination(Context ctx,
NotifyClientTerminationRequest request) {
return null;
}
@Override public CompleteFuture<ChangeInvisibleDurationResponse> changeInvisibleDuration(Context ctx,
@Override public CompletableFuture<ChangeInvisibleDurationResponse> changeInvisibleDuration(Context ctx,
ChangeInvisibleDurationRequest request) {
return null;
}