Munit Mocking DB-Connector

Question

Ich versuche, einen Integrationstest für einen Mule-Flow zu schreiben, der eine Datei aus einer JMS-Warteschlange abruft und sie in eine DB einfügt. Ein Testszenario durchläuft den Ausnahmefluss, wenn die DB nicht verfügbar ist (Verbindungsfehler). Für diesen Test möchte ich den DB-Connector verspotten und eine Ausnahme auslösen lassen.

Ich habe versucht, den Stecker so zu verhöhnen:

@Test 
public void testDBOutageException() throws Exception { 
    MuleEvent event = testEvent(INPUT_VALID_XML); 

    java.net.ConnectException connectException = new java.net.ConnectException("Could not connect to DB!");  
    MessageProcessorMocker dbMocker = whenMessageProcessor("insert").ofNamespace("db");  
    dbMocker.thenThrow(connectException); 

    event = runFlow("thomson-reuters-processFlow", event); 
} 

Bei der Ausführung der Testfall über dem Fluss ist erfolgreich, aber die DB-Anschluss lässt sich nicht spotten genannt. Es ruft nur die DB auf und fügt Daten ein. Das möchte ich nicht erreichen.

Mein Flow sieht wie folgt aus:

<?xml version="1.0" encoding="UTF-8" ?> 
<mule xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:jdbc-ee="http://www.mulesoft.org/schema/mule/ee/jdbc" xmlns:jdbc="http://www.mulesoft.org/schema/mule/jdbc" xmlns:db="http://www.mulesoft.org/schema/mule/db" xmlns:jms="http://www.mulesoft.org/schema/mule/jms" 
xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/ee/jdbc http://www.mulesoft.org/schema/mule/ee/jdbc/current/mule-jdbc-ee.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/db http://www.mulesoft.org/schema/mule/db/current/mule-db.xsd 
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-current.xsd 
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd 
http://www.mulesoft.org/schema/mule/xml http://www.mulesoft.org/schema/mule/xml/current/mule-xml.xsd 
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd"> 
    <context:property-placeholder location="classpath:thomson-reuters-process.properties, classpath:thomson-reuters-process-${env}.properties"></context:property-placeholder> 

    <spring:beans> 
    <spring:bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> 
     <spring:property name="url" value="${JDBC.url}"></spring:property> 
     <spring:property name="username" value="${JDBC.username}"></spring:property> 
     <spring:property name="password" value="${JDBC.password}"></spring:property> 
     <spring:property name="driverClassName" value="${JDBC.driver}"></spring:property> 
     <spring:property name="initialSize" value="5"></spring:property> 
     <spring:property name="testOnBorrow" value="true"></spring:property> 
     <spring:property name="validationQuery" value="${JDBC.validationQuery}"></spring:property> 
     <spring:property name="maxWait" value="60000"></spring:property> 
     <spring:property name="maxActive" value="50"></spring:property> 
     <spring:property name="removeAbandoned" value="true"></spring:property> 
     <spring:property name="removeAbandonedTimeout" value="300"></spring:property> 
     <spring:property name="logAbandoned" value="true"></spring:property> 
    </spring:bean> 
    </spring:beans> 

    <jms:activemq-connector name="Active_MQ" username="${JMS.User}" password="${JMS.Password}" brokerURL="tcp://${JMS.Host}:${JMS.Port}" validateConnections="true" doc:name="Active MQ"> 
    <reconnect frequency="10000" count="10" /> 
    </jms:activemq-connector> 
    <!-- <db:mysql-config name="MySQL_Configuration" doc:name="MySQL Configuration" 
     database="${DB.Database}" host="${DB.Host}" password="${DB.Password}" port="${DB.Port}" 
     user="${DB.User}"></db:mysql-config> --> 
    <db:generic-config name="DB_Config" dataSource-ref="dataSource" doc:name="DB_Config" /> 
    <flow name="thomson-reuters-processFlow"> 
    <jms:inbound-endpoint queue="${JMS.InQueue}" connector-ref="Active_MQ" doc:name="Retrieve from ActiveMQ JMS"></jms:inbound-endpoint> 
    <set-variable variableName="inboundPayload" value="#[payload]" doc:name="Store inboundPayload"></set-variable> 
    <!-- <logger level="INFO" doc:name="Logger"></logger> <mulexml:schema-validation-filter 
      schemaLocations="test-XSD-schema.xsd" returnResult="true" doc:name="Schema 
      Validation"></mulexml:schema-validation-filter> <logger level="INFO" doc:name="Logger"></logger> --> 
    <logger message="LOGGER 1: Inbound file from JMS, payload is: #[message.payloadAs(String)]" level="INFO" doc:name="Logger"></logger> 
    <splitter expression="#[xpath3('/Report/Data/Row[position()&gt;1]',payload,'NODESET')]" doc:name="Split XML to currency dataset"></splitter> 
    <logger message="LOGGER 2: XML was split to forex data set" level="INFO" doc:name="Logger"></logger> 
    <mulexml:dom-to-xml-transformer doc:name="DOM to XML"></mulexml:dom-to-xml-transformer> 
    <collection-aggregator failOnTimeout="true" doc:name="Build collection of individual currency rates"> 
     <expression-message-info-mapping messageIdExpression="#[message.id]" correlationIdExpression="#[message.correlationId]" /> 
    </collection-aggregator> 
    <logger message="LOGGER 3: Combined forex data in collection" level="INFO" doc:name="Logger"></logger> 
    <db:insert config-ref="DB_Config" bulkMode="true" doc:name="Push xml collection to DB" doc:description="dbConnectorInsert"> 
     <db:dynamic-query> 
     <![CDATA[INSERT INTO `exchange_rates`(`CURRENCY`, `DATE`, `REF_CURRENCY`, `EXCHANGE_RATE`,`CREATED_BY`,`CREATE_DATE`,`CHANGED_BY`,`CHANGE_DATE`,`BUYING_RATE`,`SPECIAL_RATE`) VALUES ('#[xpath3('//CURRENCY')]','#[xpath3('//DATE')]','#[xpath3('//REF_CURRENCY')]','#[xpath3('//EXCHANGE_RATE')]','${System.User}','#[server.dateTime.format('yyyy-MM-dd HH:mm:ss')]', '${System.User}','#[server.dateTime.format('yyyy-MM-dd HH:mm:ss')]','#[xpath3('//BUYING_RATE')]','#[xpath3('//SELLING_RATE')]');]]> 
     </db:dynamic-query> 
    </db:insert> 
    <logger message="LOGGER 4: DB Processing completed, payload is: #[message.payloadAs(String)]" level="INFO" doc:name="Logger"></logger> 
    <catch-exception-strategy doc:name="thomson-reuters-processCatch_Exception_Strategy"> 
     <logger level="INFO" doc:name="Logger"></logger> 
     <set-payload value="#[flowVars.inboundPayload]" doc:name="Set Original Inbound Payload"></set-payload> 
     <message-properties-transformer doc:name="Remove MULE_CORRELATION_ID"> 
     <delete-message-property key="MULE_CORRELATION_ID" /> 
     </message-properties-transformer> 
     <logger message="Exception occured, trying to push message to DLQ, payload is: #[message.payloadAs(String)]" level="INFO" doc:name="Logger"></logger> 
     <jms:outbound-endpoint queue="${JMS.DLQ}" connector-ref="Active_MQ" doc:name="Place on DLQ"></jms:outbound-endpoint> 
    </catch-exception-strategy> 
    </flow> 
</mule> 

Irgendwelche Ideen, diese Arbeit zu machen?

Answer 1

Es gab einen Fehler in MUnit 1.1.0, wo DB Mock nicht funktionierte. Es wurde in MUnit 1.2.0 Version behoben, die vor kurzem veröffentlicht wurde, versuchen Sie 1.2.0. Welche Version von MUnit verwenden Sie?