Testen von Sub-Flows in Mule

Question

Ich habe angefangen, Testfälle zu meinem Mule-Projekt zu schreiben.

Ich habe den funktionalen Testfall für meine Main Flows wie folgt geschrieben.

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")); 

} 

Aber wie kann ich meine Teilströme testen. Sie haben keine Endpunkte. Wie kann ich Nutzlast an sie weitergeben und sie testen?

Nachstehend ist meine Flusskonfiguration.

<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

die FunctionalTestCase Verwendung sollte es so einfach sein wie:

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

aber it doesn't work.

Im Moment besteht der beste Ansatz IMO darin, eine Testkonfiguration zu haben, die Flow Wrapper für die Teilflüsse enthält, die Sie testen und diese Testkonfiguration zusammen mit Ihrer Hauptkonfiguration im FunctionalTestCase laden möchten.

@ genjosanzos Ansatz funktioniert auch, aber er basiert auf der Zuordnung des Sub-Flows zu einem bereits existierenden Haupt-Flow aus dem Test-Code selbst. Ich persönlich denke, es wäre strikter, stattdessen Testabläufe zu erstellen.

Answer 2

eine Subflow von einem Testfall Aufruf ist ziemlich einfach, dies ist ein Beispiel:

@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

Durch die neueste Mule-Version verwenden, können wir Teilstrom mit dem folgenden Skript testen:

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

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

assertEquals(expect, message.getPayload());