Interface GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder

  • All Superinterfaces:
    org.apache.camel.builder.EndpointConsumerBuilder, org.apache.camel.EndpointConsumerResolver
    All Known Subinterfaces:
    GrpcEndpointBuilderFactory.GrpcEndpointBuilder
    Enclosing interface:
    GrpcEndpointBuilderFactory

    public static interface GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder
    extends org.apache.camel.builder.EndpointConsumerBuilder
    Builder for endpoint consumers for the gRPC component.
    • Method Detail

      • autoDiscoverClientInterceptors

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder autoDiscoverClientInterceptors​(boolean autoDiscoverClientInterceptors)
        Setting the autoDiscoverClientInterceptors mechanism, if true, the component will look for a ClientInterceptor instance in the registry automatically otherwise it will skip that checking. The option is a: boolean type. Default: true Group: common
      • autoDiscoverClientInterceptors

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder autoDiscoverClientInterceptors​(String autoDiscoverClientInterceptors)
        Setting the autoDiscoverClientInterceptors mechanism, if true, the component will look for a ClientInterceptor instance in the registry automatically otherwise it will skip that checking. The option will be converted to a boolean type. Default: true Group: common
      • bridgeErrorHandler

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder bridgeErrorHandler​(boolean bridgeErrorHandler)
        Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option is a: boolean type. Default: false Group: consumer
      • bridgeErrorHandler

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder bridgeErrorHandler​(String bridgeErrorHandler)
        Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option will be converted to a boolean type. Default: false Group: consumer
      • consumerStrategy

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder consumerStrategy​(GrpcEndpointBuilderFactory.GrpcConsumerStrategy consumerStrategy)
        This option specifies the top-level strategy for processing service requests and responses in streaming mode. If an aggregation strategy is selected, all requests will be accumulated in the list, then transferred to the flow, and the accumulated responses will be sent to the sender. If a propagation strategy is selected, request is sent to the stream, and the response will be immediately sent back to the sender. The option is a: org.apache.camel.component.grpc.GrpcConsumerStrategy type. Default: PROPAGATION Group: consumer
      • consumerStrategy

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder consumerStrategy​(String consumerStrategy)
        This option specifies the top-level strategy for processing service requests and responses in streaming mode. If an aggregation strategy is selected, all requests will be accumulated in the list, then transferred to the flow, and the accumulated responses will be sent to the sender. If a propagation strategy is selected, request is sent to the stream, and the response will be immediately sent back to the sender. The option will be converted to a org.apache.camel.component.grpc.GrpcConsumerStrategy type. Default: PROPAGATION Group: consumer
      • forwardOnError

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder forwardOnError​(boolean forwardOnError)
        Determines if onError events should be pushed to the Camel route. Exceptions will be set as message body. The option is a: boolean type. Default: false Group: consumer
      • forwardOnError

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder forwardOnError​(String forwardOnError)
        Determines if onError events should be pushed to the Camel route. Exceptions will be set as message body. The option will be converted to a boolean type. Default: false Group: consumer
      • maxConcurrentCallsPerConnection

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder maxConcurrentCallsPerConnection​(int maxConcurrentCallsPerConnection)
        The maximum number of concurrent calls permitted for each incoming server connection. The option is a: int type. Default: 2147483647 Group: consumer
      • maxConcurrentCallsPerConnection

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder maxConcurrentCallsPerConnection​(String maxConcurrentCallsPerConnection)
        The maximum number of concurrent calls permitted for each incoming server connection. The option will be converted to a int type. Default: 2147483647 Group: consumer
      • routeControlledStreamObserver

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder routeControlledStreamObserver​(boolean routeControlledStreamObserver)
        Lets the route to take control over stream observer. If this value is set to true, then the response observer of gRPC call will be set with the name GrpcConstants.GRPC_RESPONSE_OBSERVER in the Exchange object. Please note that the stream observer's onNext(), onError(), onCompleted() methods should be called in the route. The option is a: boolean type. Default: false Group: consumer
      • routeControlledStreamObserver

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder routeControlledStreamObserver​(String routeControlledStreamObserver)
        Lets the route to take control over stream observer. If this value is set to true, then the response observer of gRPC call will be set with the name GrpcConstants.GRPC_RESPONSE_OBSERVER in the Exchange object. Please note that the stream observer's onNext(), onError(), onCompleted() methods should be called in the route. The option will be converted to a boolean type. Default: false Group: consumer
      • authenticationType

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder authenticationType​(String authenticationType)
        Authentication method type in advance to the SSL/TLS negotiation. The option will be converted to a org.apache.camel.component.grpc.GrpcAuthType type. Default: NONE Group: security
      • negotiationType

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder negotiationType​(String negotiationType)
        Identifies the security negotiation type used for HTTP/2 communication. The option will be converted to a io.grpc.netty.NegotiationType type. Default: PLAINTEXT Group: security
      • trustCertCollectionResource

        default GrpcEndpointBuilderFactory.GrpcEndpointConsumerBuilder trustCertCollectionResource​(String trustCertCollectionResource)
        The trusted certificates collection file resource in PEM format for verifying the remote endpoint's certificate. The option is a: java.lang.String type. Group: security