org.springframework.integration.rsocket

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 bean are ready in the application context.

Since:

5.2

Author:

Artem Bilan

See Also:

IntegrationRSocketMessageHandler

Field Summary

Fields

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

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

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

Method Summary

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()
protected MimeType	getMetadataMimeType()
org.springframework.messaging.rsocket.RSocketStrategies	getRSocketStrategies()
boolean	isAutoStartup()
boolean	isRunning()
void	setApplicationContext(ApplicationContext applicationContext)
void	setAutoStartup(boolean autoStartup)
void	setDataMimeType(MimeType dataMimeType) Configure a MimeType for data exchanging.
void	setEndpoints(IntegrationRSocketEndpoint... endpoints) Configure IntegrationRSocketEndpoint instances for mapping nad handling requests.
void	setMetadataExtractor(org.springframework.messaging.rsocket.MetadataExtractor extractor) Configure a MetadataExtractor to extract the route and possibly other metadata from the first payload of incoming requests.
void	setMetadataMimeType(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()

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, stop

Field Detail

rSocketMessageHandler

protected final org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler

Constructor Detail

AbstractRSocketConnector

protected AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler)

Method Detail

setDataMimeType

public void setDataMimeType(MimeType dataMimeType)

Configure a MimeType for data exchanging.

Parameters:

dataMimeType - the MimeType to use.

getDataMimeType

protected 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(org.springframework.messaging.rsocket.RSocketStrategies rsocketStrategies)

Configure a RSocketStrategies for data encoding/decoding.

Parameters:

rsocketStrategies - the RSocketStrategies to use.

getRSocketStrategies

public org.springframework.messaging.rsocket.RSocketStrategies getRSocketStrategies()

setEndpoints

public void setEndpoints(IntegrationRSocketEndpoint... endpoints)

Configure IntegrationRSocketEndpoint instances for mapping nad handling requests.

Parameters:

endpoints - the IntegrationRSocketEndpoint instances for handling inbound requests.

See Also:

addEndpoint(IntegrationRSocketEndpoint)

setMetadataExtractor

public void setMetadataExtractor(org.springframework.messaging.rsocket.MetadataExtractor extractor)

Configure a MetadataExtractor to extract the route and possibly other metadata from the first payload of incoming requests.

By default this is a DefaultMetadataExtractor with the configured RSocketStrategies (and decoders), extracting a route from "message/x.rsocket.routing.v0" or "text/plain" metadata entries.

Parameters:

extractor - the extractor to use

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