Examples of FlowExecutionListener

org.mule.tck.listener.FlowExecutionListener
Listener for flow execution complete action.
org.springframework.webflow.execution.FlowExecutionListener
Interface to be implemented by objects that wish to listen and respond to the lifecycle of {@link FlowExecution flow executions}.
An 'observer' that is very aspect like, allowing you to insert 'cross cutting' behavior at well-defined points within one or more well-defined flow execution lifecycles.
For example, one custom listener may apply security checks at the flow execution level, preventing a flow from starting or a state from entering if the current user does not have the necessary permissions. Another listener may track flow execution navigation history to support bread crumbs. Another may perform auditing, or setup and tear down connections to a transactional resource.
Note that flow execution listeners are registered with a flow execution when that execution is created by a {@link FlowExecutionFactory factory} or restored by a{@link org.springframework.webflow.execution.repository.FlowExecutionRepository}. Typically a listener will not be registered with a flow execution at runtime, when the flow execution is already active. @see FlowDefinition @see StateDefinition @see FlowExecution @see RequestContext @see Event @author Keith Donald @author Erwin Vervaet @author Scott Andrews

Examples of org.mule.tck.listener.FlowExecutionListener


    @Before
    public void setUp()
    {
        retrievedMessages = new HashSet<Object>();
        flowExecutionListener = new FlowExecutionListener("retrieveEmails", muleContext);
    }

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener


    @Test
    public void testSynchProcessingStrategy() throws Exception
    {
        sendMessage("vm://testSynch");
        new FlowExecutionListener("synchFlow", muleContext).waitUntilFlowIsComplete();
        file = new File(FILE_PATH);
        String str = FileUtils.readFileToString(file);


        Assert.assertEquals("Part 1Part 2", str);
    }

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener

    }


    @Test
    public void handleRejectedEventWithExceptionStrategy() throws Exception
    {
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener("sedaFlowCrash", muleContext).setTimeoutInMillis(5000).setNumberOfExecutionsRequired(3);
        // Send 3 messages
        MuleClient client = muleContext.getClient();
        int nrMessages = 3;
        for (int i = 0; i < nrMessages; i++)
        {
            client.dispatch("vm://flow.in", "some data " + i, null);
        }
        flowExecutionListener.waitUntilFlowIsComplete();
        // Receive 2 messages
        for (int i = 0; i < 2; i++)
        {
            MuleMessage result = client.request("vm://flow.out", RECEIVE_TIMEOUT);
            assertNotNull(result);

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener


    private void verifyAppProcessMessageWithAppClassLoader(FakeMuleServer fakeMuleServer, String appName, String requestUrl) throws MuleException
    {
        MuleContext applicationContext = fakeMuleServer.findApplication(appName).getMuleContext();
        final AtomicReference<ClassLoader> executionClassLoader = new AtomicReference<ClassLoader>();
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener(applicationContext);
        flowExecutionListener.addListener(new Callback<MuleEvent>()
        {
            @Override
            public void execute(MuleEvent source)
            {
                executionClassLoader.set(Thread.currentThread().getContextClassLoader());
            }
        });
        applicationContext.getClient().send(String.format(requestUrl, dynamicPort.getNumber()), "test-data", null);
        flowExecutionListener.waitUntilFlowIsComplete();
        assertThat(executionClassLoader.get(), Is.is(applicationContext.getExecutionClassLoader()));
    }

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener

    }


    @Test
    public void testNoException() throws Exception
    {
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener("NoException", muleContext);
        createFileOnFtpServer("noException/test1");
        flowExecutionListener.waitUntilFlowIsComplete();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener

    }


    @Test
    public void testRouterException() throws Exception
    {
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener("RouterException", muleContext);
        createFileOnFtpServer("routerException/test1");
        flowExecutionListener.waitUntilFlowIsComplete();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener

    }


    @Test
    public void testComponentException() throws Exception
    {
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener("ComponentException", muleContext);
        createFileOnFtpServer("componentException/test1");
        flowExecutionListener.waitUntilFlowIsComplete();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener

    }


    @Test
    public void testCatchExceptionStrategyConsumesMessage() throws Exception
    {
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener("CatchExceptionStrategy", muleContext);
        createFileOnFtpServer("exceptionHandled/test1");
        flowExecutionListener.waitUntilFlowIsComplete();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {

View Full Code Here

Examples of org.mule.tck.listener.FlowExecutionListener

    }


    @Test
    public void testDefaultExceptionStrategyConsumesMessage() throws Exception
    {
        FlowExecutionListener flowExecutionListener = new FlowExecutionListener("DefaultExceptionStrategyCommit", muleContext);
        createFileOnFtpServer("commitOnException/test1");
        flowExecutionListener.waitUntilFlowIsComplete();
        prober.check(new Probe()
        {
            @Override
            public boolean isSatisfied()
            {

View Full Code Here

Examples of org.springframework.webflow.execution.FlowExecutionListener

  public void testFlowStateExceptionHandlingTransition() {
    new EndState(flow, "end");
    TransitionExecutingFlowExecutionExceptionHandler handler = new TransitionExecutingFlowExecutionExceptionHandler();
    handler.add(TestException.class, "end");
    flow.getExceptionHandlerSet().add(handler);
    FlowExecutionListener listener = new FlowExecutionListenerAdapter() {
      public void sessionEnding(RequestContext context, FlowSession session, MutableAttributeMap output) {
        assertTrue(context.getFlashScope().contains("flowExecutionException"));
        assertTrue(context.getFlashScope().contains("rootCauseException"));
        assertTrue(context.getFlashScope().get("rootCauseException") instanceof TestException);
      }

View Full Code Here

0 1 2

TOP

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.