骆驼端点嘲笑空指针异常

Question

Iam尝试模拟开关站端点开关站：// TohpGetAccountReports在骆驼中使用模拟端点。在junit测试中定义的mockAccountReportEndpoint返回null，并且测试ID失败，出现nullpointer异常。请告诉我我的代码出了什么问题？

骆驼航线：

<route id="accountReportRoute" streamCache="true"> 
     <from uri="direct:accountReport" /> 
     <doTry> 
      <setProperty propertyName="hpResponse"> 
       <constant>A</constant> 
      </setProperty> 
      <to 
       uri="xslt:xslt/account_reports_manager/create_get_accountreport_request.xslt" /> 

      <log message="GetAccountReports Request : ${body}" logName="esb.hp.InModelProvider.AccountReport" 
       loggingLevel="TRACE" /> 
      <to 
       id="AccountReportEndpoint" uri="switchyard://TohpGetAccountReports?operationName=GetAccountReports" /> 

      <log message="GetAccountReports Response : ${body}" logName="esb.hp.InModelProvider.AccountReport" 
       loggingLevel="TRACE" /> 
      <to 
       uri="xslt:xslt/account_reports_manager/create_get_accountreport_response.xslt" /> 

      <doCatch> 
       <exception>java.lang.Exception</exception> 
       <handled> 
        <constant>false</constant> 
       </handled> 
       <log 
        message="Exception in hp Model provider accountReportRoute ${exception.stacktrace} " 
        logName="esb.hp.InModelProvider.AccountReport" loggingLevel="ERROR" /> 
      </doCatch> 
     </doTry> 
     <log message="Workaround for handling account report soap fault" 
      logName="esb.hp.InModelProvider.AccountReport" loggingLevel="DEBUG" /> 
    </route> 

JUnit测试类

package com.company.esb.hp.in.modelprovider.test;   
import java.util.Map;   
import org.apache.camel.CamelContext; 
import org.apache.camel.EndpointInject; 
import org.apache.camel.Exchange; 
import org.apache.camel.Expression; 
import org.apache.camel.ProducerTemplate; 
import org.apache.camel.builder.AdviceWithRouteBuilder; 
import org.apache.camel.component.mock.MockEndpoint; 
import org.apache.camel.impl.DefaultExchange; 
import org.apache.camel.model.ModelCamelContext; 
import org.apache.log4j.Logger; 
import org.junit.Before; 
import org.junit.Test; 
import org.junit.runner.RunWith; 
import org.switchyard.ServiceDomain; 
import org.switchyard.component.test.mixins.cdi.CDIMixIn; 
import org.switchyard.component.test.mixins.http.HTTPMixIn; 
import org.switchyard.test.BeforeDeploy; 
import org.switchyard.test.Invoker; 
import org.switchyard.test.ServiceOperation; 
import org.switchyard.test.SwitchYardRunner; 
import org.switchyard.test.SwitchYardTestCaseConfig; 
import org.switchyard.test.SwitchYardTestKit; 
import org.switchyard.transform.config.model.TransfohpwitchYardScanner; 

import com.company.esb.common.test.esbSwitchyardTest; 
import com.company.esb.hp.in.modelprovider.test.util.RiskInProviderUtil; 

@SwitchYardTestCaseConfig(config = SwitchYardTestCaseConfig.SWITCHYARD_XML, mixins = { 
     CDIMixIn.class, HTTPMixIn.class }, scanners = { TransfohpwitchYardScanner.class }) 
@RunWith(SwitchYardRunner.class) 
public class hpInModelProviderTest extends esbSwitchyardTest { 
    private static final Logger LOG = Logger 
      .getLogger(hpInModelProviderTest.class); 
    private SwitchYardTestKit testKit; 

    public static final String getAcctResult = "TohpGetAccountReports"; 

    @EndpointInject(uri = "mock://switchyard:TohpGetAccountReports*") 
    protected MockEndpoint mockAccountReportEndpoint; 



    @BeforeDeploy 
    public void setProperties() { 
     System.setProperty("esb.hp.inmodelprovider.url", "http://pusslasrws1451.company.biz"); 

    } 

    @Before 
    public void installServices() { 
     simulateesbServices(testKit); 
    } 

    @Test 
    public void testAccountReportDirectRouteSuccess() throws Exception { 
     String request = readFile("xml/endtoend/success/GetJobsResults/get_job_status-response.xml"); 
     ServiceDomain domain = testKit.getServiceDomain(); 
     //testKit.removeService(getAcctResult); 
     //testKit.registerInOutService(getAcctResult, 
      // new GetAccountReportsServiceMockExchangeHandler()); 
     CamelContext ctx = (CamelContext) domain 
       .getProperty("CamelContextProperty"); 
     Exchange ex = new DefaultExchange(ctx); 
     ModelCamelContext modelContext = (ModelCamelContext) ctx; 
     modelContext.getRouteDefinition("accountReportRoute").adviceWith(modelContext, new AdviceWithRouteBuilder() { 
      @Override 
      public void configure() throws Exception { 

       weaveById("AccountReportEndpoint").replace().to(mockAccountReportEndpoint); 
      } 
     }); 
     mockAccountReportEndpoint.expectedMessageCount(1); 
     mockAccountReportEndpoint.returnReplyBody(new Expression() { 
      @Override 
      public <T> T evaluate(Exchange exchange, Class<T> type) { 
       return exchange.getContext().getTypeConverter().convertTo(type, RiskInProviderUtil.readFile("xml/endtoend/success/GetJobsResults/get_account_report_service-response.xml")); 
      } 
     }); 

     // MockEndpoint endpoint = getMockEndpoint("mock:switchyard:service"); 
     ex.setProperty("sToken", "f3669d3a-5a2b-4b99-a8df-3aabfd4aae58"); 
     ex.setProperty("sAccId", "196497"); 
     ex.getIn().setBody(request); 
     ProducerTemplate producer = ctx.createProducerTemplate(); 
     producer.send("direct:accountReport", ex); 
     System.out.println(ex.getIn().getBody(String.class)); 
    } 

    @Override 
    protected void addSetupProperties(Map<String, String> map) { 

    } 

} 

Answer 1

..after你已经完成了adviceWith必须启动通过调用上下文实例的启动方法CamelContext。

http://camel.apache.org/advicewith.html#AdviceWith-UsingisUseAdviceWith()

尝试重写isUseAdviceWith()方法（应该返回true），并启动环境下，你已经完成了adviceWith后。如果它已经开始，那么试试stop() it和start()它再次（冷启动）。