Examples of fail()


Examples of org.hornetq.spi.core.protocol.RemotingConnection.fail()

               for (Object id : idsToRemove)
               {
                  RemotingConnection conn = removeConnection(id);
                  if (conn != null)
                  {
                     conn.fail(HornetQMessageBundle.BUNDLE.clientExited(conn.getRemoteAddress()));
                  }
               }

               if (latch.await(pauseInterval, TimeUnit.MILLISECONDS))
                  return;
View Full Code Here

Examples of org.intalio.tempo.workflow.tms.ITaskManagementService.fail()

        tms.complete(task6ID);

        PATask task7 = (PATask) tms.getTask(task6ID);
        Assert.assertEquals(TaskState.COMPLETED, task7.getState());

        tms.fail(task7.getID(), "code", "reason");

        PATask task8 = (PATask) tms.getTask(task7.getID());
        Assert.assertEquals(task8.getProcessID(), task7.getProcessID());
        Assert.assertEquals(TaskState.FAILED, task8.getState());
        Assert.assertEquals("code", task8.getFailureCode());
View Full Code Here

Examples of org.intalio.tempo.workflow.tms.client.TempoClient.fail()

        // skip needs to be called on TMP first.
        if (optionalCall.equals("skip"))
            tempoClient.skip(id);
        else if (optionalCall.equals("fail"))
          tempoClient.fail(id, "0", "Error message");
        else if (optionalCall.equals("delete"))
          tempoClient.delete(new String[] { id });
        else if (optionalCall.equals("deleteAll"))
          tempoClient.deleteAll("false", "T._state = TaskState.READY", "PATask");
        else if (optionalCall.equals("reassign"))
View Full Code Here

Examples of org.jbehave.core.mock.UsingMatchers.fail()

    public void shouldCatchAndRethrowExceptionOfAnUnexpectedType() throws Exception {
        UsingMatchers m = new UsingMatchers() {};
       
        try {
            Exception exception = m.runAndCatch(UnsupportedOperationException.class, EXCEPTION_BLOCK);
            m.fail("Should have thrown IllegalArgumentException");
        } catch (IllegalArgumentException e) {
            // expected
        }
    }
   
View Full Code Here

Examples of org.jboss.ejb3.core.test.jbpapp4428.WebServiceMockStateless.fail()

   {
      final SecurityContext sc = SecurityContextFactory.createSecurityContext("test");
      SecurityContextAssociation.setSecurityContext(sc);

      WebServiceMockStateless bean = lookup(WebServiceMockStatelessBean.class.getSimpleName() + "/local", WebServiceMockStateless.class);
      bean.fail();
   }

   @Test
   public void testSucceed() throws Throwable
   {
View Full Code Here

Examples of org.jbpm.task.service.TaskClient.fail()

        if (taskSummary == null) {
            return;
        }

        BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
        client.fail(taskSummary.getId(), userId, null, responseHandler);
        responseHandler.waitTillDone(3000);
        refresh();
    }

    private TaskClient getTaskClient() {
View Full Code Here

Examples of org.osgi.service.coordinator.Coordination.fail()

                coordination.end();
        } catch (ResolveCancelledException e) {
            result = new ResolutionResult(Outcome.Cancelled, null, null, status, logger.getLog());

            if (coordination != null)
                coordination.fail(e);
        } catch (ResolutionException e) {
            status.add(new Status(IStatus.ERROR, Plugin.PLUGIN_ID, 0, e.getLocalizedMessage(), e));
            result = new ResolutionResult(Outcome.Unresolved, null, null, status, logger.getLog());

            if (coordination != null)
View Full Code Here

Examples of org.osgi.service.coordinator.Coordination.fail()

        } catch (ResolutionException e) {
            status.add(new Status(IStatus.ERROR, Plugin.PLUGIN_ID, 0, e.getLocalizedMessage(), e));
            result = new ResolutionResult(Outcome.Unresolved, null, null, status, logger.getLog());

            if (coordination != null)
                coordination.fail(e);
        } catch (Exception e) {
            status.add(new Status(IStatus.ERROR, Plugin.PLUGIN_ID, 0, "Exception during resolution.", e));
            result = new ResolutionResult(Outcome.Error, null, null, status, logger.getLog());

            if (coordination != null)
View Full Code Here

Examples of org.osgi.service.coordinator.Coordination.fail()

        } catch (Exception e) {
            status.add(new Status(IStatus.ERROR, Plugin.PLUGIN_ID, 0, "Exception during resolution.", e));
            result = new ResolutionResult(Outcome.Error, null, null, status, logger.getLog());

            if (coordination != null)
                coordination.fail(e);
        } finally {
            if (coordinator != null)
                bc.ungetService(coordSvcRef);
        }
    }
View Full Code Here

Examples of org.osgi.service.coordinator.Coordination.fail()

                coordination.end();
        } catch (ResolveCancelledException e) {
            result = new ResolutionResult(Outcome.Cancelled, null, null, status, logger.getLog());

            if (coordination != null)
                coordination.fail(e);
        } catch (ResolutionException e) {
            status.add(new Status(IStatus.ERROR, Plugin.PLUGIN_ID, 0, e.getLocalizedMessage(), e));
            result = new ResolutionResult(Outcome.Unresolved, null, e, status, logger.getLog());

            if (coordination != null)
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.