Хорошо, спасибо за совет, ребята. Я укусил пулю и сделал все правильно, вместо того, чтобы анализировать регулярное выражение. Вот мое решение:
Я создал сервис, который использует org.codehaus.jackson.map.ObjectMapper. Этот класс принимает тело обмена в качестве аргумента. Похоже на это.
public class ProviderTypeWrangler {
public String getProvider(String json) {
try {
ObjectMapper mapper = new ObjectMapper();
Integration integration;
integration = mapper.readValue(json, Integration.class);
return integration.getProvider();
} catch (JsonParseException e) {
return "";
} catch (JsonMappingException e) {
return "";
} catch (IOException e) {
return "";
}
}
}
Затем я использовал шаблон маршрутной квитанции , чтобы обеспечить доступ к этой услуге. Если кто-то сочтет целесообразным другой EIP, я буду открыт для предложений. Во всяком случае, вот пример этого.
public class WufooIntegrationRoutingSlip {
@RoutingSlip
public String slip(String body) {
String answer = "activemq:noProducerDefined";
ProviderTypeWrangler wrangler = new ProviderTypeWrangler();
String producer = wrangler.getProvider(body);
Logger mylogger = Logger.getLogger("log4j.logger.org.apache.camel");
if (!producer.equals("")) {
mylogger.info("Body:"+body);
answer = "activemq:"+producer;
}
return answer;
}
}
Затем в своем файле camel.xml я представил этот бланк маршрутизации как бин
<bean id="integrationBean" class="com.wufoo.camel.WufooIntegrationRoutingSlip"/>
И я использовал этот компонент для направления обмена в правильную очередь.
<route errorHandlerRef="dlc" autoStartup="true" id="IntegrationQueue" xmlns:ns2="http://camel.apache.org/schema/web" xmlns="http://camel.apache.org/schema/spring">
<description>Send all integrations here. Logic will parse to individual queue based on Provider.</description>
<from uri="activemq:integration"/>
<bean ref="integrationBean"/>
</route>
Я многое узнал о верблюде и весне по пути, поэтому спасибо комментаторам за то, что подтолкнул меня в правильном направлении.