我如何将Java Hashmap传递给自定义m子连接器



现在,连接器代码看起来像这样:

// myConnector class
/**
 * Process item
 *
 * {@sample.xml ../../../doc/my-connector.xml.sample myConnector:process}
 *
 * @param binary
 *          the item to process
 * @param stuff
 *          key value pairs for processing
 *
 * @return the status as a string
 *
 * @throws NullPointerException
 *          when one of the parameters are null
 */
@Processor
public String process (  @Payload final byte[] binary,
                        final HashMap<String,String> stuff)
        throws NullPointerException {...}

// myConnector.sample
<!-- BEGIN_INCLUDE(myConnector:process) -->
    <myConnector:process>
            <myConnector:stuff>
                <item1>data1</item1>
                <item2>data2</item2>
            </myConnector:stuff>
    </myConnector:process>
<!-- END_INCLUDE(myConnector:process) —>

我在mule流中的会话标题中存储了一个hashmap(#[标题:session:myhashmap]),但我不知道如何将其发送到连接器。

---更新---

如果我更改连接器示例和连接器元素以匹配我在建立连接器时会出现错误。

// myConnector.sample
<!-- BEGIN_INCLUDE(myConnector:process) -->
    <myConnector:process stuff="#[stuff]"/>
<!-- END_INCLUDE(myConnector:process) —>
// my mule flow
<flow>
    <myConnector:process stuff="#[sessionVars.myHashMap]"/>
</flow>
// the error
[ERROR] Error validating example: cvc-complex-type.3.2.2: Attribute 'stuff' is not allowed to appear in element 'myConnector:process'. Failing example: <myConnector:process stuff="#[stuff]"/>
[ERROR] error on execute: An error ocurred while the DevKit was generating Java code. Check the logs for further details.

at:

<myConnector:process>
  <myConnector:stuff ref="#[sessionVars['myHashMap']]" />
</myConnector:process>

相关内容

  • 没有找到相关文章

最新更新