Advertisement
Guest User

Untitled

a guest
Jun 20th, 2019
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.52 KB | None | 0 0
  1. @Bean
  2. @SneakyThrows
  3. RSocket rSocket() {
  4. return RSocketFactory.connect()
  5. .dataMimeType(MimeTypeUtils.APPLICATION_JSON_VALUE)
  6. .frameDecoder(PayloadDecoder.ZERO_COPY)
  7. .transport(TcpClientTransport.create(new InetSocketAddress("127.0.0.1", 7000)))
  8. .start()
  9. .block();
  10. }
  11.  
  12. @Bean
  13. RSocketRequester requester(RSocketStrategies strategies) {
  14. return RSocketRequester.wrap(rSocket(), MimeTypeUtils.APPLICATION_JSON, strategies);
  15. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement