-
Bug
-
Resolution: Done
-
Major
-
jBPM 5.4
-
None
-
Medium
jBPM Human Task Service:
TaskServiceProcess.java
public static final void main(String[] args) throws Exception { startUp(); // load up the knowledge base KnowledgeBase kbase = readKnowledgeBase(); StatefulKnowledgeSession ksession = JBPMHelper.newStatefulKnowledgeSession(kbase); // start a new process instance ksession.startProcess("com.sample.bpmn.hello"); System.out.println("Process started ..."); } private static KnowledgeBase readKnowledgeBase() throws Exception { KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder(); kbuilder.add(ResourceFactory.newClassPathResource("sample.bpmn"), ResourceType.BPMN2); return kbuilder.newKnowledgeBase(); } private static void startUp() { JBPMHelper.startH2Server(); JBPMHelper.setupDataSource(); // please comment this line if you already have the task service running, // for example when running the jbpm-installer JBPMHelper.startTaskService(); }
Client Class:
TaskServiceClient.java
public static void main(String[] args) { TaskClient client = new TaskClient(new MinaTaskClientConnector( "client 1", new MinaTaskClientHandler( SystemEventListenerFactory.getSystemEventListener()))); client.connect("localhost", 9123); BlockingTaskSummaryResponseHandler taskSummaryResponseHandler = new BlockingTaskSummaryResponseHandler(); client.getTasksOwned("john", "en-UK", taskSummaryResponseHandler); List<TaskSummary> tasks = taskSummaryResponseHandler.getResults(); for (TaskSummary task : tasks) { System.out.println(task.getId() + " " + task.getName() + " " + task.getStatus()); } }
Server Output:
org.hornetq.core.logging.impl.JULLogDelegate error GRAVE: Failed to decode java.lang.IllegalArgumentException: Invalid type: -84 at org.hornetq.core.protocol.core.impl.PacketDecoder.decode(PacketDecoder.java:550) at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:473) at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:520) at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.messageReceived(HornetQChannelHandler.java:73) at org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:100) at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:362) at org.jboss.netty.channel.StaticChannelPipeline$StaticChannelHandlerContext.sendUpstream(StaticChannelPipeline.java:514) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:287) at org.hornetq.core.remoting.impl.netty.HornetQFrameDecoder2.decode(HornetQFrameDecoder2.java:169) at org.hornetq.core.remoting.impl.netty.HornetQFrameDecoder2.messageReceived(HornetQFrameDecoder2.java:134) at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80) at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:362) at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:357) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274) at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261) at org.jboss.netty.channel.socket.oio.OioWorker.run(OioWorker.java:90) at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) at org.jboss.netty.util.internal.IoWorkerRunnable.run(IoWorkerRunnable.java:46) at org.jboss.netty.util.VirtualExecutorService$ChildExecutorRunnable.run(VirtualExecutorService.java:181) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.lang.Thread.run(Unknown Source)
