我尝试为pollEnrich模拟端点,但没有成功。使用adviceWith进行模拟对.to("")
和.enrich("")
运行良好,但对于pollEnrich,我遇到了错误:
如果您的计算机出现异常,请单击“下一步”。连接到本地主机:8983*
我不明白为什么adviceWith
不适合pollEnrich
这是一段嘲弄的代码:
public class PollEnricherRefTest extends CamelTestSupport {
public class SampleMockRoute extends RouteBuilder {
public void configure() throws Exception {
System.out.println("configure");
from("direct:sampleInput")
.log("Received Message is ${body} and Headers are ${headers}")
//.to("http4://localhost:8983/test")
.pollEnrich("http4://localhost:8983/test", (exchange1, exchange2) -> {
return exchange1;
})
.log("after enrich ${body} ")
.to("mock:output");
}
}
@Override
public boolean isUseAdviceWith() {
return true;
}
@BeforeEach
public void beforeAll() throws Exception {
AdviceWithRouteBuilder mockHttp4 = new AdviceWithRouteBuilder() {
@Override
public void configure() throws Exception {
interceptSendToEndpoint("http4://localhost:8983/test")
.log("call MOCK HTTP").skipSendToOriginalEndpoint();
}
};
context = new DefaultCamelContext();
context.addRoutes(new SampleMockRoute());
context.getRouteDefinitions().get(0).adviceWith(context, mockHttp4);
template = context.createProducerTemplate();
}
@Test
public void sampleMockTest() throws InterruptedException {
try {
context.start();
String expected = "Hello";
MockEndpoint mock = getMockEndpoint("mock:output");
mock.expectedBodiesReceived(expected);
String input = "Hello";
template.sendBody("direct:sampleInput", input);
mock.assertIsSatisfied();
context.stop();
} catch (Exception e) {
e.printStackTrace();
}
}
}
3条答案
按热度按时间uxh89sit1#
您可以尝试在configure()中使用weavyByType。唯一的问题是它会将该路由中的所有pollEnrich模式替换为下面的mock url。如果您的路由中只有一个pollEnrich,这应该可以满足您的目的。
weaveById("myPollEnrichId").replace().to("mock:mock-url");
您也可以尝试在您的路由中为该特定pollEnrich设置一个id,如下所示。
完成后,您就可以使用weavyById来模拟特定的pollEnrich。
weaveById("myPollEnrichId").replace().to("mock:mock-url");
个xqkwcwgp2#
对于遇到被替换的路由不调用聚合策略这一问题的任何人:您可以将
weaveById
与pollEnrich
一起使用,但您还需要添加AggregationStrategy参数(请参见下文),否则它将不会调用该参数,因为它会将原始的pollEnrich
替换为不包含该参数的另一个pollEnrich
。首先:在
configure
方法中为原始pollEnrich
添加一个id:第二:在测试中,使用
weaveById
将其发送到一个设置了聚合策略的模拟路由:如果您需要在路由中测试实际的聚合策略,最好的方法是为它创建一个单独的类,并在测试中重用它。
avkwfej43#
您可以使用weaveBy替换pollEnrich ...有各种变体 weaveByType、weaveById 等。
如果您使用 weaveByType,并且您的路线中有多个PollEnrich,您可以使用 selectFirst()、selectLast() 等选择。
替换可以由另一个端点完成,例如模拟端点,但出于测试目的,我发现使用处理器并直接设置所需的交换内容很方便,或者在需要时保持不变。
下面是camel 3.5的代码示例