public final class GrpcUtils extends Object
Modifier and Type | Method and Description |
---|---|
static Object |
addClientCallCredentials(Object grpcStub,
io.grpc.CallCredentials creds) |
static Object |
constructGrpcAsyncStub(String packageName,
String serviceName,
io.grpc.Channel channel,
io.grpc.CallCredentials creds,
org.apache.camel.CamelContext context) |
static Object |
constructGrpcBlockingStub(String packageName,
String serviceName,
io.grpc.Channel channel,
io.grpc.CallCredentials creds,
org.apache.camel.CamelContext context) |
static Class |
constructGrpcImplBaseClass(String packageName,
String serviceName,
org.apache.camel.CamelContext context) |
static String |
convertMethod2CamelCase(String method)
Migrated MixedLower function from the gRPC converting plugin source code
(https://github.com/grpc/grpc-java/blob/master/compiler/src/java_plugin/cpp/java_generator.cpp)
- decapitalize the first letter
- remove embedded underscores & capitalize the following letter
|
static String |
extractServiceName(String service) |
static String |
extractServicePackage(String service) |
static void |
invokeAsyncMethod(Object asyncStubClass,
String invokeMethod,
Object request,
io.grpc.stub.StreamObserver responseObserver) |
static io.grpc.stub.StreamObserver<Object> |
invokeAsyncMethodStreaming(Object asyncStubClass,
String invokeMethod,
io.grpc.stub.StreamObserver<?> responseObserver) |
static Object |
invokeSyncMethod(Object blockingStubClass,
String invokeMethod,
Object request) |
public static Object constructGrpcAsyncStub(String packageName, String serviceName, io.grpc.Channel channel, io.grpc.CallCredentials creds, org.apache.camel.CamelContext context)
public static Object constructGrpcBlockingStub(String packageName, String serviceName, io.grpc.Channel channel, io.grpc.CallCredentials creds, org.apache.camel.CamelContext context)
public static Object addClientCallCredentials(Object grpcStub, io.grpc.CallCredentials creds)
public static Class constructGrpcImplBaseClass(String packageName, String serviceName, org.apache.camel.CamelContext context)
public static void invokeAsyncMethod(Object asyncStubClass, String invokeMethod, Object request, io.grpc.stub.StreamObserver responseObserver)
public static io.grpc.stub.StreamObserver<Object> invokeAsyncMethodStreaming(Object asyncStubClass, String invokeMethod, io.grpc.stub.StreamObserver<?> responseObserver)
public static Object invokeSyncMethod(Object blockingStubClass, String invokeMethod, Object request)
public static String convertMethod2CamelCase(String method)
Apache Camel