FUSE camel+KIE执行服务器集成POC

Question

公共无效populateRestHeader（交换交换）{

// hard code the message for time being because   BatchExecutionHelperd doesn't work. please see below. 

String myMessage=“ ”+“ john”+“51 ”+“；

// setup the login token
 exchange.getIn().setHeader("Authorization", basicToken);
// POST so I can send XML.  GET works fine !
 exchange.getIn().setHeader(Exchange.HTTP_METHOD, "POST");
// the content
 exchange.getIn().setHeader(Exchange.ACCEPT_CONTENT_TYPE, "application/xml");
 exchange.getIn().setBody(myMessage);

}

在KIE服务器日志中，我得到：

15:19:33,140 WARN[org.jboss.resteasy.core.exceptionHandler]（默认任务-114）执行失败:javax.ws.rs.notsupportedException：无法在org.jboss.resteasy.core.registry.segmentnode.match（segmentnode.java(380)[resteasy-jaxrs-3.0.10.final.jar:]上使用内容类型。jboss.resteasy.core.registry.segmentnode.match（segmentnode.java:114)

“内容类型”没有正确设置，或者正文没有发送？

收到：

<?xml version="1.0" encoding="UTF-8" standalone="yes"?><response type="SUCCESS" msg="Info for container myCheese"><kie-container container-id="myCheese" status="STARTED"><release-id><artifact-id>mycheese</artifact-id><group-id>com.markit</group-id><version>1.0</version></release-id><resolved-release-id><artifact-id>mycheese</artifact-id><group-id>com.markit</group-id><version>1.0</version></resolved-release-id><scanner status="DISPOSED"/></kie-container></response>

<response type="SUCCESS" msg="Container myCheese successfully called.">
<results><![CDATA[<execution-results>
  <result identifier="person">
    <org.drools.camel.example.Person>
      <name>john</name>
      <age>51</age>
      <canDrink>true</canDrink>
      <alive>false</alive>
      <sex></sex>
      <happy>false</happy>
    </org.drools.camel.example.Person>
  </result>
  <fact-handle identifier="person" external-form="0:1:866416565:866416565:1:DEFAULT:NON_TRAIT"/>
</execution-results>]]></results>
</response>

问题：

a）知道为什么会出现错误吗？将exchange.body设置为POST的数据是否正确？b）不使用come-jetty将命令发送到Kie-Server，因为Kie-Server将其声明为REST，我可以使用CXFRS来完成此操作吗？此外，我相信Kie-Server也支持SOAP，但它的WSDL是什么？另一个替代方案是什么？

public String createCommand() {
    BatchExecutionCommandImpl command = new BatchExecutionCommandImpl();
    final List<GenericCommand<?>> commands = command.getCommands();
   
    Person person = createTestPerson();

    commands.add(new InsertObjectCommand(person, "myPerson"));
    commands.add(new FireAllRulesCommand());
    command.setLookup("ksession1");

    String myXMLMessage =     BatchExecutionHelper.newXStreamMarshaller().toXML(command);
    return myXMLMessage;
}

但我在保险丝日志中发现了异常：

Caused by: java.lang.ClassNotFoundException: org.drools.core.runtime.help.impl.BatchExecutionHelperProviderImpl not found by org.kie.internalapi [281]
  at org.apache.felix.framework.BundleWiringImpl.findClassOrResourceByDelegation(BundleWiringImpl.java:1556)
  at org.apache.felix.framework.BundleWiringImpl.access$400(BundleWiringImpl.java:77)
  at org.apache.felix.framework.BundleWiringImpl$BundleClassLoader.loadClass(BundleWiringImpl.java:1993)

似乎KIE内部包无法访问Drools核心包？

Answer 1

啊。得到了一半的答案。我需要设置

exchange.contenttype=“application/xml”！

现在可以在Fuse服务器和远程KIE服务器之间很好地工作。但是，BatchExecutionHelper异常仍然存在问题。