Class DefaultContextPeer
java.lang.Object
com.tick42.glue.internal.gateway.AbstractPeer
com.tick42.glue.internal.gateway.context.DefaultContextPeer
- All Implemented Interfaces:
ContextPeer
public class DefaultContextPeer extends AbstractPeer implements ContextPeer
-
Constructor Summary
Constructors Constructor Description DefaultContextPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker)DefaultContextPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker, com.tick42.gateway.authentication.GatewayAuthenticationProvider authenticationProvider) -
Method Summary
Modifier and Type Method Description Set<String>names()reactor.core.publisher.Mono<ContextSubscription>reset(String contextName, Map<String,Object> data)reactor.core.publisher.Mono<ContextSubscription>subscribe(String contextName, Map<String,Object> contextData)reactor.core.publisher.Mono<ContextSubscription>update(String contextName, Map<String,Object> defaultValue, Map<String,Object> update)reactor.core.publisher.Mono<ContextSubscription>updatePaths(String contextName, Map<String,Object> defaultValue, Map<String,Object> updatePaths)Methods inherited from class com.tick42.glue.internal.gateway.AbstractPeer
peerId, start, stopMethods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.tick42.glue.internal.gateway.context.ContextPeer
peerId, start, stop
-
Constructor Details
-
DefaultContextPeer
public DefaultContextPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker) -
DefaultContextPeer
public DefaultContextPeer(com.tick42.gateway.connection.GatewayConnection connection, GatewayHandshaker handshaker, com.tick42.gateway.authentication.GatewayAuthenticationProvider authenticationProvider)
-
-
Method Details
-
names
- Specified by:
namesin interfaceContextPeer
-
reset
public reactor.core.publisher.Mono<ContextSubscription> reset(String contextName, Map<String,Object> data)- Specified by:
resetin interfaceContextPeer
-
update
public reactor.core.publisher.Mono<ContextSubscription> update(String contextName, Map<String,Object> defaultValue, Map<String,Object> update)- Specified by:
updatein interfaceContextPeer
-
updatePaths
public reactor.core.publisher.Mono<ContextSubscription> updatePaths(String contextName, Map<String,Object> defaultValue, Map<String,Object> updatePaths)- Specified by:
updatePathsin interfaceContextPeer
-
subscribe
public reactor.core.publisher.Mono<ContextSubscription> subscribe(String contextName, Map<String,Object> contextData)- Specified by:
subscribein interfaceContextPeer
-