- All Known Implementing Classes:
DefaultAgmPeer
public interface AgmPeer
-
-
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.Disposable |
methods(StateSubscriber<MethodKey,com.tick42.gateway.messages.agm.Method> listener) |
|
PeerData |
peerData() |
|
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.Disposable |
servers(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) |
|
-
Method Details
-
-
-
unregister
reactor.core.publisher.Mono<Void> unregister(
String methodId)
-
-
-
-
-
methods
Map<MethodKey,com.tick42.gateway.messages.agm.Method> methods()
-
-
-