Class DefaultAgmPeer
java.lang.Object
com.tick42.glue.internal.gateway.AbstractPeer
com.tick42.glue.internal.gateway.agm.DefaultAgmPeer
- All Implemented Interfaces:
AgmPeer
public class DefaultAgmPeer extends AbstractPeer implements AgmPeer
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.tick42.glue.internal.gateway.agm.AgmPeer
AgmPeer.InvalidPeerException, AgmPeer.MethodHandler, AgmPeer.StreamFlux<T>, AgmPeer.StreamHandler -
Field Summary
-
Constructor Summary
Constructors Constructor Description DefaultAgmPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker)DefaultAgmPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker, com.tick42.gateway.authentication.GatewayAuthenticationProvider authenticationProvider) -
Method Summary
Modifier and Type Method Description reactor.core.publisher.Mono<Map<String,Object>>call(String serverId, String methodId, Map<String,Object> arg)reactor.core.publisher.Mono<Void>fire(String serverId, String methodId, Map<String,Object> arg)Map<MethodKey,com.tick42.gateway.messages.agm.Method>methods()reactor.core.Disposablemethods(StateSubscriber<MethodKey,com.tick42.gateway.messages.agm.Method> listener)PeerDatapeerData()reactor.core.publisher.Mono<String>peerId()reactor.core.publisher.Mono<MethodKey>register(com.tick42.gateway.messages.agm.Method method, AgmPeer.MethodHandler handler)reactor.core.publisher.Mono<MethodKey>register(com.tick42.gateway.messages.agm.Method method, AgmPeer.StreamHandler handler)Map<String,PeerData>servers()reactor.core.Disposableservers(StateSubscriber<String,PeerData> listener)reactor.core.publisher.Mono<AgmPeer.StreamFlux<reactor.util.function.Tuple2<Boolean,Map<String,Object>>>>subscribe(String serverId, String methodId, Map<String,Object> arg)reactor.core.publisher.Mono<Void>unregister(String methodId)Methods inherited from class com.tick42.glue.internal.gateway.AbstractPeer
start, stop
-
Field Details
-
META
-
-
Constructor Details
-
DefaultAgmPeer
public DefaultAgmPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker, com.tick42.gateway.authentication.GatewayAuthenticationProvider authenticationProvider) -
DefaultAgmPeer
public DefaultAgmPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker)
-
-
Method Details
-
peerData
-
peerId
- Overrides:
peerIdin classAbstractPeer
-
register
public reactor.core.publisher.Mono<MethodKey> register(com.tick42.gateway.messages.agm.Method method, AgmPeer.MethodHandler handler) -
methods
-
methods
public reactor.core.Disposable methods(StateSubscriber<MethodKey,com.tick42.gateway.messages.agm.Method> listener) -
servers
-
servers
-
register
public reactor.core.publisher.Mono<MethodKey> register(com.tick42.gateway.messages.agm.Method method, AgmPeer.StreamHandler handler) -
unregister
- Specified by:
unregisterin interfaceAgmPeer
-
call
-
fire
-
subscribe
-