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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addRequesterInterceptor(io.rsocket.plugins.RSocketInterceptor interceptor)
void	addResponderInterceptor(io.rsocket.plugins.RSocketInterceptor interceptor)
Supplier<Set<ServiceLocator>>	exposedServices()
URI	originUri()
List<io.rsocket.plugins.RSocketInterceptor>	requestInterceptors()
List<io.rsocket.plugins.RSocketInterceptor>	responderInterceptors()
Supplier<io.cloudevents.v1.CloudEventImpl<ServicesExposedEvent>>	servicesExposedEvent()
void	setApplicationContext(@NotNull org.springframework.context.ApplicationContext applicationContext)
Supplier<io.rsocket.Payload>	setupPayload()
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

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()

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<io.cloudevents.v1.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