Skip to content

ARTEMIS-6165 start/stop button on lock coordinators #217

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
clebertsuconic wants to merge 1 commit into
base: main
Choose a base branch
from
Open

ARTEMIS-6165 start/stop button on lock coordinators #217

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 10 additions & 0 deletions ...onsole-extension/artemis-extension/packages/artemis-console-plugin/src/artemis-service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
}
Expand Down
28 changes: 27 additions & 1 deletion ...console-extension/artemis-extension/packages/artemis-console-plugin/src/status/Status.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -297,15 +297,41 @@ export const Status: React.FunctionComponent = () => {
<Th>Name</Th>
<Th>ID</Th>
<Th>Status</Th>
<Th></Th>
</Tr>
</Thead>
<Tbody>
{
lockCoordinators?.lockCoordinators.map((coordinator, index) => {
return <Tr>
return <Tr key={index}>
<Td>{coordinator.name}</Td>
<Td>{coordinator.lockId}</Td>
<Td>{coordinator.status}</Td>
<Td>
{coordinator.status === 'Stopped' ? (
<Button variant="primary" size="sm" onClick={() => {
artemisService.startLockCoordinator(coordinator.name)
.then(() => {
eventService.notify({ type: 'success', message: 'Lock Coordinator ' + coordinator.name + ' started', duration: 3000 });
getLockCoordinators();
})
.catch((error) => {
eventService.notify({ type: 'danger', message: 'Failed to start Lock Coordinator: ' + jolokiaService.errorMessage(error) });
});
}}>Start</Button>
) : (
<Button variant="secondary" size="sm" onClick={() => {
artemisService.stopLockCoordinator(coordinator.name)
.then(() => {
eventService.notify({ type: 'success', message: 'Lock Coordinator ' + coordinator.name + ' stopped', duration: 3000 });
getLockCoordinators();
})
.catch((error) => {
eventService.notify({ type: 'danger', message: 'Failed to stop Lock Coordinator: ' + jolokiaService.errorMessage(error) });
});
}}>Stop</Button>
)}
</Td>
</Tr>
})
}
Expand Down
Loading