[JBoss Messaging] - consume queue is slow
by everson .
everson . [https://community.jboss.org/people/everjava] created the discussion
"consume queue is slow"
To view the discussion, visit: https://community.jboss.org/message/778407#778407
--------------------------------------------------------------
What could I do to check or fix slow consume in my queues ? I'm using jboss 5.01 + jbossesb 4.9
Follow my code.
private InitialContext getInitialContext() throws NamingException {
Properties jndiProps = new Properties();
jndiProps.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
jndiProps.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
jndiProps.put(Context.PROVIDER_URL, "jnp://localhost:1099");
InitialContext initialContext = new InitialContext(jndiProps);
return initialContext;
}
public ObjectMessage getMessage(String lookup, String messageSelector) {
Session session = null;
Connection connection = null;
ObjectMessage om = null;
try {
ConnectionFactory factory = (QueueConnectionFactory) getInitialContext().lookup("/ConnectionFactory");
connection = factory.createConnection();
session = connection.createSession(false, QueueSession.AUTO_ACKNOWLEDGE);
Destination destination = (Destination) getInitialContext().lookup(lookup);
MessageConsumer consumer = session.createConsumer(destination, messageSelector);
connection.start();
Message message = null;
message = consumer.receiveNoWait(); *//here, if I use receive(), I'm going to wait about 10-15 seconds to get the message. Sometimes I get in 1 or 2 seconds...*
if (message == null)
message = consumer.receive(15000);
om = (ObjectMessage) message;
} catch (Exception e) {
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/778407#778407]
Start a new discussion in JBoss Messaging at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
13 years, 4 months
[jBPM] - JBPM5.4 full installer, error when accessing jbpm-console's REST to get task list
by Thomas Setiabudi
Thomas Setiabudi [https://community.jboss.org/people/thomas.setiabudi] created the discussion
"JBPM5.4 full installer, error when accessing jbpm-console's REST to get task list"
To view the discussion, visit: https://community.jboss.org/message/777945#777945
--------------------------------------------------------------
hi,
I use JBPM5.4 Full Installer, run ant install.demo, then ant start.demo,
then I try to access http://localhost:8080/gwt-console-server/rs/tasks/mary/participation http://localhost:8080/gwt-console-server/rs/tasks/krisv (http://localhost:8080/gwt-console-server/rs/tasks/mary/participation)http...
I got this result
{"tasks":[]}
but when I look at server.log, there are many error log there, what may be the cause? is it a bug?
http://pastebin.com/G6amvF8W http://pastebin.com/G6amvF8W
19:31:13,064 WARN [org.drools.guvnor.server.repository.RulesRepositoryManager] (http-localhost-127.0.0.1-8080-2) Creating RulesRepository with default username.
19:31:13,064 INFO [stdout] (http-localhost-127.0.0.1-8080-2) =============== session-guest-59
19:31:13,079 INFO [stdout] (http-localhost-127.0.0.1-8080-2) =============== session-guest-59
19:31:14,704 ERROR [org.hibernate.hql.internal.ast.ErrorCounter] (Thread-68) <AST>:0:0: unexpected end of subtree
19:31:14,720 ERROR [org.hibernate.hql.internal.ast.ErrorCounter] (Thread-68) <AST>:0:0: unexpected end of subtree: <AST>:0:0: unexpected end of subtree
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.fromElementList(HqlSqlBaseWalker.java:3146) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.fromClause(HqlSqlBaseWalker.java:694) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.query(HqlSqlBaseWalker.java:550) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.collectionFunctionOrSubselect(HqlSqlBaseWalker.java:4467) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.inRhs(HqlSqlBaseWalker.java:4372) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.comparisonExpr(HqlSqlBaseWalker.java:4047) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1923) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1876) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1851) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1848) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1848) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1848) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1848) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1848) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.logicalExpr(HqlSqlBaseWalker.java:1848) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.whereClause(HqlSqlBaseWalker.java:782) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.query(HqlSqlBaseWalker.java:583) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.selectStatement(HqlSqlBaseWalker.java:287) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.antlr.HqlSqlBaseWalker.statement(HqlSqlBaseWalker.java:235) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QueryTranslatorImpl.analyze(QueryTranslatorImpl.java:248) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:183) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:136) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:101) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:80) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.engine.query.spi.QueryPlanCache.getHQLQueryPlan(QueryPlanCache.java:119) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.internal.AbstractSessionImpl.getHQLQueryPlan(AbstractSessionImpl.java:214) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.internal.SessionImpl.list(SessionImpl.java:1107) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.internal.QueryImpl.list(QueryImpl.java:101) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.ejb.QueryImpl.getResultList(QueryImpl.java:252) [hibernate-entitymanager-4.0.1.Final.jar:4.0.1.Final]
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParameters(TaskPersistenceManager.java:352) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:295) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:317) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.TaskServiceSession.getTasksAssignedAsPotentialOwnerByStatus(TaskServiceSession.java:801) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.TaskServerHandler.messageReceived(TaskServerHandler.java:359) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.hornetq.HornetQTaskServerHandler.messageReceived(HornetQTaskServerHandler.java:43) [jbpm-human-task-hornetq-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.hornetq.BaseHornetQTaskServer.run(BaseHornetQTaskServer.java:104) [jbpm-human-task-hornetq-5.4.0.Final.jar:5.4.0.Final]
at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_30]
19:31:14,798 ERROR [stderr] (Thread-68) java.lang.RuntimeException: Operation failed
19:31:14,798 ERROR [stderr] (Thread-68) at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:310)
19:31:14,798 ERROR [stderr] (Thread-68) at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:317)
19:31:14,798 ERROR [stderr] (Thread-68) at org.jbpm.task.service.TaskServiceSession.getTasksAssignedAsPotentialOwnerByStatus(TaskServiceSession.java:801)
19:31:14,798 ERROR [stderr] (Thread-68) at org.jbpm.task.service.TaskServerHandler.messageReceived(TaskServerHandler.java:359)
19:31:14,814 ERROR [stderr] (Thread-68) at org.jbpm.task.service.hornetq.HornetQTaskServerHandler.messageReceived(HornetQTaskServerHandler.java:43)
19:31:14,814 ERROR [stderr] (Thread-68) at org.jbpm.task.service.hornetq.BaseHornetQTaskServer.run(BaseHornetQTaskServer.java:104)
19:31:14,814 ERROR [stderr] (Thread-68) at java.lang.Thread.run(Thread.java:662)
19:31:14,814 ERROR [stderr] (Thread-68) Caused by: java.lang.IllegalArgumentException: org.hibernate.hql.internal.ast.QuerySyntaxException: unexpected end of subtree [select new org.jbpm.task.query.TaskSummary( t.id, t.taskData.processInstanceId, name.text, subject.text, description.text, t.taskData.status, t.priority, t.taskData.skipable, actualOwner, createdBy, t.taskData.createdOn, t.taskData.activationTime, t.taskData.expirationTime, t.taskData.processId, t.taskData.processSessionId) from org.jbpm.task.Task t left join t.taskData.createdBy as createdBy left join t.taskData.actualOwner as actualOwner left join t.subjects as subject left join t.descriptions as description left join t.names as name, org.jbpm.task.OrganizationalEntity potentialOwners where t.archived = 0 and ( potentialOwners.id = :userId or potentialOwners.id in () ) and potentialOwners in elements ( t.peopleAssignments.potentialOwners ) and ( name.language = :language or t.names.size = 0 ) and ( subject.language = :language or t.subjects.size = 0 ) and ( description.language = :language or t.descriptions.size = 0 ) and t.taskData.status in (:status) and t.taskData.expirationTime is null]
19:31:14,829 ERROR [stderr] (Thread-68) at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1348)
19:31:14,829 ERROR [stderr] (Thread-68) at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1289)
19:31:14,829 ERROR [stderr] (Thread-68) at org.hibernate.ejb.QueryImpl.getResultList(QueryImpl.java:261)
19:31:14,829 ERROR [stderr] (Thread-68) at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParameters(TaskPersistenceManager.java:352)
19:31:14,829 ERROR [stderr] (Thread-68) at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:295)
19:31:14,845 ERROR [stderr] (Thread-68) ... 6 more
19:31:14,845 ERROR [stderr] (Thread-68) Caused by: org.hibernate.hql.internal.ast.QuerySyntaxException: unexpected end of subtree [select new org.jbpm.task.query.TaskSummary( t.id, t.taskData.processInstanceId, name.text, subject.text, description.text, t.taskData.status, t.priority, t.taskData.skipable, actualOwner, createdBy, t.taskData.createdOn, t.taskData.activationTime, t.taskData.expirationTime, t.taskData.processId, t.taskData.processSessionId) from org.jbpm.task.Task t left join t.taskData.createdBy as createdBy left join t.taskData.actualOwner as actualOwner left join t.subjects as subject left join t.descriptions as description left join t.names as name, org.jbpm.task.OrganizationalEntity potentialOwners where t.archived = 0 and ( potentialOwners.id = :userId or potentialOwners.id in () ) and potentialOwners in elements ( t.peopleAssignments.potentialOwners ) and ( name.language = :language or t.names.size = 0 ) and ( subject.language = :language or t.subjects.size = 0 ) and ( description.language = :language or t.descriptions.size = 0 ) and t.taskData.status in (:status) and t.taskData.expirationTime is null]
19:31:14,845 ERROR [stderr] (Thread-68) at org.hibernate.hql.internal.ast.QuerySyntaxException.convert(QuerySyntaxException.java:54)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.hql.internal.ast.QuerySyntaxException.convert(QuerySyntaxException.java:47)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.hql.internal.ast.ErrorCounter.throwQueryException(ErrorCounter.java:79)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.hql.internal.ast.QueryTranslatorImpl.analyze(QueryTranslatorImpl.java:255)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.hql.internal.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:183)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.hql.internal.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:136)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:101)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:80)
19:31:14,860 ERROR [stderr] (Thread-68) at org.hibernate.engine.query.spi.QueryPlanCache.getHQLQueryPlan(QueryPlanCache.java:119)
19:31:14,876 ERROR [stderr] (Thread-68) at org.hibernate.internal.AbstractSessionImpl.getHQLQueryPlan(AbstractSessionImpl.java:214)
19:31:14,876 ERROR [stderr] (Thread-68) at org.hibernate.internal.SessionImpl.list(SessionImpl.java:1107)
19:31:14,876 ERROR [stderr] (Thread-68) at org.hibernate.internal.QueryImpl.list(QueryImpl.java:101)
19:31:14,876 ERROR [stderr] (Thread-68) at org.hibernate.ejb.QueryImpl.getResultList(QueryImpl.java:252)
19:31:14,876 ERROR [stderr] (Thread-68) ... 8 more
19:31:14,876 ERROR [org.jbpm.task.service.TaskServerHandler] (Thread-68) Operation failed: java.lang.RuntimeException: Operation failed
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:310) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:317) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.TaskServiceSession.getTasksAssignedAsPotentialOwnerByStatus(TaskServiceSession.java:801) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.TaskServerHandler.messageReceived(TaskServerHandler.java:359) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.hornetq.HornetQTaskServerHandler.messageReceived(HornetQTaskServerHandler.java:43) [jbpm-human-task-hornetq-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.hornetq.BaseHornetQTaskServer.run(BaseHornetQTaskServer.java:104) [jbpm-human-task-hornetq-5.4.0.Final.jar:5.4.0.Final]
at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_30]
Caused by: java.lang.IllegalArgumentException: org.hibernate.hql.internal.ast.QuerySyntaxException: unexpected end of subtree [select new org.jbpm.task.query.TaskSummary( t.id, t.taskData.processInstanceId, name.text, subject.text, description.text, t.taskData.status, t.priority, t.taskData.skipable, actualOwner, createdBy, t.taskData.createdOn, t.taskData.activationTime, t.taskData.expirationTime, t.taskData.processId, t.taskData.processSessionId) from org.jbpm.task.Task t left join t.taskData.createdBy as createdBy left join t.taskData.actualOwner as actualOwner left join t.subjects as subject left join t.descriptions as description left join t.names as name, org.jbpm.task.OrganizationalEntity potentialOwners where t.archived = 0 and ( potentialOwners.id = :userId or potentialOwners.id in () ) and potentialOwners in elements ( t.peopleAssignments.potentialOwners ) and ( name.language = :language or t.names.size = 0 ) and ( subject.language = :language or t.subjects.size = 0 ) and ( description.language = :language or t.descriptions.size = 0 ) and t.taskData.status in (:status) and t.taskData.expirationTime is null]
at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1348) [hibernate-entitymanager-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1289) [hibernate-entitymanager-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.ejb.QueryImpl.getResultList(QueryImpl.java:261) [hibernate-entitymanager-4.0.1.Final.jar:4.0.1.Final]
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParameters(TaskPersistenceManager.java:352) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.persistence.TaskPersistenceManager.queryWithParametersInTransaction(TaskPersistenceManager.java:295) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
... 6 more
Caused by: org.hibernate.hql.internal.ast.QuerySyntaxException: unexpected end of subtree [select new org.jbpm.task.query.TaskSummary( t.id, t.taskData.processInstanceId, name.text, subject.text, description.text, t.taskData.status, t.priority, t.taskData.skipable, actualOwner, createdBy, t.taskData.createdOn, t.taskData.activationTime, t.taskData.expirationTime, t.taskData.processId, t.taskData.processSessionId) from org.jbpm.task.Task t left join t.taskData.createdBy as createdBy left join t.taskData.actualOwner as actualOwner left join t.subjects as subject left join t.descriptions as description left join t.names as name, org.jbpm.task.OrganizationalEntity potentialOwners where t.archived = 0 and ( potentialOwners.id = :userId or potentialOwners.id in () ) and potentialOwners in elements ( t.peopleAssignments.potentialOwners ) and ( name.language = :language or t.names.size = 0 ) and ( subject.language = :language or t.subjects.size = 0 ) and ( description.language = :language or t.descriptions.size = 0 ) and t.taskData.status in (:status) and t.taskData.expirationTime is null]
at org.hibernate.hql.internal.ast.QuerySyntaxException.convert(QuerySyntaxException.java:54) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QuerySyntaxException.convert(QuerySyntaxException.java:47) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.ErrorCounter.throwQueryException(ErrorCounter.java:79) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QueryTranslatorImpl.analyze(QueryTranslatorImpl.java:255) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:183) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.hql.internal.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:136) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:101) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.engine.query.spi.HQLQueryPlan.<init>(HQLQueryPlan.java:80) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.engine.query.spi.QueryPlanCache.getHQLQueryPlan(QueryPlanCache.java:119) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.internal.AbstractSessionImpl.getHQLQueryPlan(AbstractSessionImpl.java:214) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.internal.SessionImpl.list(SessionImpl.java:1107) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.internal.QueryImpl.list(QueryImpl.java:101) [hibernate-core-4.0.1.Final.jar:4.0.1.Final]
at org.hibernate.ejb.QueryImpl.getResultList(QueryImpl.java:252) [hibernate-entitymanager-4.0.1.Final.jar:4.0.1.Final]
... 8 more
19:31:14,954 ERROR [org.jbpm.task.service.hornetq.HornetQTaskClientConnector] (Thread-88) Client Exception with class class org.jbpm.task.service.hornetq.HornetQTaskClientConnector$1 using port 5153: java.lang.NullPointerException
at org.jbpm.task.service.TaskClientHandler.messageReceived(TaskClientHandler.java:62) [jbpm-human-task-core-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.hornetq.HornetQTaskClientHandler.messageReceived(HornetQTaskClientHandler.java:56) [jbpm-human-task-hornetq-5.4.0.Final.jar:5.4.0.Final]
at org.jbpm.task.service.hornetq.HornetQTaskClientConnector$1.run(HornetQTaskClientConnector.java:122) [jbpm-human-task-hornetq-5.4.0.Final.jar:5.4.0.Final]
at java.lang.Thread.run(Thread.java:662) [rt.jar:1.6.0_30]
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/777945#777945]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
13 years, 4 months
[jBPM] - Re: jBPM-console - Oracle - start process
by Aadav N
Aadav N [https://community.jboss.org/people/aadav] created the discussion
"Re: jBPM-console - Oracle - start process"
To view the discussion, visit: https://community.jboss.org/message/778240#778240
--------------------------------------------------------------
Hi bpmn2user,
I'm facing the same issue with this mina human task server. I'm also using oracle as my backend. Did you get a chance to fix it? Though I get the process created successfully, because of this issue I'm not able to get the tasks created. Any help..!? Would be appreciated greatly..
Exception as follows:
2012-11-26 06:55:02,494 INFO [org.apache.coyote.http11.Http11Protocol] (main) Starting Coyote HTTP/1.1 on http-localhost%2F127.0.0.1-8080
2012-11-26 06:55:02,512 INFO [org.apache.coyote.ajp.AjpProtocol] (main) Starting Coyote AJP/1.3 on ajp-localhost%2F127.0.0.1-8009
2012-11-26 06:55:02,520 INFO [org.jboss.bootstrap.microcontainer.ServerImpl] (main) JBoss (Microcontainer) [5.1.0.GA (build: SVNTag=JBoss_5_1_0_GA date=200905221634)] Started in 2m:23s:333ms
2012-11-26 06:55:12,153 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:55:14,042 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) CREATED
2012-11-26 06:55:14,043 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) OPENED
2012-11-26 06:55:14,045 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) Loaded user admin:
2012-11-26 06:55:14,045 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) admin
2012-11-26 06:55:14,045 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) manager
2012-11-26 06:55:14,045 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) user
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) Loaded user krisv:
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) admin
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) manager
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) user
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) Loaded user john:
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) admin
2012-11-26 06:55:14,046 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) manager
2012-11-26 06:55:14,047 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) user
2012-11-26 06:55:14,047 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) Loaded user mary:
2012-11-26 06:55:14,047 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) admin
2012-11-26 06:55:14,047 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) manager
2012-11-26 06:55:14,047 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-1) user
2012-11-26 06:55:14,052 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) RECEIVED: HeapBuffer[pos=0 lim=178 cap=2048: 00 00 00 AE AC ED 00 05 73 72 01 00 1D 6F 72 67...]
2012-11-26 06:55:14,054 INFO [STDOUT] (NioProcessor-3) Hibernate: select user0_.id as id60_0_ from JBPMDB.OrganizationalEntity user0_ where user0_.id=? and user0_.DTYPE='User'
2012-11-26 06:55:14,071 INFO [STDOUT] (NioProcessor-3) Hibernate: select task0_.id as col_0_0_, task0_.processInstanceId as col_1_0_, names4_.text as col_2_0_, subjects2_.text as col_3_0_, descriptio3_.text as col_4_0_, task0_.status as col_5_0_, task0_.priority as col_6_0_, task0_.skipable as col_7_0_, task0_.actualOwner_id as col_8_0_, task0_.createdBy_id as col_9_0_, task0_.createdOn as col_10_0_, task0_.activationTime as col_11_0_, task0_.expirationTime as col_12_0_, task0_.processId as col_13_0_, task0_.processSessionId as col_14_0_ from JBPMDB.Task task0_, JBPMDB.OrganizationalEntity user1_, JBPMDB.I18NText subjects2_, JBPMDB.I18NText descriptio3_, JBPMDB.I18NText names4_, JBPMDB.OrganizationalEntity user5_ where task0_.createdBy_id=user1_.id(+) and task0_.id=subjects2_.Task_Subjects_Id(+) and task0_.id=descriptio3_.Task_Descriptions_Id(+) and task0_.id=names4_.Task_Names_Id(+) and task0_.actualOwner_id=user5_.id and task0_.archived=0 and task0_.actualOwner_id=? and (names4_.language=? or (select count(names7_.Task_Names_Id) from JBPMDB.I18NText names7_ where task0_.id=names7_.Task_Names_Id)=0) and (subjects2_.language=? or (select count(subjects8_.Task_Subjects_Id) from JBPMDB.I18NText subjects8_ where task0_.id=subjects8_.Task_Subjects_Id)=0) and (descriptio3_.language=? or (select count(descriptio9_.Task_Descriptions_Id) from JBPMDB.I18NText descriptio9_ where task0_.id=descriptio9_.Task_Descriptions_Id)=0) and (task0_.expirationTime is null)
2012-11-26 06:55:14,106 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
2012-11-26 06:55:14,112 INFO [STDOUT] (NioProcessor-6) [2012:11:331 06:11:112:debug] Message receieved on client : QueryTaskSummaryResponse
2012-11-26 06:55:14,113 INFO [STDOUT] (NioProcessor-6) [2012:11:331 06:11:113:debug] Arguments : [[]]
2012-11-26 06:55:22,732 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:55:24,732 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) IDLE
2012-11-26 06:55:33,081 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:55:35,248 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) IDLE
2012-11-26 06:55:43,559 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:55:45,559 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) IDLE
2012-11-26 06:55:53,559 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:55:55,559 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) IDLE
2012-11-26 06:56:03,577 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:56:05,577 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) IDLE
2012-11-26 06:56:06,950 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) RECEIVED: HeapBuffer[pos=0 lim=339 cap=2048: 00 00 01 4F AC ED 00 05 73 72 01 00 1D 6F 72 67...]
2012-11-26 06:56:06,950 INFO [STDOUT] (http-localhost%2F127.0.0.1-8080-2) Registered human task listener
2012-11-26 06:56:06,952 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) RECEIVED: HeapBuffer[pos=0 lim=673 cap=1024: 00 00 01 4C AC ED 00 05 73 72 01 00 1D 6F 72 67...]
2012-11-26 06:56:06,954 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) RECEIVED: HeapBuffer[pos=0 lim=420 cap=1024: 00 00 01 A0 AC ED 00 05 73 72 01 00 1D 6F 72 67...]
2012-11-26 06:56:06,960 ERROR [STDERR] (NioProcessor-2) org.apache.mina.filter.codec.ProtocolDecoderException: java.lang.IllegalStateException: unread block data (Hexdump: 00 00 01 A0 AC ED 00 05 73 72 01 00 1D 6F 72 67 2E 6A 62 70 6D 2E 74 61 73 6B 2E 73 65 72 76 69 63 65 2E 43 6F 6D 6D 61 6E 64 78 70 00 00 00 06 73 72 01 00 13 6A 61 76 61 2E 75 74 69 6C 2E 41 72 72 61 79 4C 69 73 74 78 70 00 00 00 02 77 04 00 00 00 02 73 72 01 00 12 6F 72 67 2E 6A 62 70 6D 2E 74 61 73 6B 2E 54 61 73 6B 78 70 77 E6 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 01 00 00 00 00 00 00 00 00 00 05 65 6E 2D 55 4B 00 0D 50 72 6F 63 65 73 73 20 4F 72 64 65 72 00 00 00 01 00 00 00 00 00 00 00 00 00 05 65 6E 2D 55 4B 00 0D 50 6C 65 61 73 65 20 63 72 65 61 74 65 00 00 00 01 00 00 00 00 00 00 00 00 00 05 65 6E 2D 55 4B 00 0D 50 6C 65 61 73 65 20 63 72 65 61 74 65 01 00 00 00 00 01 00 00 00 05 6B 72 69 73 76 00 00 00 00 00 00 00 00 00 00 00 01 00 00 00 0D 41 64 6D 69 6E 69 73 74 72 61 74 6F 72 00 00 00 00 00 01 01 00 07 43 72 65 61 74 65 64 00 00 01 00 05 6B 72 69 73 76 00 00 00 00 01 00 00 00 00 00 00 06 D6 01 00 00 00 00 00 00 06 D5 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 78 70 78 7E 72 01 00 21 6F 72 67 2E 6A 62 70 6D 2E 74 61 73 6B 2E 73 65 72 76 69 63 65 2E 43 6F 6D 6D 61 6E 64 4E 61 6D 65 78 72 01 00 0E 6A 61 76 61 2E 6C 61 6E 67 2E 45 6E 75 6D 78 70 74 00 0E 41 64 64 54 61 73 6B 52 65 71 75 65 73 74)
2012-11-26 06:56:06,961 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:251)
2012-11-26 06:56:06,961 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)
2012-11-26 06:56:06,961 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1200(DefaultIoFilterChain.java:46)
2012-11-26 06:56:06,961 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:796)
2012-11-26 06:56:06,961 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.filter.logging.LoggingFilter.messageReceived(LoggingFilter.java:177)
2012-11-26 06:56:06,961 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain.access$1200(DefaultIoFilterChain.java:46)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain$EntryImpl$1.messageReceived(DefaultIoFilterChain.java:796)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.IoFilterAdapter.messageReceived(IoFilterAdapter.java:119)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain.callNextMessageReceived(DefaultIoFilterChain.java:434)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.filterchain.DefaultIoFilterChain.fireMessageReceived(DefaultIoFilterChain.java:426)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.polling.AbstractPollingIoProcessor.read(AbstractPollingIoProcessor.java:692)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:645)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:634)
2012-11-26 06:56:06,962 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$400(AbstractPollingIoProcessor.java:66)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:1078)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.lang.Thread.run(Thread.java:662)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) Caused by: java.lang.IllegalStateException: unread block data
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream$BlockDataInputStream.setBlockDataMode(ObjectInputStream.java:2376)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1360)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1946)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1870)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1752)
2012-11-26 06:56:06,963 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1328)
2012-11-26 06:56:06,964 ERROR [STDERR] (NioProcessor-2) at java.io.ObjectInputStream.readObject(ObjectInputStream.java:350)
2012-11-26 06:56:06,964 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.core.buffer.AbstractIoBuffer.getObject(AbstractIoBuffer.java:1982)
2012-11-26 06:56:06,964 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.filter.codec.serialization.ObjectSerializationDecoder.doDecode(ObjectSerializationDecoder.java:92)
2012-11-26 06:56:06,964 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.filter.codec.CumulativeProtocolDecoder.decode(CumulativeProtocolDecoder.java:178)
2012-11-26 06:56:06,964 ERROR [STDERR] (NioProcessor-2) at org.apache.mina.filter.codec.ProtocolCodecFilter.messageReceived(ProtocolCodecFilter.java:241)
2012-11-26 06:56:06,964 ERROR [STDERR] (NioProcessor-2) ... 19 more
2012-11-26 06:56:06,998 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-4) CREATED
2012-11-26 06:56:06,999 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-4) OPENED
2012-11-26 06:56:06,999 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-4) RECEIVED: HeapBuffer[pos=0 lim=196 cap=2048: 00 00 00 C0 AC ED 00 05 73 72 01 00 1D 6F 72 67...]
2012-11-26 06:56:07,001 INFO [STDOUT] (NioProcessor-4) Hibernate: select user0_.id as id60_0_ from JBPMDB.OrganizationalEntity user0_ where user0_.id=? and user0_.DTYPE='User'
2012-11-26 06:56:07,005 INFO [STDOUT] (NioProcessor-4) Hibernate: select task0_.id as col_0_0_, task0_.processInstanceId as col_1_0_, names5_.text as col_2_0_, subjects3_.text as col_3_0_, descriptio4_.text as col_4_0_, task0_.status as col_5_0_, task0_.priority as col_6_0_, task0_.skipable as col_7_0_, task0_.actualOwner_id as col_8_0_, task0_.createdBy_id as col_9_0_, task0_.createdOn as col_10_0_, task0_.activationTime as col_11_0_, task0_.expirationTime as col_12_0_, task0_.processId as col_13_0_, task0_.processSessionId as col_14_0_ from JBPMDB.Task task0_, JBPMDB.OrganizationalEntity user1_, JBPMDB.OrganizationalEntity user2_, JBPMDB.I18NText subjects3_, JBPMDB.I18NText descriptio4_, JBPMDB.I18NText names5_, JBPMDB.OrganizationalEntity organizati6_ where task0_.createdBy_id=user1_.id(+) and task0_.actualOwner_id=user2_.id(+) and task0_.id=subjects3_.Task_Subjects_Id(+) and task0_.id=descriptio4_.Task_Descriptions_Id(+) and task0_.id=names5_.Task_Names_Id(+) and task0_.archived=0 and organizati6_.id=? and (organizati6_.id in (select potentialo9_.entity_id from JBPMDB.PeopleAssignments_PotOwners potentialo9_ where task0_.id=potentialo9_.task_id)) and (names5_.language=? or (select count(names10_.Task_Names_Id) from JBPMDB.I18NText names10_ where task0_.id=names10_.Task_Names_Id)=0) and (subjects3_.language=? or (select count(subjects11_.Task_Subjects_Id) from JBPMDB.I18NText subjects11_ where task0_.id=subjects11_.Task_Subjects_Id)=0) and (descriptio4_.language=? or (select count(descriptio12_.Task_Descriptions_Id) from JBPMDB.I18NText descriptio12_ where task0_.id=descriptio12_.Task_Descriptions_Id)=0) and (task0_.status in ('Created' , 'Ready' , 'Reserved' , 'InProgress' , 'Suspended')) and (task0_.expirationTime is null)
2012-11-26 06:56:07,020 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-4) SENT: HeapBuffer[pos=0 lim=0 cap=0: empty]
2012-11-26 06:56:07,020 INFO [STDOUT] (NioProcessor-11) [2012:11:331 06:11:20:debug] Message receieved on client : QueryTaskSummaryResponse
2012-11-26 06:56:07,021 INFO [STDOUT] (NioProcessor-11) [2012:11:331 06:11:21:debug] Arguments : [[]]
2012-11-26 06:56:16,155 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-3) IDLE
2012-11-26 06:56:17,155 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-2) IDLE
2012-11-26 06:56:17,155 INFO [org.apache.mina.filter.logging.LoggingFilter] (NioProcessor-4) IDLE
Thanks,
Aadav
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/778240#778240]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
13 years, 4 months
[jBPM] - Using jBPM as state machine engine - is it a good idea?
by Zdenek Hrib
Zdenek Hrib [https://community.jboss.org/people/zdenek.hrib] created the discussion
"Using jBPM as state machine engine - is it a good idea?"
To view the discussion, visit: https://community.jboss.org/message/778239#778239
--------------------------------------------------------------
Hi,
I usualy have a database oriented application, which stores records, where one field of the record (one column in a row in database) stores something called "state" - eg. record is "new", "revised", "waiting for approval" or "cancelled". The state of the record should change automatically according to changes in other fields of the record - eg. if someone changes a description of a "new" record, it should be changed to "revised" but if amount > 100 than it should go to "waiting for approval" instead. I would like to have some library where I could in case of record update do something like this (pseudo-code):
Process process = createProcesFromDefinition("mydefinition.process");
process.setCurrentState(getStateFromDatabase());
process.setOldRecord(getRecordFromDatabase());
process.setNewRecord(getRecordWhichIsToBeSaved());
State state = process.computeResultingState();
storeStateToDatabase(state);
I would like to have the process definition in some kind of XML format, and the rules for decision about the resulting transition in MVEL (or something else supported by Drools/JBoss Rules).
Is it possible to use jBPM in this way - just as a state machine engine? Could someone point me in the right direction, which classes should I explore in the jBPM API to do this?
I have seen some examples, but they always start the process from the beginning - but I would like to "fast forward" the process in some other state, provide some data, and let the engine&rules to choose the next state.
Thank you
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/778239#778239]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
13 years, 4 months