@Override
    public ListenerResult listen(WorkflowContext context) throws Exception {
        StreamResourceProcessForm form = (StreamResourceProcessForm) context.getProcessForm();
        final InlongStreamInfo streamInfo = form.getStreamInfo();
        final String operator = context.getOperator();
        final GroupOperateType operateType = form.getGroupOperateType();
        final String groupId = streamInfo.getInlongGroupId();
        final String streamId = streamInfo.getInlongStreamId();
        StreamStatus status;
        switch (operateType) {
            case RESTART:
                status = StreamStatus.CONFIG_SUCCESSFUL;
                break;
            case SUSPEND:
                status = StreamStatus.CONFIG_OFFLINE_SUCCESSFUL;
                break;
            case DELETE:
                status = StreamStatus.DELETED;
                break;
            default:
                throw new RuntimeException(String.format("Unsupported operate=%s for inlong group", operateType));
        }
        streamService.updateStatus(groupId, streamId, status.getCode(), operator);
        streamService.update(streamInfo.genRequest(), operator);
        return ListenerResult.success();
    }
The listener of InlongStream when update operates successfully.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/stream/UpdateStreamCompleteListener.java