Package de.scoopgmbh.copper.persistent

Examples of de.scoopgmbh.copper.persistent.PersistentScottyEngine.startup()

122
123
124
125
126
127
128
129
130
131
132
    final int NUMB = 50;
    final String DATA = createTestData(50);
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      for (int i=0; i<NUMB; i++) {
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
    final String DATA = createTestData(50);
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    context.getBean(DatabaseDialect.class).setRemoveWhenFinished(false);
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    try {
      WorkflowInstanceDescr<String> desc = new WorkflowInstanceDescr<String>(PersistentUnitTestWorkflow_NAME, DATA, "DUPLICATE#ID", 1, null);
      engine.run(desc);
      engine.run(desc);
      org.junit.Assert.fail("expected an DuplicateIdException");
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
    final int NUMB = 20;
    final String DATA = createTestData(dataSize);
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      for (int i=0; i<NUMB; i++) {
View Full Code Here
225
226
227
228
229
230
231
232
233
234
235
    final int NUMB = 20;
    final ConfigurableApplicationContext context = createContext(dsContext);
    final DataSource ds = context.getBean(DataSource.class);
    cleanDB(ds);
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      new RetryingTransaction<Void>(ds) {
View Full Code Here
264
265
266
267
268
269
270
271
272
273
274
    final int NUMB = 50;
    final ConfigurableApplicationContext context = createContext(dsContext);
    final DataSource ds = context.getBean(DataSource.class);
    cleanDB(ds);
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      final List<Workflow<?>> list = new ArrayList<Workflow<?>>();
View Full Code Here
307
308
309
310
311
312
313
314
315
316
317
    logger.info("running testTimeouts");
    final int NUMB = 10;
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      for (int i=0; i<NUMB; i++) {
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
    assumeFalse(skipTests());
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    try {
      engine.startup();
      final WorkflowInstanceDescr<Serializable> wfInstanceDescr = new WorkflowInstanceDescr<Serializable>("de.scoopgmbh.copper.test.persistent.ExceptionThrowingPersistentUnitTestWorkflow");
      wfInstanceDescr.setId(engine.createUUID());
      engine.run(wfInstanceDescr);
      Thread.sleep(5000);
      //check
View Full Code Here
392
393
394
395
396
397
398
399
400
401
402
    assumeFalse(skipTests());
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    try {
      engine.startup();
      final WorkflowInstanceDescr<Serializable> wfInstanceDescr = new WorkflowInstanceDescr<Serializable>("de.scoopgmbh.copper.test.persistent.ExceptionThrowingPersistentUnitTestWorkflow");
      wfInstanceDescr.setId(engine.createUUID());
      engine.run(wfInstanceDescr);
      Thread.sleep(5000);
      //check
View Full Code Here
447
448
449
450
451
452
453
454
455
456
457
    logger.info("running testParentChildWorkflow");
    final int NUMB = 20;
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      for (int i=0; i<NUMB; i++) {
View Full Code Here
480
481
482
483
484
485
486
487
488
489
490
    final ConfigurableApplicationContext context = createContext(dsContext);
    cleanDB(context.getBean(DataSource.class));
    final PersistentScottyEngine engine = context.getBean(PersistentScottyEngine.class);
    final ScottyDBStorageInterface dbStorageInterface = context.getBean(ScottyDBStorageInterface.class);
    dbStorageInterface.setRemoveWhenFinished(false);
    engine.startup();
    final BackChannelQueue backChannelQueue = context.getBean(BackChannelQueue.class);
    try {
      assertEquals(EngineState.STARTED,engine.getEngineState());

      for (int i=0; i<NUMB; i++) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.