public abstract class AbstractRSocketConnector
extends java.lang.Object
implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.SmartLifecycle
It accepts IntegrationRSocketEndpoint instances for mapping registration via an internal
IntegrationRSocketMessageHandler or performs an auto-detection otherwise, when all beans are ready
in the application context.
IntegrationRSocketMessageHandler| Modifier and Type | Field and Description |
|---|---|
protected org.springframework.integration.rsocket.IntegrationRSocketMessageHandler |
rSocketMessageHandler |
| Modifier | Constructor and Description |
|---|---|
protected |
AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler) |
| 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 org.springframework.util.MimeType |
getDataMimeType() |
protected org.springframework.util.MimeType |
getMetadataMimeType() |
org.springframework.messaging.rsocket.RSocketStrategies |
getRSocketStrategies() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext) |
void |
setAutoStartup(boolean autoStartup) |
void |
setDataMimeType(org.springframework.util.MimeType dataMimeType)
Configure a
MimeType for data exchanging. |
void |
setEndpoints(IntegrationRSocketEndpoint... endpoints)
Configure
IntegrationRSocketEndpoint instances for mapping and handling requests. |
void |
setMetadataMimeType(org.springframework.util.MimeType metadataMimeType)
Configure a
MimeType for metadata exchanging. |
void |
setRSocketStrategies(org.springframework.messaging.rsocket.RSocketStrategies rsocketStrategies)
Configure a
RSocketStrategies for data encoding/decoding. |
void |
start() |
void |
stop() |
protected final org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler
protected AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler)
public void setDataMimeType(@Nullable
org.springframework.util.MimeType dataMimeType)
MimeType for data exchanging.dataMimeType - the MimeType to use.@Nullable protected org.springframework.util.MimeType getDataMimeType()
public void setMetadataMimeType(org.springframework.util.MimeType metadataMimeType)
MimeType for metadata exchanging.
Default to "message/x.rsocket.composite-metadata.v0".metadataMimeType - the MimeType to use.protected org.springframework.util.MimeType getMetadataMimeType()
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 and 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(org.springframework.context.ApplicationContext applicationContext)
throws org.springframework.beans.BeansException
setApplicationContext in interface org.springframework.context.ApplicationContextAwareorg.springframework.beans.BeansExceptionpublic void afterPropertiesSet()
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanpublic void afterSingletonsInstantiated()
afterSingletonsInstantiated in interface org.springframework.beans.factory.SmartInitializingSingletonpublic void setAutoStartup(boolean autoStartup)
public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic void start()
start in interface org.springframework.context.Lifecycleprotected abstract void doStart()
public void stop()
stop in interface org.springframework.context.Lifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecycle