Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Bean
- @SneakyThrows
- RSocket rSocket() {
- return RSocketFactory.connect()
- .dataMimeType(MimeTypeUtils.APPLICATION_JSON_VALUE)
- .frameDecoder(PayloadDecoder.ZERO_COPY)
- .transport(TcpClientTransport.create(new InetSocketAddress("127.0.0.1", 7000)))
- .start()
- .block();
- }
- @Bean
- RSocketRequester requester(RSocketStrategies strategies) {
- return RSocketRequester.wrap(rSocket(), MimeTypeUtils.APPLICATION_JSON, strategies);
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement