|
|
@ -69,7 +69,7 @@ public class RSocketServerAutoConfiguration {
|
|
|
|
RSocketWebSocketNettyRouteProvider rSocketWebsocketRouteProvider(RSocketProperties properties,
|
|
|
|
RSocketWebSocketNettyRouteProvider rSocketWebsocketRouteProvider(RSocketProperties properties,
|
|
|
|
RSocketMessageHandler messageHandler) {
|
|
|
|
RSocketMessageHandler messageHandler) {
|
|
|
|
return new RSocketWebSocketNettyRouteProvider(properties.getServer().getMappingPath(),
|
|
|
|
return new RSocketWebSocketNettyRouteProvider(properties.getServer().getMappingPath(),
|
|
|
|
messageHandler.serverAcceptor());
|
|
|
|
messageHandler.serverResponder());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -101,7 +101,7 @@ public class RSocketServerAutoConfiguration {
|
|
|
|
@ConditionalOnMissingBean
|
|
|
|
@ConditionalOnMissingBean
|
|
|
|
RSocketServerBootstrap rSocketServerBootstrap(RSocketServerFactory rSocketServerFactory,
|
|
|
|
RSocketServerBootstrap rSocketServerBootstrap(RSocketServerFactory rSocketServerFactory,
|
|
|
|
RSocketMessageHandler rSocketMessageHandler) {
|
|
|
|
RSocketMessageHandler rSocketMessageHandler) {
|
|
|
|
return new RSocketServerBootstrap(rSocketServerFactory, rSocketMessageHandler.serverAcceptor());
|
|
|
|
return new RSocketServerBootstrap(rSocketServerFactory, rSocketMessageHandler.serverResponder());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|