9:32 a.m.
René Zoller [https://community.jboss.org/people/rzoller] created the discussion
"Extending jbpm-human-task-war by custom EventListner but they don't get
fired"
To view the discussion, visit: https://community.jboss.org/message/808596#808596
--------------------------------------------------------------
Hello all,
I'm trying to extend the jbpm-human-task-war by implementing an own
HumanTaskServiceServlet and a custom EventListner. My EventListner looks like this:
public class MyTaskEventListner implements TaskEventListener {
private static final Logger logger = LoggerFactory
.getLogger(SiebelTaskEventListner.class);
@Override
public void taskCreated(TaskUserEvent event) {
// TODO Call Siebel to add Task;
logger.info("Task created!");
}
@Override
public void taskClaimed(TaskUserEvent event) {
// Nothing to do here
}
@Override
public void taskStarted(TaskUserEvent event) {
// TODO Call Desktop Connector to open dialogue;
logger.info("Task Started!");
}
@Override
public void taskStopped(TaskUserEvent event) {
// TODO Call Siebel to make the activity editable;
logger.info("Task stoped!.");
}
@Override
public void taskReleased(TaskUserEvent event) {
// Nothing to do here
}
@Override
public void taskCompleted(TaskUserEvent event) {
// TODO Call Siebel to close activity and make it editable again;
logger.info("Task completed! I have to inform Siebel.");
}
@Override
public void taskFailed(TaskUserEvent event) {
logger.info("Task failed!");
}
@Override
public void taskSkipped(TaskUserEvent event) {
// Nothing to do here
}
@Override
public void taskForwarded(TaskUserEvent event) {
// Nothing to do here
}
}
I'm adding the EventListner with
public class HumanTaskServiceServlet extends HttpServlet {
private static final long serialVersionUID = 5L;
private TaskServer server = null;
private Thread thread = null;
public void init() throws ServletException {
EntityManagerFactory emf = Persistence
.createEntityManagerFactory(getConfigParameter(
"task.persistence.unit", "org.jbpm.task"));
String escalationHandlerClass = getConfigParameter(
"escalated.deadline.handler.class",
DefaultEscalatedDeadlineHandler.class.getName());
TaskService taskService = null;
try {
EscalatedDeadlineHandler handler = getInstance(escalationHandlerClass);
if (handler instanceof DefaultEscalatedDeadlineHandler) {
UserInfo userInfo = null;
try {
String userInfoClass = getConfigParameter(
"user.info.class", null);
userInfo = getInstance(userInfoClass);
} catch (IllegalArgumentException e) {
Properties registryProps = new Properties();
registryProps.load(this.getClass().getResourceAsStream(
"/userinfo.properties"));
// userInfo = new DefaultUserInfo(registryProps);
}
((DefaultEscalatedDeadlineHandler) handler)
.setUserInfo(userInfo);
}
taskService = new TaskService(emf,
SystemEventListenerFactory.getSystemEventListener(),
handler);
} catch (Exception e) {
taskService = new TaskService(emf,
SystemEventListenerFactory.getSystemEventListener());
}
String usersConfig = getConfigParameter("load.users", "");
String groupsConfig = getConfigParameter("load.groups", "");
Map<String, User> users = new HashMap<String, User>();
Map<String, Group> groups = new HashMap<String, Group>();
try {
if (usersConfig != null && usersConfig.length() > 0) {
if (usersConfig.endsWith(".mvel")) {
Map vars = new HashMap();
Reader reader = new InputStreamReader(
getConfigFileStream(usersConfig));
users = (Map<String, User>) TaskService.eval(reader, vars);
} else if (usersConfig.endsWith(".properties")) {
Properties props = new Properties();
props.load(getConfigFileStream(usersConfig));
Enumeration<?> ids = props.propertyNames();
while (ids.hasMoreElements()) {
Object idObject = ids.nextElement();
if (idObject instanceof String) {
String id = (String) idObject;
users.put(id, new User(id));
}
}
}
}
} catch (Exception e) {
System.err.println("Problem loading users from specified file: "
+ usersConfig + " error message: " + e);
}
try {
if (groupsConfig != null && groupsConfig.length() > 0) {
if (groupsConfig.endsWith(".mvel")) {
Map vars = new HashMap();
Reader reader = new InputStreamReader(
getConfigFileStream(groupsConfig));
groups = (Map<String, Group>) TaskService
.eval(reader, vars);
} else if (groupsConfig.endsWith(".properties")) {
Properties props = new Properties();
props.load(getConfigFileStream(groupsConfig));
Enumeration<?> ids = props.propertyNames();
while (ids.hasMoreElements()) {
Object idObject = ids.nextElement();
if (idObject instanceof String) {
String id = (String) idObject;
groups.put(id, new Group(id));
}
}
}
}
} catch (Exception e) {
System.err.println("Problem loading groups from specified file: "
+ groupsConfig + " error message: " + e);
}
taskService.addUsersAndGroups(users, groups);
// Add our own Siebel TaskListener
taskService.addEventListener(new SiebelTaskEventListner());
int port = Integer.parseInt(getConfigParameter("hornetq.port",
"5153"));
String host = getConfigParameter("hornetq.host",
"localhost");
server = new HornetQTaskServer(taskService, host, port);
thread = new Thread(server);
thread.start();
System.out.println("HornetQ Task service started correctly !");
System.out.println("HornetQ Task service running (host " + host
+ " port " + port + ") ...");
UserGroupCallbackManager manager = UserGroupCallbackManager
.getInstance();
if (!manager.existsCallback()) {
String callbackClass = getConfigParameter(
"user.group.callback.class", "");
UserGroupCallback userGroupCallback = getInstance(callbackClass);
manager.setCallback(userGroupCallback);
}
System.out.println("Task service startup completed successfully !");
}
...
}
But when I'm starting a Task in jbpm-console non of the methods is executed. How can I
assign/ how do I correctly implement a EventListner for User Tasks?
Thank you!
René
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/808596#808596]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&...]