public abstract class AbstractRSocketConnector extends Object implements ApplicationContextAware, InitializingBean, DisposableBean, SmartInitializingSingleton, SmartLifecycle
It accepts IntegrationRSocketEndpoint instances for mapping registration via an internal
IntegrationRSocketAcceptor or performs an auto-detection otherwise, when all bean are ready
in the application context.
IntegrationRSocketAcceptor| Modifier and Type | Field and Description |
|---|---|
protected org.springframework.integration.rsocket.IntegrationRSocketAcceptor |
rsocketAcceptor |
DEFAULT_PHASE| Modifier | Constructor and Description |
|---|---|
protected |
AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketAcceptor rsocketAcceptor) |
| Modifier and Type | Method and Description |
|---|---|
void |
addEndpoint(IntegrationRSocketEndpoint endpoint)
Add an
IntegrationRSocketEndpoint for mapping and handling RSocket requests. |
void |
afterPropertiesSet() |
void |
afterSingletonsInstantiated() |
protected abstract void |
doStart() |
protected MimeType |
getDataMimeType() |
org.springframework.messaging.rsocket.RSocketStrategies |
getRSocketStrategies() |
boolean |
isRunning() |
void |
setApplicationContext(ApplicationContext applicationContext) |
void |
setDataMimeType(MimeType dataMimeType)
Configure a
MimeType for data exchanging. |
void |
setEndpoints(IntegrationRSocketEndpoint... endpoints)
Configure
IntegrationRSocketEndpoint instances for mapping nad handling requests. |
void |
setRSocketStrategies(org.springframework.messaging.rsocket.RSocketStrategies rsocketStrategies)
Configure a
RSocketStrategies for data encoding/decoding. |
void |
start() |
void |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdestroygetPhase, isAutoStartup, stopprotected final org.springframework.integration.rsocket.IntegrationRSocketAcceptor rsocketAcceptor
protected AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketAcceptor rsocketAcceptor)
public void setDataMimeType(MimeType dataMimeType)
MimeType for data exchanging.dataMimeType - the MimeType to use.protected MimeType getDataMimeType()
public void setRSocketStrategies(org.springframework.messaging.rsocket.RSocketStrategies rsocketStrategies)
RSocketStrategies for data encoding/decoding.rsocketStrategies - the RSocketStrategies to use.public org.springframework.messaging.rsocket.RSocketStrategies getRSocketStrategies()
public void setEndpoints(IntegrationRSocketEndpoint... endpoints)
IntegrationRSocketEndpoint instances for mapping nad handling requests.endpoints - the IntegrationRSocketEndpoint instances for handling inbound requests.addEndpoint(IntegrationRSocketEndpoint)public void addEndpoint(IntegrationRSocketEndpoint endpoint)
IntegrationRSocketEndpoint for mapping and handling RSocket requests.endpoint - the IntegrationRSocketEndpoint to map.public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext in interface ApplicationContextAwareBeansExceptionpublic void afterPropertiesSet()
afterPropertiesSet in interface InitializingBeanpublic void afterSingletonsInstantiated()
afterSingletonsInstantiated in interface SmartInitializingSingletonprotected abstract void doStart()