Class AbstractRSocketConnector

java.lang.Object

org.springframework.integration.rsocket.AbstractRSocketConnector

All Implemented Interfaces:

Aware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle

Direct Known Subclasses:

ClientRSocketConnector, ServerRSocketConnector

public abstract class AbstractRSocketConnector
extends Object
implements ApplicationContextAware, InitializingBean, DisposableBean, SmartInitializingSingleton, 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

Author:

Artem Bilan

See Also:

• IntegrationRSocketMessageHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.springframework.integration.rsocket.IntegrationRSocketMessageHandler	rSocketMessageHandler

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler)

Method Summary

Modifier and Type	Method	Description
void	addEndpoint(IntegrationRSocketEndpoint endpoint)	Add an IntegrationRSocketEndpoint for mapping and handling RSocket requests.
void	afterPropertiesSet()
void	afterSingletonsInstantiated()
protected abstract void	doStart()
protected @Nullable MimeType	getDataMimeType()
protected MimeType	getMetadataMimeType()
RSocketStrategies	getRSocketStrategies()
boolean	isAutoStartup()
boolean	isRunning()
void	setApplicationContext(ApplicationContext applicationContext)
void	setAutoStartup(boolean autoStartup)
void	setDataMimeType(@Nullable MimeType dataMimeType)	Configure a MimeType for data exchanging.
void	setEndpoints(IntegrationRSocketEndpoint... endpoints)	Configure IntegrationRSocketEndpoint instances for mapping and handling requests.
void	setMetadataMimeType(MimeType metadataMimeType)	Configure a MimeType for metadata exchanging.
void	setRSocketStrategies(RSocketStrategies rsocketStrategies)	Configure a RSocketStrategies for data encoding/decoding.
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isPauseable, 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 MimeType dataMimeType)

Configure a MimeType for data exchanging.

Parameters:

dataMimeType - the MimeType to use.

getDataMimeType

protected @Nullable MimeType getDataMimeType()

setMetadataMimeType

public void setMetadataMimeType(MimeType metadataMimeType)

Configure a MimeType for metadata exchanging. Default to "message/x.rsocket.composite-metadata.v0".

Parameters:

metadataMimeType - the MimeType to use.

getMetadataMimeType

protected MimeType getMetadataMimeType()

setRSocketStrategies

public void setRSocketStrategies(RSocketStrategies rsocketStrategies)

Configure a RSocketStrategies for data encoding/decoding.

Parameters:

rsocketStrategies - the RSocketStrategies to use.

getRSocketStrategies

public RSocketStrategies getRSocketStrategies()

setEndpoints

public void setEndpoints(IntegrationRSocketEndpoint... endpoints)

Configure IntegrationRSocketEndpoint instances for mapping and handling requests.

Parameters:

endpoints - the IntegrationRSocketEndpoint instances for handling inbound requests.

See Also:

• addEndpoint(IntegrationRSocketEndpoint)

addEndpoint

public void addEndpoint(IntegrationRSocketEndpoint endpoint)

Add an IntegrationRSocketEndpoint for mapping and handling RSocket requests.

Parameters:

endpoint - the IntegrationRSocketEndpoint to map.

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

setAutoStartup

public void setAutoStartup(boolean autoStartup)

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

start

public void start()

Specified by:

start in interface Lifecycle

doStart

protected abstract void doStart()

stop

public void stop()

Specified by:

stop in interface Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle