@Override
    public ListenerResult listen(WorkflowContext context) throws Exception {
        log.info("operate stream source for groupId={}", context.getProcessForm().getInlongGroupId());
        InlongGroupInfo groupInfo = getGroupInfo(context.getProcessForm());
        final String groupId = groupInfo.getInlongGroupId();
        List<InlongStreamBriefInfo> streamResponses = streamService.listBriefWithSink(groupId);
        streamResponses
                .forEach(stream -> operateStreamSources(groupId, stream.getInlongStreamId(), context.getOperator()));
        return ListenerResult.success();
    }
Event listener of operate resources, such as delete, stop, restart sources.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/source/AbstractSourceOperateListener.java