Skip to content

Commit

Permalink
Listen RSocket on 0.0.0.0
Browse files Browse the repository at this point in the history
  • Loading branch information
bsideup committed Oct 30, 2018
1 parent 40a4282 commit 359e836
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ public void initialize(GenericApplicationContext applicationContext) {
val liiklusService = applicationContext.getBean(ReactorLiiklusServiceImpl.class);
return RSocketFactory.receive()
.acceptor((setup, sendingSocket) -> Mono.just(new RequestHandlingRSocket(new LiiklusServiceServer(liiklusService, Optional.empty(), Optional.empty()))))
.transport(TcpServerTransport.create(serverProperties.getPort()))
.transport(TcpServerTransport.create(serverProperties.getHost(), serverProperties.getPort()))
.start()
.block();
},
Expand All @@ -54,6 +54,8 @@ public void initialize(GenericApplicationContext applicationContext) {
@Data
static class RSocketServerProperties {

String host = "0.0.0.0";

int port = 8081;

boolean enabled = true;
Expand Down

0 comments on commit 359e836

Please sign in to comment.