@Subscribe
    public synchronized void killLocalProcess(final KillLocalProcessEvent event) throws SQLException {
        if (!event.getInstanceId().equals(contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getId())) {
            return;
        }
        Process process = ProcessRegistry.getInstance().get(event.getProcessId());
        if (null != process) {
            process.setInterrupted(true);
            for (Statement each : process.getProcessStatements().values()) {
                each.cancel();
            }
        }
        contextManager.getPersistServiceFacade().getRepository().delete(ComputeNode.getProcessKillInstanceIdNodePath(event.getInstanceId(), event.getProcessId()));
    }
@Test
    void assertKillLocalProcess() throws SQLException {
        String instanceId = contextManager.getComputeNodeInstanceContext().getInstance().getMetaData().getId();
        String processId = "foo_id";
        subscriber.killLocalProcess(new KillLocalProcessEvent(instanceId, processId));
        verify(repository).delete("/nodes/compute_nodes/kill_process_trigger/" + instanceId + ":foo_id");
    }