Wanneer uw workflows aanpassen en uitbreiden kunt u tot werkschemavoorwerpen toegang hebben:
De workflow-Java API bestaat uit het com.adobe.granite.workflow
-pakket en verschillende subpakketten. Het belangrijkste lid van de API is de klasse com.adobe.granite.workflow.WorkflowSession
. De klasse WorkflowSession
biedt toegang tot zowel ontwerp-tijd- als runtime-workflowobjecten:
De klasse biedt ook verschillende methoden voor het ingrijpen in workflowlevenscycli.
De volgende tabel bevat koppelingen naar de referentiedocumentatie van verschillende belangrijke Java-objecten die moeten worden gebruikt wanneer programmatisch wordt gewerkt met workflows. De volgende voorbeelden demonstreren hoe u de klassenobjecten in code verkrijgt en gebruikt.
Functies | Objecten |
---|---|
Een workflow openen | WorkflowSession |
Een workflowinstantie uitvoeren en opvragen | Workflow WorkItem WorkflowData |
Een workflowmodel beheren | WorkflowModel WorkflowNode WorkflowTransition |
Informatie voor een knooppunt in de workflow (of niet) | WorkflowStatus |
Zoals beschreven in Locating the Script, verstrekt AEM (via Apache Sling) een ECMA manuscriptmotor die server-zijmanuscripten ECMA uitvoert. De org.apache.sling.scripting.core.ScriptHelper
klasse is onmiddellijk beschikbaar aan uw manuscripten als sling
variabele.
De ScriptHelper
klasse verleent toegang tot SlingHttpServletRequest
die u kunt gebruiken om WorkflowSession
voorwerp uiteindelijk te verkrijgen; bijvoorbeeld:
var wfsession = sling.getRequest().getResource().getResourceResolver().adaptTo(Packages.com.adobe.granite.workflow.WorkflowSession);
De workflowconsole maakt intensief gebruik van de REST API; Deze pagina beschrijft dus de REST API voor workflows.
Met het opdrachtregelprogramma 'curl' kunt u de REST-API voor workflowobjecten gebruiken om toegang te krijgen tot workflowobjecten en de levenscycli van instanties te beheren. De voorbeelden op deze pagina demonstreren het gebruik van de REST API via het curl opdrachtregelprogramma.
De volgende acties worden ondersteund met de REST API:
Met Firebug, een Firefox-extensie voor webontwikkeling, kunt u het HTTP-verkeer volgen wanneer de console wordt uitgevoerd. U kunt bijvoorbeeld de parameters en de waarden controleren die naar de AEM server worden verzonden met een POST
-verzoek.
Op deze pagina wordt aangenomen dat AEM wordt uitgevoerd op localhost op poort 4502
en dat de installatiecontext " /
" (root) is. Als dit niet het geval is voor uw installatie, moeten de URI's, waarop de HTTP-aanvragen van toepassing zijn, dienovereenkomstig worden aangepast.
De rendering die wordt ondersteund voor GET
-aanvragen is de JSON-rendering. De URL's voor GET
moeten bijvoorbeeld de extensie .json
hebben:
http://localhost:4502/etc/workflow.json
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/etc/workflow/instances
HTTP-aanvraagmethode | Acties |
GET |
Hier worden de beschikbare workflowinstanties weergegeven. |
POST |
Hiermee wordt een nieuwe werkstroominstantie gemaakt. De parameters zijn: |
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/etc/workflow/instances.{state}
HTTP-aanvraagmethode | Acties |
---|---|
GET |
Hier worden de beschikbare workflowinstanties en hun statussen vermeld ( RUNNING , SUSPENDED , ABORTED of COMPLETED ) |
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/etc/workflow/instances/{id}
HTTP-aanvraagmethode | Acties |
GET |
Haalt de gegevens van de instanties (definitie en metagegevens) op, inclusief de koppeling naar het respectievelijke workflowmodel. |
POST |
Wijzigt de status van de instantie. De nieuwe staat wordt verzonden als parameter state en moet één van de volgende waarden hebben: RUNNING , SUSPENDED of ABORTED .Als de nieuwe status niet bereikbaar is (bijvoorbeeld wanneer een afgesloten instantie wordt opgeschort), wordt een 409 (CONFLICT ) reactie teruggestuurd naar de client. |
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/etc/workflow/models
HTTP-aanvraagmethode | Acties |
GET |
Hier worden de beschikbare workflowmodellen weergegeven. |
POST |
Hiermee maakt u een nieuw workflowmodel. Als de parameter title wordt verzonden, wordt een nieuw model gecreeerd met de gespecificeerde titel. Als u een JSON-modeldefinitie koppelt als parameter model , wordt een nieuw workflowmodel gemaakt volgens de opgegeven definitie.Een 201 antwoord (CREATED ) wordt teruggestuurd met een plaatsheader die URL van het nieuwe werkschemamodel bevat.Dit gebeurt ook wanneer een modeldefinitie wordt gekoppeld als een bestandsparameter die modelfile wordt genoemd.In beide gevallen van de model en modelfile parameters, type wordt een extra geroepen parameter vereist om het rangschikkingsformaat te bepalen. De nieuwe rangschikkingsformaten kunnen worden geïntegreerd gebruikend OSGI API. Er wordt een standaard JSON-serializer geleverd met de workflow-engine. Het type is JSON. Zie hieronder voor een voorbeeld van de opmaak. |
Voorbeeld: in browser, produceert een verzoek aan http://localhost:4502/etc/workflow/models.json
een jsreactie gelijkend op het volgende:
[
{"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"}
]
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502*{uri}*
Waar *{uri}*
het pad naar het modelknooppunt in de repository is.
HTTP-aanvraagmethode | Acties |
GET |
Haalt de HEAD -versie van het model (definitie en metagegevens) op. |
PUT |
Werkt de HEAD versie van het model bij (leidt tot een nieuwe versie).De volledige modeldefinitie voor de nieuwe versie van het model moet als geroepen parameter worden toegevoegd model . Bovendien is een type parameter nodig zoals wanneer het creëren van nieuwe modellen en moet de waarde JSON hebben. |
POST |
Hetzelfde gedrag als bij PUT. Nodig omdat AEM widgets bewerkingen PUT niet ondersteunen. |
DELETE |
Hiermee verwijdert u het model. Om problemen met de firewall/proxy op te lossen, wordt een POST met een koptekstvermelding X-HTTP-Method-Override met waarde DELETE ook geaccepteerd als DELETE -verzoek. |
Voorbeeld: in browser, keert een verzoek aan http://localhost:4502/var/workflow/models/publish_example.json
een json
reactie terug die aan de volgende code gelijkaardig is:
{
"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":
{
}
}
]}
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/etc/workflow/models/{id}.{version}
HTTP-aanvraagmethode | Acties |
---|---|
GET |
Haalt de gegevens van het model op in de opgegeven versie (indien aanwezig). |
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/bin/workflow/inbox
HTTP-aanvraagmethode | Acties |
GET |
Maakt een lijst van de het werkpunten die in inbox van de gebruiker zijn, die door de de authentificatiekopballen van HTTP wordt geïdentificeerd. |
POST |
Voltooit het het werkpunt de waarvan URI als parameter item wordt verzonden en vooruitgang de volgens werkschemainstantie aan de volgende knoop(s), die door de parameter route of backroute in het geval van het gaan van een stap terug wordt bepaald.Als de parameter delegatee wordt verzonden, item wordt het het werkpunt dat door de parameter wordt geïdentificeerd afgevaardigd aan de gespecificeerde deelnemer. |
De volgende HTTP-aanvraagmethoden zijn van toepassing op:
http://localhost:4502/bin/workflow/inbox/{id}
HTTP-aanvraagmethode | Acties |
---|---|
GET |
Haalt de gegevens (definitie en metagegevens) op van het inbox WorkItem dat door de id ervan wordt geïdentificeerd. |
Voer een GET uit om een lijst met alle actieve workflows op te halen:
http://localhost:4502/etc/workflow/instances.RUNNING.json
Voorbeeld met krullen:
curl -u admin:admin http://localhost:4502/etc/workflow/instances.RUNNING.json
De uri
die in de resultaten wordt getoond kan als instantie id
in andere bevelen worden gebruikt; bijvoorbeeld:
[
{"uri":"/etc/workflow/instances/server0/2017-03-08/request_for_activation_1"}
]
Deze curl
opdracht kan worden gebruikt met elke workflowstatus in plaats van RUNNING
.
Als u de Werkstroomtitel op het tabblad Instanties van de workflowconsole wilt wijzigen, verzendt u een POST
-opdracht:
tot: http://localhost:4502/etc/workflow/instances/{id}
met de volgende parameters:
action
: de waarde ervan moet : UPDATE
workflowTitle
: de titel van de workflowVoorbeeld met krullen:
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
Ga als volgt te werk om een lijst met alle beschikbare workflowmodellen op te halen:
http://localhost:4502/etc/workflow/models.json
Voorbeeld met krullen:
curl -u admin:admin http://localhost:4502/etc/workflow/models.json
Zie ook Workflowmodellen beheren.
De klasse com.adobe.granite.workflow.WorkflowSession
kan worden aangepast vanuit een javax.jcr.Session
-object of een org.apache.sling.api.resource.ResourceResolver
-object.
Gebruik in een JSP-script (of Java-code voor een servlet-klasse) het HTTP-aanvraagobject om een SlingHttpServletRequest
-object te verkrijgen, dat toegang biedt tot een ResourceResolver
-object. Pas het object ResourceResolver
aan op 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);
%>
Gebruik de variabele sling
om het SlingHttpServletRequest
voorwerp te verkrijgen dat u gebruikt om een ResourceResolver
voorwerp te verkrijgen. Pas het object ResourceResolver
aan op het object WorkflowSession
.
var wfsession = sling.getRequest().getResource().getResourceResolver().adaptTo(Packages.com.adobe.granite.workflow.WorkflowSession);
De volgende voorbeelden laten zien hoe u workflowmodellen kunt openen:
WorkflowSession.createNewModel
methode.De gebruikte voorbeelden:
/var/workflow/models/mymodel/jcr:content/model
).Als u het model verwijdert, wordt de eigenschap deleted
van het onderliggende knooppunt metaData
van het model ingesteld op true
.
Verwijderen verwijdert het modelknooppunt niet.
Bij het maken van een nieuw model:
De redacteur van het werkschemamodel vereist dat de modellen een specifieke knoopstructuur onder /var/workflow/models
gebruiken. Het bovenliggende knooppunt van het model moet van het type cq:Page
zijn met een jcr:content
-knooppunt met de volgende eigenschapswaarden:
sling:resourceType
: cq/workflow/components/pages/model
cq:template
: /libs/cq/workflow/templates/model
Wanneer u een model creeert, moet u deze cq:Page
knoop eerst creëren en zijn jcr:content
knoop als ouder van de modelknoop gebruiken.
Het argument id
dat sommige methodes voor het identificeren van het model vereisen is de absolute weg van de modelknoop in de bewaarplaats:
/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}
Wegens het vereiste detailniveau, wordt de krulling niet praktisch geacht voor het creëren van en/of het lezen van een model.
U kunt WorkflowStatus API gebruiken om informatie over de werkschemastatus van een knoop terug te winnen.
Verschillende methoden hebben de parameter:
excludeSystemWorkflows
Deze parameter kan op true
worden geplaatst om erop te wijzen dat de systeemwerkschema's van de relevante resultaten zouden moeten worden uitgesloten.
U kunt de configuratie OSGi bijwerken Adobe Granite Workflow PayloadMapCache die de workflow Models
opgeeft die als systeemworkflows moet worden beschouwd. De standaardworkflowmodellen (runtime) zijn:
/var/workflow/models/scheduled_activation/jcr:content/model
/var/workflow/models/scheduled_deactivation/jcr:content/model
Als u een stap Deelnemer moet automatisch vooruitzetten die niet binnen een vooraf bepaald tijdstip is voltooid, kunt u:
Implementeer een OSGI-gebeurtenislistener om te luisteren naar het maken en wijzigen van taken.
Geef een time-out (deadline) op en maak vervolgens een geplande slingertaak die op dat moment moet worden uitgevoerd.
Schrijf een taakmanager die op de hoogte wordt gebracht wanneer de onderbreking verloopt en de baan teweegbrengt.
Deze manager zal de vereiste actie op de taak nemen als de taak nog niet wordt voltooid
De te nemen maatregelen moeten duidelijk omschreven zijn om van deze aanpak gebruik te kunnen maken.
Hieronder vindt u basisvoorbeelden van de wijze waarop u programmatisch kunt communiceren met workflowinstanties.
// 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);
Een workflow starten
# 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
De instanties weergeven
# listing the instances
curl -u admin:admin http://localhost:4502/etc/workflow/instances.json
Hierin worden alle gevallen vermeld; bijvoorbeeld:
[
{"uri":"/var/workflow/instances/server0/2018-02-26/prototype-01_1"}
,{"uri":"/var/workflow/instances/server0/2018-02-26/prototype-01_2"}
]
Zie Hoe te om een Lijst van alle Lopende Werkschema's met hun IDs voor het vermelden van instanties met een specifieke status te krijgen.
Een workflow opschorten
# 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
Een workflow hervatten
# 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
Een werkstroominstantie beëindigen
# 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
Het volgende verstrekt basisvoorbeelden van hoe te (programmatisch) met het werkpunten in wisselwerking te staan.
// 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));
Werkitems van de aanbieding in het Postvak IN
# listing the work items
curl -u admin:admin http://localhost:4502/bin/workflow/inbox
Details voor werkitems die zich momenteel in de Postvak IN bevinden, worden weergegeven. bijvoorbeeld:
[{
"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"
}
Werkitems delegeren
# 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
De delegatee
moet een geldige optie voor de werkschemastap zijn.
Werkonderdelen voltooien of naar de volgende stap gaan
# 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
Gebruik het OSGi-gebeurtenisframework om te luisteren naar gebeurtenissen die door de klasse com.adobe.granite.workflow.event.WorkflowEvent
worden gedefinieerd. Deze klasse biedt ook verschillende nuttige methoden om informatie over het onderwerp van de gebeurtenis te verkrijgen. De methode getWorkItem
retourneert bijvoorbeeld het object WorkItem
voor het werkitem dat bij de gebeurtenis is betrokken.
De volgende voorbeeldcode definieert een service die luistert naar workflowgebeurtenissen en taken uitvoert op basis van het type gebeurtenis.
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;
}
}