eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventMeshSubscribeReply.java [62:69]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Optional<EventMeshMessage> handle(final EventMeshMessage msg) {
        log.info("receive request-reply msg: {}", msg);
        if (msg != null) {
            return Optional.of(msg);
        } else {
            return Optional.empty();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsSubscribeReply.java [64:72]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public Optional<CloudEvent> handle(final CloudEvent msg) {
        log.info("receive request-reply msg: {}", msg);

        if (msg != null) {
            return Optional.of(msg);
        } else {
            return Optional.empty();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -