@Configuration @ConditionalOnProperty(value="grpc.stub", havingValue="riff") public static class GrpcProcessorConfiguration.RiffStubConfiguration extends Object
Constructor and Description |
---|
RiffStubConfiguration() |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> |
process(reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> request) |
function.ReactorMessageFunctionGrpc.ReactorMessageFunctionStub |
processorStub(io.grpc.Channel grpcChannel) |
@Bean public function.ReactorMessageFunctionGrpc.ReactorMessageFunctionStub processorStub(io.grpc.Channel grpcChannel)
@StreamListener @Output(value="output") public reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> process(@Input(value="input") reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> request)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.