Package org.frankframework.console.controllers

Class ClusterMembers

java.lang.Object

org.frankframework.console.controllers.ClusterMembers

All Implemented Interfaces:

EventListener, org.springframework.context.ApplicationListener<ClusterMemberEvent>

@RestController
@Scope(proxyMode=TARGET_CLASS)
public class ClusterMembers
extends Object
implements org.springframework.context.ApplicationListener<ClusterMemberEvent>

Cluster in this sense does not directly mean a Kubernetes or similar cluster, but a Hazelcast cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ClusterMembers.ClusterMemberTargetModel
static final record	ClusterMembers.GetClusterMembersParams

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.springframework.messaging.simp.SimpMessagingTemplate	messagingTemplate

Constructor Summary

Constructors

Constructor	Description
ClusterMembers(ClientSession session, OutboundGateway outboundGateway, org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate)

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<?>	getClusterMembers(ClusterMembers.GetClusterMembersParams params)
void	onApplicationEvent(ClusterMemberEvent event)
org.springframework.http.ResponseEntity<?>	setClusterMemberTarget(ClusterMembers.ClusterMemberTargetModel model)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.ApplicationListener

supportsAsyncExecution

Field Details

messagingTemplate

protected final org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate

Constructor Details

ClusterMembers

public ClusterMembers(ClientSession session,
 OutboundGateway outboundGateway,
 org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate)

Method Details

getClusterMembers

@RolesAllowed({"IbisObserver","IbisDataAdmin","IbisAdmin","IbisTester"})
@GetMapping(value="/cluster/members",
            produces="application/json")
public org.springframework.http.ResponseEntity<?> getClusterMembers(ClusterMembers.GetClusterMembersParams params)

setClusterMemberTarget

@RolesAllowed({"IbisObserver","IbisDataAdmin","IbisAdmin","IbisTester"})
@PostMapping(value="/cluster/members",
             produces="application/json",
             consumes="application/json")
public org.springframework.http.ResponseEntity<?> setClusterMemberTarget(@RequestBody
 ClusterMembers.ClusterMemberTargetModel model)

onApplicationEvent

public void onApplicationEvent(ClusterMemberEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<ClusterMemberEvent>