Package com.alibaba.spring.boot.rsocket

Class RSocketRequesterSupportImpl

java.lang.Object

com.alibaba.spring.boot.rsocket.RSocketRequesterSupportImpl

All Implemented Interfaces:

RSocketRequesterSupport, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class RSocketRequesterSupportImpl
extends Object
implements RSocketRequesterSupport, org.springframework.context.ApplicationContextAware

RSocket Requester Support implementation: setup payload, published service, token and app info

Author:

leijuan

Field Summary

Fields

Modifier and Type	Field	Description
protected org.springframework.context.ApplicationContext	applicationContext
protected String	appName
protected Properties	env
protected char[]	jwtToken
protected RSocketProperties	properties
protected List<io.rsocket.plugins.RSocketInterceptor>	requestInterceptors
protected List<io.rsocket.plugins.RSocketInterceptor>	responderInterceptors
protected io.rsocket.SocketAcceptor	socketAcceptor

Constructor Summary

Constructors

Constructor	Description
RSocketRequesterSupportImpl(RSocketProperties properties, Properties env, io.rsocket.SocketAcceptor socketAcceptor)

Method Summary

Modifier and Type	Method	Description
void	addRequesterInterceptor(io.rsocket.plugins.RSocketInterceptor interceptor)
void	addResponderInterceptor(io.rsocket.plugins.RSocketInterceptor interceptor)
Supplier<Set<ServiceLocator>>	exposedServices()
String	inputStreamToString(InputStream inputStream)
URI	originUri()
List<io.rsocket.plugins.RSocketInterceptor>	requestInterceptors()
List<io.rsocket.plugins.RSocketInterceptor>	responderInterceptors()
Supplier<CloudEventImpl<ServicesExposedEvent>>	servicesExposedEvent()
void	setApplicationContext(@NotNull org.springframework.context.ApplicationContext applicationContext)
Supplier<io.rsocket.Payload>	setupPayload(String serviceId)
io.rsocket.SocketAcceptor	socketAcceptor()
Supplier<Set<ServiceLocator>>	subscribedServices()

Methods inherited from class java.lang.Object

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

Field Detail

env

protected Properties env

properties

protected RSocketProperties properties

appName

protected String appName

jwtToken

protected char[] jwtToken

applicationContext

protected org.springframework.context.ApplicationContext applicationContext

socketAcceptor

protected io.rsocket.SocketAcceptor socketAcceptor

responderInterceptors

protected List<io.rsocket.plugins.RSocketInterceptor> responderInterceptors

requestInterceptors

protected List<io.rsocket.plugins.RSocketInterceptor> requestInterceptors

Constructor Detail

RSocketRequesterSupportImpl

public RSocketRequesterSupportImpl(RSocketProperties properties,
                                   Properties env,
                                   io.rsocket.SocketAcceptor socketAcceptor)

Method Detail

originUri

public URI originUri()

Specified by:

originUri in interface RSocketRequesterSupport

setupPayload

public Supplier<io.rsocket.Payload> setupPayload(String serviceId)

Specified by:

setupPayload in interface RSocketRequesterSupport

exposedServices

public Supplier<Set<ServiceLocator>> exposedServices()

Specified by:

exposedServices in interface RSocketRequesterSupport

subscribedServices

public Supplier<Set<ServiceLocator>> subscribedServices()

Specified by:

subscribedServices in interface RSocketRequesterSupport

servicesExposedEvent

public Supplier<CloudEventImpl<ServicesExposedEvent>> servicesExposedEvent()

Specified by:

servicesExposedEvent in interface RSocketRequesterSupport

socketAcceptor

public io.rsocket.SocketAcceptor socketAcceptor()

Specified by:

socketAcceptor in interface RSocketRequesterSupport

responderInterceptors

public List<io.rsocket.plugins.RSocketInterceptor> responderInterceptors()

Specified by:

responderInterceptors in interface RSocketRequesterSupport

addResponderInterceptor

public void addResponderInterceptor(io.rsocket.plugins.RSocketInterceptor interceptor)

requestInterceptors

public List<io.rsocket.plugins.RSocketInterceptor> requestInterceptors()

Specified by:

requestInterceptors in interface RSocketRequesterSupport

addRequesterInterceptor

public void addRequesterInterceptor(io.rsocket.plugins.RSocketInterceptor interceptor)

setApplicationContext

public void setApplicationContext(@NotNull
                                  @NotNull org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

inputStreamToString

public String inputStreamToString(InputStream inputStream)