nav[aria-label="Primary Navigation"] { padding: 0; & ul { list-style: none; width: 100%; display: flex; flex-direction: row; justify-content: start; align-items: start; gap: 30px; padding: 0; & li { margin: 0; } & ul li { list-style: none; } } }

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

Notify users of new tasks via Email

zfranken

I would like to notify users via email when they are assigned a task or are one of a group of candidate users. This is fairly straight forward for a single user with a TaskListener, but I can't think of any way to get at the candidate users/groups and to let them know they have a task waiting to be claimed. Anybody know of a way to do this?

Thanks.

Find more posts tagged with

Comments

zfranken

Since I posted, I found http://jira.codehaus.org/browse/ACT-32. Hopefully this will include notifications for candidates as well as assignees.

I was hoping I could get it working with the listener below, but it appears that the task is not yet persisted when the listeners are fired so the taskService lookups fail. Perhaps an additional event once the task is persisted would help.

<br>public class NotificationListener implements TaskListener {<br><br> private static Logger log = Logger.getLogger(NotificationListener.class.getName());<br><br> @Override<br> public void notify(DelegateTask delegateTask) {<br>&nbsp; TaskService taskService = ProcessEngines.getDefaultProcessEngine().getTaskService();<br>&nbsp; List<IdentityLink> identityLinks = taskService.getIdentityLinksForTask(delegateTask.getId());<br>&nbsp; <br>&nbsp; for(IdentityLink link : identityLinks) {<br>&nbsp;&nbsp; String type = link.getType();<br>&nbsp;&nbsp; if(type.equals(IdentityLinkType.ASSIGNEE)) {<br>&nbsp;&nbsp;&nbsp; log.log(Level.INFO,"========== NOTIFY User of assignment: " + link.getUserId() + " ==============");<br>&nbsp;&nbsp; }<br>&nbsp;&nbsp; if(type.equals(IdentityLinkType.CANDIDATE)) {<br>&nbsp;&nbsp;&nbsp; log.log(Level.INFO,"========== NOTIFY User of assignment: " + link.getUserId() + " ==============");<br>&nbsp;&nbsp; }<br>&nbsp; }<br> }<br>}<br>

trademak

Hi,

You can try casting the DelegateTask parameter to TaskEntity and then you should be able to get the candidate users and groups directly.

Best regards,

zfranken

Perfect! Thanks. Here is my implementation for reference:

<br>import java.util.List;<br>import java.util.logging.Logger;<br><br>import org.activiti.engine.ActivitiException;<br>import org.activiti.engine.delegate.DelegateTask;<br>import org.activiti.engine.delegate.TaskListener;<br>import org.activiti.engine.identity.Group;<br>import org.activiti.engine.identity.User;<br>import org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl;<br>import org.activiti.engine.impl.context.Context;<br>import org.activiti.engine.impl.persistence.entity.IdentityLinkEntity;<br>import org.activiti.engine.impl.persistence.entity.TaskEntity;<br>import org.activiti.engine.task.IdentityLinkType;<br>import org.apache.commons.mail.Email;<br>import org.apache.commons.mail.EmailException;<br>import org.apache.commons.mail.HtmlEmail;<br><br><br>public class NotificationListener implements TaskListener {<br><br> private static Logger log = Logger.getLogger(NotificationListener.class.getName());<br><br> @Override<br> public void notify(DelegateTask delegateTask) {<br>&nbsp; TaskEntity task = (TaskEntity)delegateTask;<br>&nbsp; String assignee = task.getAssignee();<br>&nbsp; List<IdentityLinkEntity> identityLinks = task.getIdentityLinks();<br>&nbsp; <br>&nbsp; StringBuffer message = new StringBuffer("");<br>&nbsp; message.append("You have a new assigned task. <br/><br/>");<br>&nbsp; message.append("<a href=\"<a href="http://localhost:8080/activiti-explorer/#tasks/" rel="nofollow noopener noreferrer">http://localhost:8080/activiti-explorer/#tasks/</a>");<br>&nbsp; message.append(task.getId());<br>&nbsp; message.append("?category=inbox\">");<br>&nbsp; message.append(task.getName());<br>&nbsp; message.append("</a>");<br>&nbsp; <br>&nbsp; if(assignee != null && assignee.length() > 0) {<br>&nbsp;&nbsp; User user = Context.getProcessEngineConfiguration().getIdentityService().createUserQuery().userId(assignee).singleResult();<br>&nbsp;&nbsp; sendNotification(user, message.toString());<br>&nbsp; }<br>&nbsp; <br>&nbsp; for(IdentityLinkEntity link : identityLinks) {<br>&nbsp;&nbsp; if(link.getType().equals(IdentityLinkType.CANDIDATE)) {<br>&nbsp;&nbsp;&nbsp; if(link.isUser()) {<br>&nbsp;&nbsp;&nbsp;&nbsp; User user = Context.getProcessEngineConfiguration().getIdentityService().createUserQuery().userId(link.getUserId()).singleResult();<br>&nbsp;&nbsp;&nbsp;&nbsp; sendNotification(user, message.toString());<br>&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp; if(link.isGroup()) {<br>&nbsp;&nbsp;&nbsp;&nbsp; List<User> users = Context.getProcessEngineConfiguration().getIdentityService().createUserQuery().memberOfGroup(link.getGroupId()).list();<br>&nbsp;&nbsp;&nbsp;&nbsp; for(User user : users) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sendNotification(user, message.toString());<br>&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp; }<br>&nbsp; }<br>&nbsp; <br> }<br> <br> protected void sendNotification(User user, String message) {<br><br>&nbsp; HtmlEmail email = new HtmlEmail();<br>&nbsp; try {<br>&nbsp;&nbsp; email.setHtmlMsg(message);<br>&nbsp;&nbsp; email.addTo(user.getEmail()); <br>&nbsp;&nbsp; email.setSubject("Activiti Assignment Notification");<br>&nbsp;&nbsp; email.setFrom("noreply@deltafaucet.com");<br><br>&nbsp;&nbsp; setMailServerProperties(email);<br><br>&nbsp;&nbsp; email.send();<br>&nbsp; } catch (EmailException e) {<br>&nbsp;&nbsp; throw new ActivitiException("Could not send e-mail:" + e.getMessage(), e);<br>&nbsp; }<br> }<br> <br> protected void setMailServerProperties(Email email) {<br>&nbsp; ProcessEngineConfigurationImpl processEngineConfiguration = Context.getProcessEngineConfiguration();<br><br>&nbsp; String host = processEngineConfiguration.getMailServerHost();<br>&nbsp; if (host == null) {<br>&nbsp;&nbsp; throw new ActivitiException("Could not send email: no SMTP host is configured");<br>&nbsp; }<br>&nbsp; email.setHostName(host);<br><br>&nbsp; int port = processEngineConfiguration.getMailServerPort();<br>&nbsp; email.setSmtpPort(port);<br><br>&nbsp; String user = processEngineConfiguration.getMailServerUsername();<br>&nbsp; String password = processEngineConfiguration.getMailServerPassword();<br>&nbsp; if (user != null && password != null) {<br>&nbsp;&nbsp; email.setAuthentication(user, password);<br>&nbsp; }<br> }<br><br>}<br><br>

pteki

one quick question, is this TaskListener.Notify() works, even if we create a task using restAPI? I have overridden the Notify and I'm getting this only when we do the create/assign through activiti UI, not through API. Did I miss something.

jbarrez

The task listener is part of the process definition, so it doesn't matter if it's done through Java / REST.
Can you give an example where you see it's not working (process xml + the api you're calling)

pteki

Here the URL and the sample JSON. BTW, we are using the alfresco's distribution.
http://localhost:8181/activiti-app/api/enterprise/process-instances

<br>activiti-user: ABCDEF<br>activiti-user-value-type:userExternalIdType<br>{ <br>&nbsp;&nbsp;&nbsp; "processDefinitionId":"IC-Cash-Payment:13:1030028", <br>&nbsp;&nbsp;&nbsp; "name":"ICO Cash 22", <br>&nbsp;&nbsp;&nbsp; "values":<br>&nbsp;&nbsp;&nbsp; {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "account":"123456", <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "status":"active", <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "valueDate":"2015-12-21T01:00:00Z",<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "tradeType":"xxxx", <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "amount":"10000",<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "iij":"IIJ00000001",<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "clientReference":"CRxxxx", <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "paymentDetail":"ddddddddddd", <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "authorizationsNeeded":"true"<br>&nbsp;&nbsp;&nbsp; }<br>}<br>

the Notify method
[java]
@Override
       public void notify(DelegateTask task) {
              LOGGER.info(String.format("Received EVENT:[%1s] for TASK:[%2s]",task.getEventName(),task.getId()));
              //Debug print: Engine Details
              LOGGER.debug(String.format("\nTask [%1s] Listener\n\tEngineServices: {%2s}\n\tRepository Service: {%3s}",
                           task.getId(),
                           task.getExecution().getEngineServices().toString(),
                           task.getExecution().getEngineServices().getRepositoryService().toString()
                           ));
              //Debug print: Process Details
              LOGGER.debug(String.format("\nTask [%1s] Process Details:{ProcessInstanceId: [%2s], ProcessDefinitionId: [%3s], DeploymentId: [%4s], ResouceName:[%5s]}",
                           task.getId(),
                           task.getProcessInstanceId(),
                           task.getProcessDefinitionId(),
                            task.getExecution().getEngineServices().getRepositoryService().getProcessDefinition(task.getProcessDefinitionId()).getDeploymentId(),
                            task.getExecution().getEngineServices().getRepositoryService().getProcessDefinition(task.getProcessDefinitionId()).getResourceName()));


              switch(task.getEventName().toString()){
                     case TaskListener.EVENTNAME_CREATE:
                           createMyTaskEntry(task,"In Progress");
                           break;
                     case TaskListener.EVENTNAME_COMPLETE:
                           createMyTaskEntry(task,"Closed");
                           break;
                     case TaskListener.EVENTNAME_ASSIGNMENT:
                           createMyTaskEntry(task,"Assigned");
                           break;
                     case TaskListener.EVENTNAME_DELETE:
                           createMyTaskEntry(task,"Cancelled");
                           break;
                     default:
                           LOGGER.info(String.format("No Processing Defined for EVENT:[%1s] for TASK:[%2s]",task.getEventName(),task.getId()));
              }

       }
[/java]

jbarrez

OK, nothing wrong there. And that task listener is in the process definition defined? It is also on your classpath of the server?

pteki

yes. the issue was encoding my restTemplate didn't set the encoding to UTF-8 and there was some character which made the failure.
Added the below line, made it work at the client side.
restTemplate.getMessageConverters().add(0, new StringHttpMessageConverter(Charset.forName("UTF-8")));
Thanks for the help.