Author: porcherg Date: 2008-08-12 07:46:56 -0400 (Tue, 12 Aug 2008) New Revision: 1874 Added: jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorIsolationDbTest.java Log: job executor test with read committed isolation level Added: jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorIsolationDbTest.java =================================================================== --- jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorIsolationDbTest.java (rev 0) +++ jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorIsolationDbTest.java 2008-08-12 11:46:56 UTC (rev 1874) @@ -0,0 +1,82 @@ +/** + * Copyright (C) 2007 Bull S. A. S. + * Bull, Rue Jean Jaures, B.P.68, 78340, Les Clayes-sous-Bois + * This library is free software; you can redistribute it and/or modify it under the terms + * of the GNU Lesser General Public License as published by the Free Software Foundation + * version 2.1 of the License. + * This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; + * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. + * See the GNU Lesser General Public License for more details. + * You should have received a copy of the GNU Lesser General Public License along with this + * program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth + * Floor, Boston, MA 02110-1301, USA. + **/ +package org.jbpm.pvm.internal.jobexecutor; + +import java.util.ArrayList; +import java.util.List; + +import org.jbpm.pvm.env.Environment; +import org.jbpm.pvm.internal.cmd.Command; +import org.jbpm.pvm.internal.job.CommandMessage; +import org.jbpm.pvm.internal.log.Log; +import org.jbpm.pvm.internal.wire.descriptor.ObjectDescriptor; +import org.jbpm.pvm.job.Message; +import org.jbpm.pvm.session.MessageSession; +import org.jbpm.pvm.session.PvmDbSession; +import org.jbpm.pvm.test.base.DbTestCase; + + +/** + * This class contains job executor tests which requires to have a read commited isolation level. + * + * @author Guillaume Porcher + * + */ +public class JobExecutorIsolationDbTest extends DbTestCase { + + static int jobExecutorTimeoutMillis = 500; + static int checkInterval = 400; + + public static class SimpleTestCommand implements Command<Object> { + private static final Log log = Log.getLog(SimpleTestCommand.class.getName()); + + public Object execute(Environment environment) throws Exception { + log.debug("command executed !"); + return null; + } + } + + /* + * Basic test that only shows a simple situation in which we need to have a read commited isolation level. + */ + public void testInsertMessage() throws InterruptedException { + JobExecutorTest.processedMessageIds = new ArrayList<Integer>(); + JobExecutor jobExecutor = getEnvironmentFactory().get(JobExecutor.class); + jobExecutor.setIdleInterval(jobExecutorTimeoutMillis); + jobExecutor.start(); + try { + commandService.execute(new Command<Object>() { + public Object execute(Environment environment) throws Exception { + MessageSession messageSession = environment.get(MessageSession.class); + CommandMessage commandMessage = new CommandMessage(new ObjectDescriptor(SimpleTestCommand.class)); + messageSession.send(commandMessage); + List<Message> messages = environment.get(PvmDbSession.class).findMessages(); + assertNotNull(messages); + assertEquals(1, messages.size()); + Thread.sleep(jobExecutorTimeoutMillis * 2); + messages = environment.get(PvmDbSession.class).findMessages(); + assertNotNull(messages); + assertEquals("Job has been executed before the transaction is committed !!", 1, messages.size()); + return null; + } + }); + Thread.sleep(jobExecutorTimeoutMillis * 2); + } finally { + jobExecutor.stop(true); + } + + + } + +} Property changes on: jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorIsolationDbTest.java ___________________________________________________________________ Name: svn:keywords + Id