mule - 在 mule 中的流之间读取 mule 中的数据库

Question

我在与 MULE 一起探索的第二周。我的要求是根据来自 http 端点的输入读取数据库或读取文件。我试图在流程中使用 CHOICE 并确定输入的性质，然后以不同的方向流出。但我的问题是我不确定如何使用查询值或文件值设置消息。

任何人都可以帮助我输入一些信息吗？

Answer 1

请查看此模块

https://github.com/mulesoft/mule-requester-module

它可以在流中的任何点请求资源。它用于最初仅由消息源请求的资源。

用例是：

• 在流程中间加载文件
• 使用流中间队列中的消息（一条、N 条、全部）。
• 按需从邮件服务器中提取消息，例如在扩充器中使用其数据。

它是围绕典型muleContext.getClient()调用的简单 devkit 包装器

public Object request(String resource, @Optional @Default("1000") long timeout, @Optional String returnClass, @Optional Boolean throwExceptionOnTimeout) throws MuleException {
        MuleMessage message = muleContext.getClient().request(resource, timeout);
        Object result = null;
        if (message != null)
        {
            result = message.getPayload();
            if (returnClass != null)
            {
                try {
                    Transformer transformer = muleContext.getRegistry().lookupTransformer(DataTypeFactory.create(result.getClass()), DataTypeFactory.create(Class.forName(returnClass)));
                    result = transformer.transform(result);
                } catch (ClassNotFoundException e) {
                    throw new DefaultMuleException(e);
                }
            }
        } else if (Boolean.TRUE.equals(throwExceptionOnTimeout))
        {
            throw new DefaultMuleException("No message received in the configured timeout - " + timeout);
        }
        return result;
    }