Class AbstractRSocketConnector
java.lang.Object
org.springframework.integration.rsocket.AbstractRSocketConnector
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
- Direct Known Subclasses:
ClientRSocketConnector,ServerRSocketConnector
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
A base connector container for common RSocket client and server functionality.
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.
- Since:
- 5.2
- See Also:
IntegrationRSocketMessageHandler
-
Field Summary
Fields Modifier and Type Field Description protected org.springframework.integration.rsocket.IntegrationRSocketMessageHandlerrSocketMessageHandler -
Constructor Summary
Constructors Modifier Constructor Description protectedAbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler) -
Method Summary
Modifier and Type Method Description voidaddEndpoint(IntegrationRSocketEndpoint endpoint)Add anIntegrationRSocketEndpointfor mapping and handling RSocket requests.voidafterPropertiesSet()voidafterSingletonsInstantiated()protected abstract voiddoStart()protected org.springframework.util.MimeTypegetDataMimeType()protected org.springframework.util.MimeTypegetMetadataMimeType()org.springframework.messaging.rsocket.RSocketStrategiesgetRSocketStrategies()booleanisAutoStartup()booleanisRunning()voidsetApplicationContext(org.springframework.context.ApplicationContext applicationContext)voidsetAutoStartup(boolean autoStartup)voidsetDataMimeType(org.springframework.util.MimeType dataMimeType)Configure aMimeTypefor data exchanging.voidsetEndpoints(IntegrationRSocketEndpoint... endpoints)ConfigureIntegrationRSocketEndpointinstances for mapping and handling requests.voidsetMetadataMimeType(org.springframework.util.MimeType metadataMimeType)Configure aMimeTypefor metadata exchanging.voidsetRSocketStrategies(org.springframework.messaging.rsocket.RSocketStrategies rsocketStrategies)Configure aRSocketStrategiesfor data encoding/decoding.voidstart()voidstop()
-
Field Details
-
rSocketMessageHandler
protected final org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler
-
-
Constructor Details
-
AbstractRSocketConnector
protected AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler)
-
-
Method Details
-
setDataMimeType
public void setDataMimeType(@Nullable org.springframework.util.MimeType dataMimeType)Configure aMimeTypefor data exchanging.- Parameters:
dataMimeType- theMimeTypeto use.
-
getDataMimeType
@Nullable protected org.springframework.util.MimeType getDataMimeType() -
setMetadataMimeType
public void setMetadataMimeType(org.springframework.util.MimeType metadataMimeType)Configure aMimeTypefor metadata exchanging. Default to"message/x.rsocket.composite-metadata.v0".- Parameters:
metadataMimeType- theMimeTypeto use.
-
getMetadataMimeType
protected org.springframework.util.MimeType getMetadataMimeType() -
setRSocketStrategies
public void setRSocketStrategies(org.springframework.messaging.rsocket.RSocketStrategies rsocketStrategies)Configure aRSocketStrategiesfor data encoding/decoding.- Parameters:
rsocketStrategies- theRSocketStrategiesto use.
-
getRSocketStrategies
public org.springframework.messaging.rsocket.RSocketStrategies getRSocketStrategies() -
setEndpoints
ConfigureIntegrationRSocketEndpointinstances for mapping and handling requests.- Parameters:
endpoints- theIntegrationRSocketEndpointinstances for handling inbound requests.- See Also:
addEndpoint(IntegrationRSocketEndpoint)
-
addEndpoint
Add anIntegrationRSocketEndpointfor mapping and handling RSocket requests.- Parameters:
endpoint- theIntegrationRSocketEndpointto map.
-
setApplicationContext
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException- Specified by:
setApplicationContextin interfaceorg.springframework.context.ApplicationContextAware- Throws:
org.springframework.beans.BeansException
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean
-
afterSingletonsInstantiated
public void afterSingletonsInstantiated()- Specified by:
afterSingletonsInstantiatedin interfaceorg.springframework.beans.factory.SmartInitializingSingleton
-
setAutoStartup
public void setAutoStartup(boolean autoStartup) -
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartupin interfaceorg.springframework.context.SmartLifecycle
-
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
doStart
protected abstract void doStart() -
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-