diff --git a/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/artemis-service.ts b/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/artemis-service.ts index 5d1b3dc..8a3e99f 100644 --- a/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/artemis-service.ts +++ b/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/artemis-service.ts @@ -180,6 +180,8 @@ const CLOSE_CONNECTION_SIG = "closeConnectionWithID(java.lang.String)"; const CLOSE_SESSION_SIG = "closeSessionWithID(java.lang.String,java.lang.String)"; const CLOSE_CONSUMER_SIG = "closeConsumerWithID(java.lang.String,java.lang.String)"; const LIST_LOCK_MANAGER_SIG = "listLockCoordinatorsAsJSON()"; +const START_LOCK_COORDINATOR_SIG = "startLockCoordinator(java.lang.String)"; +const STOP_LOCK_COORDINATOR_SIG = "stopLockCoordinator(java.lang.String)"; const MS_PER_SEC = 1000; const MS_PER_MIN = 60 * MS_PER_SEC; @@ -654,6 +656,14 @@ class ArtemisService { return jolokiaService.execute(await this.getBrokerObjectName(), CLOSE_CONSUMER_SIG, [session, name]); } + async startLockCoordinator(name: string) { + return jolokiaService.execute(await this.getBrokerObjectName(), START_LOCK_COORDINATOR_SIG, [name]); + } + + async stopLockCoordinator(name: string) { + return jolokiaService.execute(await this.getBrokerObjectName(), STOP_LOCK_COORDINATOR_SIG, [name]); + } + async getBrokerObjectName() { return await this.brokerObjectName; } diff --git a/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/status/Status.tsx b/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/status/Status.tsx index b8e2ec7..664d5d0 100644 --- a/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/status/Status.tsx +++ b/artemis-console-extension/artemis-extension/packages/artemis-console-plugin/src/status/Status.tsx @@ -297,15 +297,41 @@ export const Status: React.FunctionComponent = () => { Name ID Status + { lockCoordinators?.lockCoordinators.map((coordinator, index) => { - return + return {coordinator.name} {coordinator.lockId} {coordinator.status} + + {coordinator.status === 'Stopped' ? ( + + ) : ( + + )} + }) }