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 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
FieldsModifier and TypeFieldDescriptionprotected final org.springframework.integration.rsocket.IntegrationRSocketMessageHandlerFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedAbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler) -
Method Summary
Modifier and TypeMethodDescriptionvoidaddEndpoint(IntegrationRSocketEndpoint endpoint) Add anIntegrationRSocketEndpointfor mapping and handling RSocket requests.voidvoidprotected abstract voiddoStart()protected org.springframework.util.MimeTypeprotected org.springframework.util.MimeTypeorg.springframework.messaging.rsocket.RSocketStrategiesbooleanbooleanvoidsetApplicationContext(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()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.beans.factory.DisposableBean
destroyMethods inherited from interface org.springframework.context.SmartLifecycle
getPhase, stop
-
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
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
-