/*
* Copyright (c) MuleSoft, Inc. All rights reserved. http://www.mulesoft.com
* The software in this package is published under the terms of the CPAL v1.0
* license, a copy of which has been included with this distribution in the
* LICENSE.txt file.
*/
package org.mule.transport.vm.functional.transactions;
import static org.hamcrest.core.IsNull.notNullValue;
import static org.hamcrest.core.IsNull.nullValue;
import static org.junit.Assert.assertThat;
import static org.junit.Assert.fail;
import org.mule.api.MuleEvent;
import org.mule.api.MuleException;
import org.mule.api.MuleMessage;
import org.mule.api.transaction.TransactionException;
import org.mule.api.transport.DispatchException;
import org.mule.construct.Flow;
import org.mule.tck.junit4.FunctionalTestCase;
import org.hamcrest.core.Is;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
public class VmSingleTransactionTransactionalElementTestCase extends FunctionalTestCase
{
@Override
protected String getConfigFile()
{
return "vm/vm-single-tx-transactional.xml";
}
@Before
public void setUpTest() throws MuleException
{
purge("vm://out1?connector=vmConnector1");
purge("vm://out2?connector=vmConnector1");
purge("vm://out3?connector=vmConnector1");
}
private void purge(String endpoint) throws MuleException
{
while (muleContext.getClient().request(endpoint,10) != null);
}
@Test
public void testTransactional() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactional");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
@Test
public void testTransactionalFailInTheMiddle() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalFailInTheMiddle");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
} catch (Exception e)
{
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, nullValue());
assertThat(message2, nullValue());
}
@Test
public void testTransactionalFailAtEnd() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalFailAtEnd");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
} catch (Exception e)
{
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, nullValue());
assertThat(message2, nullValue());
}
@Test
public void testTransactionalFailAfterEnd() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalFailAfterEnd");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
} catch (Exception e)
{
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
@Test
public void testTransactionalFailInTheMiddleWithCatchExceptionStrategy() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalFailInTheMiddleWithCatchExceptionStrategy");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, nullValue());
}
@Test
public void testTransactionalFailAtEndWithCatchExceptionStrategy() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalFailAtEndWithCatchExceptionStrategy");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
@Test
@Ignore
public void testTransactionalWorksWithAnotherResourceType() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalWorksWithAnotherResourceType");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
fail("DispatchException should be thrown");
} catch (DispatchException e)
{
assertThat(e.getCause() instanceof TransactionException, Is.is(true));
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, nullValue());
assertThat(message2, nullValue());
}
@Test
public void testTransactionalDoesntFailWithAnotherResourceType() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalDoesntFailWithAnotherResourceType");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
MuleMessage message3 = muleContext.getClient().request("vm://out3?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
assertThat(message3, notNullValue());
}
@Test
public void testTransactionalWithAnotherResourceTypeAndExceptionAtEnd() throws Exception
{
Flow flow = (Flow) getFlowConstruct("transactionalWithAnotherResourceTypeAndExceptionAtEnd");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
} catch (Exception e)
{
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
MuleMessage message3 = muleContext.getClient().request("vm://out3?connector=vmConnector1", 1000);
assertThat(message1, nullValue());
assertThat(message2, nullValue());
assertThat(message3, notNullValue());
}
@Test
public void testNestedTransactional() throws Exception
{
Flow flow = (Flow) getFlowConstruct("nestedTransactional");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
@Test
public void testNestedTransactionalFail() throws Exception
{
Flow flow = (Flow) getFlowConstruct("nestedTransactionalFail");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
} catch (Exception e)
{
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, nullValue());
}
@Test
public void testNestedTransactionalFailWithCatch() throws Exception
{
Flow flow = (Flow) getFlowConstruct("nestedTransactionalFailWithCatch");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
@Test
public void testNestedTransactionalWithBeginOrJoin() throws Exception
{
Flow flow = (Flow) getFlowConstruct("nestedTransactionalWithBeginOrJoin");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
@Test
public void testNestedTransactionalWithBeginOrJoinFail() throws Exception
{
Flow flow = (Flow) getFlowConstruct("nestedTransactionalWithBeginOrJoinFail");
MuleEvent event = getTestEvent("message", flow);
try
{
flow.process(event);
} catch (Exception e)
{
}
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, nullValue());
assertThat(message2, nullValue());
}
@Test
public void testNestedTransactionalWithBeginOrJoinFailWithCatch() throws Exception
{
Flow flow = (Flow) getFlowConstruct("nestedTransactionalWithBeginOrJoinFailWithCatch");
MuleEvent event = getTestEvent("message", flow);
flow.process(event);
MuleMessage message1 = muleContext.getClient().request("vm://out1?connector=vmConnector1", 1000);
MuleMessage message2 = muleContext.getClient().request("vm://out2?connector=vmConnector1", 1000);
assertThat(message1, notNullValue());
assertThat(message2, notNullValue());
}
}