워크플로우 사용자 지정 및 확장 시워크플로우 개체에 액세스할 수 있습니다.
워크플로우 Java API는 com.adobe.granite.workflow
패키지와 여러 하위 패키지로 구성됩니다. API의 가장 중요한 멤버는 com.adobe.granite.workflow.WorkflowSession
클래스입니다. WorkflowSession
클래스는 디자인 타임 및 런타임 워크플로우 개체 모두에 액세스할 수 있도록 합니다.
또한 이 클래스는 워크플로우 주기를 위한 몇 가지 방법을 제공합니다.
다음 표는 프로그래밍 방식으로 워크플로우와 상호 작용할 때 사용할 몇 가지 주요 Java 개체의 참조 설명서에 대한 링크를 제공합니다. 다음 예제에서는 코드에서 클래스 개체를 가져오고 사용하는 방법을 보여 줍니다.
기능 | 오브젝트 |
---|---|
워크플로우 액세스 | WorkflowSession |
워크플로우 인스턴스 실행 및 쿼리 | Workflow WorkItem WorkflowData |
워크플로우 모델 관리 | WorkflowModel WorkflowNode WorkflowTransition |
워크플로우에 있는 노드에 대한 정보 | WorkflowStatus |
스크립트에 설명된 대로, AEM(Apache Sling을 통해)에서는 서버측 ECMA 스크립트를 실행하는 ECMA 스크립트 엔진을 제공합니다. 스크립트에서 org.apache.sling.scripting.core.ScriptHelper
클래스를 바로 sling
변수로 사용할 수 있습니다.
ScriptHelper
클래스는 WorkflowSession
개체를 최종적으로 가져오는 데 사용할 수 있는 SlingHttpServletRequest
에 대한 액세스 권한을 제공합니다.예:
var wfsession = sling.getRequest().getResource().getResourceResolver().adaptTo(Packages.com.adobe.granite.workflow.WorkflowSession);
워크플로우 콘솔에서는 REST API를 많이 사용합니다.따라서 이 페이지에서는 워크플로우에 대한 REST API에 대해 설명합니다.
curl 명령줄 도구를 사용하면 Workflow REST API를 사용하여 워크플로우 개체에 액세스하고 인스턴스 주기를 관리할 수 있습니다. 이 페이지 전체의 예에서 curl 명령줄 도구를 통해 REST API를 사용하는 것을 보여줍니다.
다음 작업이 REST API에서 지원됩니다.
웹 개발을 위한 Firefox 확장인 Firebug를 사용하여 콘솔을 작동할 때 HTTP 트래픽을 따를 수 있습니다. 예를 들어 POST
요청을 사용하여 AEM 서버로 전송된 매개 변수와 값을 확인할 수 있습니다.
이 페이지에서는 AEM이 포트 4502
의 localhost에서 실행되며 설치 컨텍스트가 " /
"(루트)라고 가정합니다. 설치가 아닌 경우 HTTP 요청이 적용되는 URI를 적절하게 조정해야 합니다.
GET
요청에 지원되는 렌더링은 JSON 렌더링입니다. GET
의 URL에는 .json
확장자가 있어야 합니다. 예를 들면 다음과 같습니다.
http://localhost:4502/etc/workflow.json
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/etc/workflow/instances
HTTP 요청 메서드 | 작업 |
GET |
사용 가능한 워크플로우 인스턴스를 나열합니다. |
POST |
새 워크플로우 인스턴스를 만듭니다. 매개 변수: |
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/etc/workflow/instances.{state}
HTTP 요청 메서드 | 작업 |
---|---|
GET |
사용 가능한 워크플로우 인스턴스와 해당 상태( RUNNING , SUSPENDED , ABORTED 또는 COMPLETED )를 나열합니다. |
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/etc/workflow/instances/{id}
HTTP 요청 메서드 | 작업 |
GET |
각 워크플로우 모델에 대한 링크를 포함하는 인스턴스 데이터(정의 및 메타데이터)를 가져옵니다. |
POST |
인스턴스의 상태를 변경합니다. 새 상태는 매개 변수 state 로 전송되며 다음 값 중 하나가 있어야 합니다.RUNNING , SUSPENDED 또는 ABORTED .새 상태에 연결할 수 없는 경우(예: 종료된 인스턴스를 일시 중단할 때) 409 (CONFLICT ) 응답이 클라이언트로 다시 전송됩니다. |
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/etc/workflow/models
HTTP 요청 메서드 | 작업 |
GET |
사용 가능한 워크플로우 모델을 나열합니다. |
POST |
새 워크플로우 모델 만들기. 매개 변수 title 이 전송되면 지정된 제목과 함께 새 모델이 만들어집니다. JSON 모델 정의를 매개 변수 model 로 첨부하면 제공된 정의에 따라 새 워크플로우 모델이 만들어집니다.새 201 워크플로우 모델 리소스의 URL을 포함하는 위치 헤더와 함께 응답(CREATED )이 다시 전송됩니다.모델 정의가 라는 파일 매개 변수로 첨부된 경우에도 modelfile 마찬가지입니다.이 두 경우 모두 model 와 modelfile 매개 변수의 경우 serialization 형식을 정의하려면 라는 추가 매개 변수 type 가 필요합니다. OSGI API를 사용하여 새로운 직렬화 형식을 통합할 수 있습니다. 워크플로우 엔진과 함께 표준 JSON 직렬 변환기가 제공됩니다. 해당 유형은 JSON입니다. 형식에 대한 예는 아래를 참조하십시오. |
예:브라우저에서 http://localhost:4502/etc/workflow/models.json
에 대한 요청은 다음과 유사한 json 응답을 생성합니다.
[
{"uri":"/var/workflow/models/activationmodel"}
,{"uri":"/var/workflow/models/dam/adddamsize"}
,{"uri":"/var/workflow/models/cloudconfigs/dtm-reactor/library-download"}
,{"uri":"/var/workflow/models/ac-newsletter-workflow-simple"}
,{"uri":"/var/workflow/models/dam/dam-create-language-copy"}
,{"uri":"/var/workflow/models/dam/dam-create-and-translate-language-copy"}
,{"uri":"/var/workflow/models/dam-indesign-proxy"}
,{"uri":"/var/workflow/models/dam-xmp-writeback"}
,{"uri":"/var/workflow/models/dam-parse-word-documents"}
,{"uri":"/var/workflow/models/dam/process_subasset"}
,{"uri":"/var/workflow/models/dam/dam_set_last_modified"}
,{"uri":"/var/workflow/models/dam/dam-autotag-assets"}
,{"uri":"/var/workflow/models/dam/update_asset"}
,{"uri":"/var/workflow/models/dam/update_asset_offloading"}
,{"uri":"/var/workflow/models/dam/dam-update-language-copy"}
,{"uri":"/var/workflow/models/dam/update_from_lightbox"}
,{"uri":"/var/workflow/models/cloudservices/DTM_bundle_download"}
,{"uri":"/var/workflow/models/dam/dam_download_asset"}
,{"uri":"/var/workflow/models/dam/dynamic-media-encode-video"}
,{"uri":"/var/workflow/models/dam/dynamic-media-video-thumbnail-replacement"}
,{"uri":"/var/workflow/models/dam/dynamic-media-video-user-uploaded-thumbnail"}
,{"uri":"/var/workflow/models/newsletter_bounce_check"}
,{"uri":"/var/workflow/models/projects/photo_shoot_submission"}
,{"uri":"/var/workflow/models/projects/product_photo_shoot"}
,{"uri":"/var/workflow/models/projects/approval_workflow"}
,{"uri":"/var/workflow/models/prototype-01"}
,{"uri":"/var/workflow/models/publish_example"}
,{"uri":"/var/workflow/models/publish_to_campaign"}
,{"uri":"/var/workflow/models/screens/publish_to_author_bin"}
,{"uri":"/var/workflow/models/s7dam/request_to_publish_to_youtube"}
,{"uri":"/var/workflow/models/projects/request_copy"}
,{"uri":"/var/workflow/models/projects/request_email"}
,{"uri":"/var/workflow/models/projects/request_landing_page"}
,{"uri":"/var/workflow/models/projects/request_launch"}
,{"uri":"/var/workflow/models/request_for_activation"}
,{"uri":"/var/workflow/models/request_for_deactivation"}
,{"uri":"/var/workflow/models/request_for_deletion"}
,{"uri":"/var/workflow/models/request_for_deletion_without_deactivation"}
,{"uri":"/var/workflow/models/request_to_complete_move_operation"}
,{"uri":"/var/workflow/models/reverse_replication"}
,{"uri":"/var/workflow/models/salesforce-com-export"}
,{"uri":"/var/workflow/models/scene7"}
,{"uri":"/var/workflow/models/scheduled_activation"}
,{"uri":"/var/workflow/models/scheduled_deactivation"}
,{"uri":"/var/workflow/models/screens/screens-update-asset"}
,{"uri":"/var/workflow/models/translation"}
,{"uri":"/var/workflow/models/s7dam/request_to_remove_from_youtube"}
,{"uri":"/var/workflow/models/wcm-translation/create_language_copy"}
,{"uri":"/var/workflow/models/wcm-translation/prepare_translation_project"}
,{"uri":"/var/workflow/models/wcm-translation/translate-i18n-dictionary"}
,{"uri":"/var/workflow/models/wcm-translation/sync_translation_job"}
,{"uri":"/var/workflow/models/wcm-translation/translate-language-copy"}
,{"uri":"/var/workflow/models/wcm-translation/update_language_copy"}
]
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502*{uri}*
여기서 *{uri}*
은 저장소의 모델 노드의 경로입니다.
HTTP 요청 메서드 | 작업 |
GET |
모델의 HEAD 버전(정의 및 메타데이터)을 가져옵니다. |
PUT |
모델의 HEAD 버전을 업데이트합니다(새 버전을 만듭니다).모델의 새 버전에 대한 전체 모델 정의를 라는 매개변수로 추가해야 합니다 model . 또한 새 모델을 만들 때에는 type 매개 변수가 필요하며 JSON .값을 지정해야 합니다 |
POST |
PUT과 동일한 동작입니다. AEM 위젯이 PUT 작업을 지원하지 않으므로 필요합니다. |
DELETE |
모델을 삭제합니다. 방화벽/프록시 문제를 해결하기 위해 값이 DELETE 인 X-HTTP-Method-Override 헤더 항목이 포함된 POST 도 DELETE 요청으로 수락됩니다. |
예:브라우저에서 http://localhost:4502/var/workflow/models/publish_example.json
에 대한 요청은 다음 코드와 유사한 json
응답을 반환합니다.
{
"id":"/var/workflow/models/publish_example",
"title":"Publish Example",
"version":"1.0",
"description":"This example shows a simple review and publish process.",
"metaData":
{
"multiResourceSupport":"true",
"tags":"wcm,publish"
},
"nodes":
[{
"id":"node0",
"type":"START",
"title":"Start",
"description":"The start node of the workflow.",
"metaData":
{
}
},
{
"id":"node1",
"type":"PARTICIPANT",
"title":"Validate Content",
"description":"Validate the modified content.",
"metaData":
{
"PARTICIPANT":"admin"
}
},
{
"id":"node2",
"type":"PROCESS",
"title":"Publish Content",
"description":"Publish the modified content.",
"metaData":
{
"PROCESS_AUTO_ADVANCE":"true",
"PROCESS":"com.day.cq.wcm.workflow.process.ActivatePageProcess"
}
},
{
"id":"node3",
"type":"END",
"title":"End",
"description":"The end node of the workflow.",
"metaData":
{
}
}],
"transitions":
[{
"from":"node0",
"to":"node1",
"metaData":
{
}
},
{
"from":"node1",
"to":"node2",
"metaData":
{
}
},
{
"from":"node2",
"to":"node3",
"metaData":
{
}
}
]}
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/etc/workflow/models/{id}.{version}
HTTP 요청 메서드 | 작업 |
---|---|
GET |
지정된 버전에서 모델의 데이터를 가져옵니다(있는 경우). |
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/bin/workflow/inbox
HTTP 요청 메서드 | 작업 |
GET |
HTTP 인증 헤더로 식별되는 사용자의 받은 편지함에 있는 작업 항목을 나열합니다. |
POST |
URI가 매개 변수 item (으)로 전송되는 작업 항목을 완료하고, 한 단계 뒤로 이동할 경우 매개 변수 route 또는 backroute 에 의해 정의된 다음 노드로 해당 워크플로우 인스턴스를 진행합니다.매개변수 delegatee 가 전송되면 매개변수로 식별된 작업 항목 item 이 지정된 참여자에게 위임됩니다. |
다음 HTTP 요청 메서드는 다음에 적용됩니다.
http://localhost:4502/bin/workflow/inbox/{id}
HTTP 요청 메서드 | 작업 |
---|---|
GET |
받은 편지함 WorkItem 의 데이터(정의 및 메타데이터)를 해당 ID로 식별합니다. |
실행 중인 모든 워크플로우의 목록을 가져오려면 GET을 수행하십시오.
http://localhost:4502/etc/workflow/instances.RUNNING.json
curl 사용 예:
curl -u admin:admin http://localhost:4502/etc/workflow/instances.RUNNING.json
결과에 표시된 uri
은 다른 명령에서 id
인스턴스로 사용할 수 있습니다.예:
[
{"uri":"/etc/workflow/instances/server0/2017-03-08/request_for_activation_1"}
]
이 curl
명령은 RUNNING
대신 워크플로우 상태와 함께 사용할 수 있습니다.
워크플로우 콘솔의 인스턴스 탭에 표시되는 워크플로우 제목을 변경하려면 POST
명령을 보냅니다.
끝: http://localhost:4502/etc/workflow/instances/{id}
다음 매개 변수와 함께 사용할 수 있습니다.
action
:값은 다음과 같습니다. UPDATE
workflowTitle
:워크플로우 제목curl 사용 예:
curl -u admin:admin -d "action=UPDATE&workflowTitle=myWorkflowTitle" http://localhost:4502/etc/workflow/instances/{id}
# for example
curl -u admin:admin -d "action=UPDATE&workflowTitle=myWorkflowTitle" http://localhost:4502/etc/workflow/instances/server0/2017-03-08/request_for_activation_1
사용 가능한 모든 워크플로우 모델 목록을 보려면 다음 작업을 수행하십시오.
http://localhost:4502/etc/workflow/models.json
curl 사용 예:
curl -u admin:admin http://localhost:4502/etc/workflow/models.json
또한 워크플로우 모델 관리를 참조하십시오.
com.adobe.granite.workflow.WorkflowSession
클래스는 javax.jcr.Session
개체 또는 org.apache.sling.api.resource.ResourceResolver
개체에서 적응할 수 있습니다.
JSP 스크립트(또는 서블릿 클래스의 Java 코드)에서 HTTP 요청 개체를 사용하여 ResourceResolver
객체에 대한 액세스를 제공하는 SlingHttpServletRequest
개체를 가져옵니다. ResourceResolver
개체를 WorkflowSession
에 조정합니다.
<%
%><%@include file="/libs/foundation/global.jsp"%><%
%><%@page session="false"
import="com.adobe.granite.workflow.WorkflowSession,
org.apache.sling.api.SlingHttpServletRequest"%><%
SlingHttpServletRequest slingReq = (SlingHttpServletRequest)request;
WorkflowSession wfSession = slingReq.getResourceResolver().adaptTo(WorkflowSession.class);
%>
sling
변수를 사용하여 ResourceResolver
개체를 가져오는 데 사용하는 SlingHttpServletRequest
개체를 가져옵니다. ResourceResolver
개체를 WorkflowSession
개체에 조정합니다.
var wfsession = sling.getRequest().getResource().getResourceResolver().adaptTo(Packages.com.adobe.granite.workflow.WorkflowSession);
다음 예는 워크플로우 모델에 액세스하는 방법을 보여줍니다.
WorkflowSession.createNewModel
메서드를 사용합니다.사용된 예:
/var/workflow/models/mymodel/jcr:content/model
사용).모델을 삭제하면 모델의 metaData
하위 노드의 deleted
속성이 true
로 설정됩니다.
삭제해도 모델 노드가 제거되지 않습니다.
새 모델을 생성할 때:
워크플로우 모델 편집기를 사용하려면 모델이 /var/workflow/models
아래의 특정 노드 구조를 사용해야 합니다. 모델의 상위 노드는 jcr:content
노드가 다음 속성 값을 갖는 cq:Page
유형이어야 합니다.
sling:resourceType
: cq/workflow/components/pages/model
cq:template
: /libs/cq/workflow/templates/model
모델을 생성할 때 먼저 이 cq:Page
노드를 만들고 해당 jcr:content
노드를 모델 노드의 상위로 사용해야 합니다.
모델을 식별하는 데 필요한 일부 메서드가 저장소의 모델 노드의 절대 경로입니다.id
/var/workflow/models/<*model_name>*/jcr:content/model
모든 워크플로우 모델을 나열하는 방법🔗을 참조하십시오.
<%@include file="/libs/foundation/global.jsp"%><%
%><%@page session="false" import="com.adobe.granite.workflow.WorkflowSession,
com.adobe.granite.workflow.model.WorkflowModel,
org.apache.sling.api.SlingHttpServletRequest"%><%
SlingHttpServletRequest slingReq = (SlingHttpServletRequest)request;
WorkflowSession wfSession = slingReq.getResourceResolver().adaptTo(WorkflowSession.class);
/* Create the parent page */
String modelRepo = new String("/var/workflow/models");
String modelTemplate = new String ("/libs/cq/workflow/templates/model");
String modelName = new String("mymodel");
Page modelParent = pageManager.create(modelRepo, modelName, modelTemplate, "My workflow model");
/* create the model */
String modelId = new String(modelParent.getPath()+"/jcr:content/model")
WorkflowModel model = wfSession.createNewModel("Made using Java",modelId);
/* delete the model */
wfSession.deleteModel(modelId);
%>
var resolver = sling.getRequest().getResource().getResourceResolver();
var wfSession = resolver.adaptTo(Packages.com.adobe.granite.workflow.WorkflowSession);
var pageManager = resolver.adaptTo(Packages.com.day.cq.wcm.api.PageManager);
//create the parent page node
var workflowPage = pageManager.create("/var/workflow/models", "mymodel", "/libs/cq/workflow/templates/model", "Created via ECMA Script");
var modelId = workflowPage.getPath()+ "/jcr:content/model";
//create the model
var model = wfSession.createNewModel("My Model", modelId);
//delete the model
var model = wfSession.deleteModel(modelId);
# deleting the model by its id
curl -u admin:admin -X DELETE http://localhost:4502/etc/workflow/models/{id}
필요한 세부 수준 때문에 curl은 모델을 만들거나 읽는 데 실용적이지 않은 것으로 간주됩니다.
WorkflowStatus API를 사용하여 노드의 워크플로우 상태에 대한 정보를 검색할 수 있습니다.
다양한 방법에는 다음과 같은 매개 변수가 있습니다.
excludeSystemWorkflows
이 매개 변수를 true
(으)로 설정하여 시스템 워크플로우를 관련 결과에서 제외해야 함을 나타낼 수 있습니다.
은(는) 시스템 워크플로우로 간주되는 워크플로우 Models
를 지정하는 OSGi 구성 Granite Workflow PayloadMapCache Adobe을 업데이트할 수 있습니다. 기본(런타임) 워크플로우 모델은 다음과 같습니다.
/var/workflow/models/scheduled_activation/jcr:content/model
/var/workflow/models/scheduled_deactivation/jcr:content/model
사전 정의된 시간 내에 완료되지 않은 참가자 단계를 자동으로 진행해야 하는 경우 다음을 수행할 수 있습니다.
OSGI 이벤트 리스너를 구현하여 작업 생성 및 수정 사항을 수신합니다.
시간 제한(기한)을 지정한 다음 해당 시간에 실행할 예약된 슬링 작업을 만듭니다.
시간 제한이 만료되고 작업이 트리거될 때 알림을 받는 작업 처리기를 작성합니다.
작업이 아직 완료되지 않은 경우 이 처리기는 작업에 필요한 작업을 수행합니다
이 접근 방식을 사용할 수 있도록 수행할 작업을 명확히 정의해야 합니다.
다음은 워크플로우 인스턴스와 상호 작용(프로그래밍 방식으로)하는 방법에 대한 기본 예를 제공합니다.
// starting a workflow
WorkflowModel model = wfSession.getModel(workflowId);
WorkflowData wfData = wfSession.newWorkflowData("JCR_PATH", repoPath);
wfSession.startWorkflow(model, wfData);
// querying and managing a workflow
Workflow[] workflows workflows = wfSession.getAllWorkflows();
Workflow workflow= wfSession.getWorkflow(id);
wfSession.suspendWorkflow(workflow);
wfSession.resumeWorkflow(workflow);
wfSession.terminateWorkflow(workflow);
// starting a workflow
var model = wfSession.getModel(workflowId);
var wfData = wfSession.newWorkflowData("JCR_PATH", repoPath);
wfSession.startWorkflow(model, wfData);
// querying and managing a workflow
var workflows = wfSession.getWorkflows(“RUNNING“);
var workflow= wfSession.getWorkflow(id);
wfSession.suspendWorkflow(workflow);
wfSession.resumeWorkflow(workflow);
wfSession.terminateWorkflow(workflow);
워크플로우 시작
# starting a workflow
curl -d "model={id}&payloadType={type}&payload={payload}" http://localhost:4502/etc/workflow/instances
# for example:
curl -u admin:admin -d "model=/var/workflow/models/request_for_activation&payloadType=JCR_PATH&payload=/content/we-retail/us/en/products" http://localhost:4502/etc/workflow/instances
인스턴스 나열
# listing the instances
curl -u admin:admin http://localhost:4502/etc/workflow/instances.json
그러면 모든 인스턴스가 나열됩니다.예:
[
{"uri":"/var/workflow/instances/server0/2018-02-26/prototype-01_1"}
,{"uri":"/var/workflow/instances/server0/2018-02-26/prototype-01_2"}
]
특정 상태의 인스턴스를 나열하려면 실행 중인 모든 워크플로우 목록을 해당 ID로 가져오는 방법을 참조하십시오.
워크플로우 일시 중단
# suspending a workflow
curl -d "state=SUSPENDED" http://localhost:4502/etc/workflow/instances/{id}
# for example:
curl -u admin:admin -d "state=SUSPENDED" http://localhost:4502/etc/workflow/instances/server0/2017-03-08/request_for_activation_1
워크플로우 다시 시작
# resuming a workflow
curl -d "state=RUNNING" http://localhost:4502/etc/workflow/instances/{id}
# for example:
curl -u admin:admin -d "state=RUNNING" http://localhost:4502/etc/workflow/instances/server0/2017-03-08/request_for_activation_1
워크플로우 인스턴스 종료
# terminating a workflow
curl -d "state=ABORTED" http://localhost:4502/etc/workflow/instances/{id}
# for example:
curl -u admin:admin -d "state=ABORTED" http://localhost:4502/etc/workflow/instances/server0/2017-03-08/request_for_activation_1
다음은 작업 항목과 상호 작용(프로그래밍)하는 방법에 대한 기본 예를 제공합니다.
// querying work items
WorkItem[] workItems = wfSession.getActiveWorkItems();
WorkItem workItem = wfSession.getWorkItem(id);
// getting routes
List<Route> routes = wfSession.getRoutes(workItem);
// delegating
Iterator<Participant> delegatees = wfSession.getDelegatees(workItem);
wfSession.delegateWorkItem(workItem, delegatees.get(0));
// completing or advancing to the next step
wfSession.complete(workItem, routes.get(0));
// querying work items
var workItems = wfSession.getActiveWorkItems();
var workItem = wfSession.getWorkItem(id);
// getting routes
var routes = wfSession.getRoutes(workItem);
// delegating
var delegatees = wfSession.getDelegatees(workItem);
wfSession.delegateWorkItem(workItem, delegatees.get(0));
// completing or advancing to the next step
wfSession.complete(workItem, routes.get(0));
받은 편지함에서 작업 항목 나열
# listing the work items
curl -u admin:admin http://localhost:4502/bin/workflow/inbox
현재 받은 편지함에 있는 작업 항목에 대한 세부 사항이 나열됩니다.예:
[{
"uri_xss": "/var/workflow/instances/server0/2018-02-26/prototype-01_2/workItems/node2_var_workflow_instances_server0_2018-02-26_prototype-01_2",
"uri": "/var/workflow/instances/server0/2018-02-26/prototype-01_2/workItems/node2_var_workflow_instances_server0_2018-02-26_prototype-01_2",
"currentAssignee_xss": "workflow-administrators",
"currentAssignee": "workflow-administrators",
"startTime": 1519656289274,
"payloadType_xss": "JCR_PATH",
"payloadType": "JCR_PATH",
"payload_xss": "/content/we-retail/es/es",
"payload": "/content/we-retail/es/es",
"comment_xss": "Process resource is null",
"comment": "Process resource is null",
"type_xss": "WorkItem",
"type": "WorkItem"
},{
"uri_xss": "configuration/configure_analyticstargeting",
"uri": "configuration/configure_analyticstargeting",
"currentAssignee_xss": "administrators",
"currentAssignee": "administrators",
"type_xss": "Task",
"type": "Task"
},{
"uri_xss": "configuration/securitychecklist",
"uri": "configuration/securitychecklist",
"currentAssignee_xss": "administrators",
"currentAssignee": "administrators",
"type_xss": "Task",
"type": "Task"
},{
"uri_xss": "configuration/enable_collectionofanonymoususagedata",
"uri": "configuration/enable_collectionofanonymoususagedata",
"currentAssignee_xss": "administrators",
"currentAssignee": "administrators",
"type_xss": "Task",
"type": "Task"
},{
"uri_xss": "configuration/configuressl",
"uri": "configuration/configuressl",
"currentAssignee_xss": "administrators",
"currentAssignee": "administrators",
"type_xss": "Task",
"type": "Task"
}
작업 항목 위임
# delegating
curl -d "item={item}&delegatee={delegatee}" http://localhost:4502/bin/workflow/inbox
# for example:
curl -u admin:admin -d "item=/etc/workflow/instances/server0/2017-03-08/request_for_activation_1/workItems/node1_etc_workflow_instances_server0_2017-03-08_request_for_act_1&delegatee=administrators" http://localhost:4502/bin/workflow/inbox
delegatee
은(는) 워크플로우 단계에 유효한 옵션이어야 합니다.
다음 단계로 작업 항목 완료 또는 진행
# retrieve the list of routes; the results will be similar to {"results":1,"routes":[{"rid":"233123169","label":"End","label_xss":"End"}]}
http://localhost:4502/etc/workflow/instances/<path-to-the-workitem>.routes.json
# completing or advancing to the next step; use the appropriate route ID (rid value) from the above list
curl -d "item={item}&route={route}" http://localhost:4502/bin/workflow/inbox
# for example:
curl -u admin:admin -d "item=/etc/workflow/instances/server0/2017-03-08/request_for_activation_1/workItems/node1_etc_workflow_instances_server0_2017-03-08_request_for_activation_1&route=233123169" http://localhost:4502/bin/workflow/inbox
OSGi 이벤트 프레임워크를 사용하여 com.adobe.granite.workflow.event.WorkflowEvent
클래스가 정의한 이벤트를 수신합니다. 또한 이 클래스는 이벤트의 주제에 대한 정보를 얻는 데 유용한 몇 가지 방법을 제공합니다. 예를 들어 getWorkItem
메서드는 이벤트에 포함된 작업 항목에 대한 WorkItem
개체를 반환합니다.
다음 예제 코드는 워크플로우 이벤트를 수신하고 이벤트 유형에 따라 작업을 수행하는 서비스를 정의합니다.
package com.adobe.example.workflow.listeners;
import org.apache.sling.event.jobs.JobProcessor;
import org.apache.sling.event.jobs.JobUtil;
import org.osgi.service.event.Event;
import org.osgi.service.event.EventHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Property;
import org.apache.felix.scr.annotations.Service;
import com.adobe.granite.workflow.event.WorkflowEvent;
import com.adobe.granite.workflow.exec.WorkItem;
/**
* The <code>WorkflowEventCatcher</code> class listens to workflow events.
*/
@Component(metatype=false, immediate=true)
@Service(value=org.osgi.service.event.EventHandler.class)
public class WorkflowEventCatcher implements EventHandler, JobProcessor {
@Property(value=com.adobe.granite.workflow.event.WorkflowEvent.EVENT_TOPIC)
static final String EVENT_TOPICS = "event.topics";
private static final Logger logger = LoggerFactory.getLogger(WorkflowEventCatcher.class);
public void handleEvent(Event event) {
JobUtil.processJob(event, this);
}
public boolean process(Event event) {
logger.info("Received event of topic: " + event.getTopic());
String topic = event.getTopic();
try {
if (topic.equals(WorkflowEvent.EVENT_TOPIC)) {
WorkflowEvent wfevent = (WorkflowEvent)event;
String eventType = wfevent.getEventType();
String instanceId = wfevent.getWorkflowInstanceId();
if (instanceId != null) {
//workflow instance events
if (eventType.equals(WorkflowEvent.WORKFLOW_STARTED_EVENT) ||
eventType.equals(WorkflowEvent.WORKFLOW_RESUMED_EVENT) ||
eventType.equals(WorkflowEvent.WORKFLOW_SUSPENDED_EVENT)) {
// your code comes here...
} else if (
eventType.equals(WorkflowEvent.WORKFLOW_ABORTED_EVENT) ||
eventType.equals(WorkflowEvent.WORKFLOW_COMPLETED_EVENT)) {
// your code comes here...
}
// workflow node event
if (eventType.equals(WorkflowEvent.NODE_TRANSITION_EVENT)) {
WorkItem currentItem = (WorkItem) event.getProperty(WorkflowEvent.WORK_ITEM);
// your code comes here...
}
}
}
} catch(Exception e){
logger.debug(e.getMessage());
e.printStackTrace();
}
return true;
}
}