Testowanie podprzepływów w Mule

Question

Zacząłem pisać przypadki testowe do mojego projektu Mule.

Napisałem funkcjonalny przypadek testowy dla moich głównych przepływów w następujący sposób.

public void testMainFlow_1() throws Exception{ 
    MuleClient client = muleContext.getClient(); 
      MuleMessage result = client.send(helloServiceAddress, fileAsString("SamplePayloads/input_Request.xml"), properties); 
    assertNotNull("Null Result", result);   
    assertEquals(result.getPayloadAsString(), fileAsString("SampleResponses/sampleResponse.xml")); 

} 

Ale jak mogę przetestować moje pod-przepływy. Nie mają żadnych punktów końcowych. Więc jak mogę przekazać im ładunek i przetestować go.

Podana poniżej jest moja konfiguracja przepływu.

<flow name="main_flow" > 
    .... 
    .... 
    <flow-ref name="subflow_1" /> 
    .... 
    .... 
    <flow-ref name="subflow_2" /> 
    .... 
    .... 
</flow> 

<sub-flow name="subflow_1"> 
    .... 
    <some-transformer ... /> 
    <out-bound call to web-service /> 
    <some-transformer ... /> 
    .... 
</sub-flow> 

<sub-flow name="subflow_2"> 
    .... 
    <some-transformer ... /> 
    <out-bound call to web-service /> 
    <some-transformer ... /> 
    .... 
</sub-flow> 

Answer 1

Stosując FunctionalTestCase powinien być tak prosty, jak:

MessageProcessor subFlow = muleContext.getRegistry().lookupObject("subflow_1"); 
MuleEvent result = subFlow.process(getTestEvent("test_data")); 

ale it doesn't work.

Na razie najlepsze podejście IMO polega na posiadaniu konfiguracji testowej, która zawiera owijacze przepływu dla podstrumów, które chcesz przetestować, i załadowanie tego testu konfiguracji obok głównej konfiguracji w FunctionalTestCase.

@ Podejście genjosanzo działa również, ale opiera się na powiązaniu podstrumienia z wcześniej istniejącym przepływem głównym z samego kodu testu. Osobiście uważam, że bardziej rygorystycznie byłoby tworzyć strumienie testowe.

Answer 2

Wywoływanie subflow od przypadku testu jest dość proste, jest to na przykład:

@Test 
    public void invokeSubFlow() throws Exception { 
     MessageProcessor mp = (MessageProcessor) muleContext.getRegistry() 
       .lookupObject("subflow_2"); 
     FlowConstruct parentFlow = muleContext.getRegistry().lookupFlowConstruct("main_flow"); 
     ((FlowConstructAware) mp).setFlowConstruct(muleContext.getRegistry() 
       .lookupFlowConstruct("subflow_2")); 
     Lifecycle lc = (Lifecycle) mp; 
     lc.initialise(); 
     lc.start(); 
     MuleMessage muleMessage = new DefaultMuleMessage("test", muleContext); 
     MuleEvent event = new DefaultMuleEvent(muleMessage, 
       MessageExchangePattern.REQUEST_RESPONSE, 
       new DefaultMuleSession(parentFlow,muleContext)); 

     mp.process(event); 
    } 

Answer 3

Wykorzystując najnowszą wersję Mule możemy przetestować sub-flow z następującym scenariuszu:

SubflowInterceptingChainLifecycleWrapper subFlow = getSubFlow("subflowName"); 
subFlow.initialise(); 

MuleEvent event = subFlow.process(getTestEvent("")); 
MuleMessage message = event.getMessage(); 

assertEquals(expect, message.getPayload());