org.mule.api.context.WorkManager.execute()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-27 16:27:05 27 4

@Override
  public void onThrowable(final Throwable t)
  {
    workManager.execute(new Runnable()
    {
      @Override
      public void run()
      {
        completionHandler.onFailure((Exception) t);
      }
    });
  }
}

@Override
public Response onCompleted(final Response response) throws Exception
{
  workManager.execute(new Runnable()
  {
    @Override
    public void run()
    {
      try
      {
        completionHandler.onCompletion(createMuleResponse(response, response.getResponseBodyAsStream()));
      }
      catch (IOException e)
      {
        completionHandler.onFailure(e);
      }
    }
  });
  return null;
}

public void onThrowable(final Throwable t)
{
  try
  {
    closeOut();
  }
  catch (IOException e)
  {
    // ignore
  }
  if (!handled.getAndSet(true))
  {
    workManager.execute(new Runnable()
    {
      @Override
      public void run()
      {
        completionHandler.onFailure((Exception) t);
      }
    });
  }
}

private void handleIfNecessary()
  {
    if (!handled.getAndSet(true))
    {
      response = responseBuilder.build();
      workManager.execute(new Runnable()
      {
        @Override
        public void run()
        {
          try
          {
            completionHandler.onCompletion(createMuleResponse(response, input));
          }
          catch (IOException e)
          {
            completionHandler.onFailure(e);
          }
        }
      });
    }
  }
}

@Override
public void execute(final Runnable runnable)
{
  try
  {
    workTracker.addWork(runnable);
    delegateHolder.getWorkManager().execute(new TrackeableRunnable(runnable));
  }
  catch (RuntimeException e)
  {
    workTracker.removeWork(runnable);
    throw e;
  }
}

27 4 0

• dji-sdk - 大疆错误: Execution could not be executed

  有时我一直在努力理解为什么在尝试创建航路点任务时任务管理器会收到错误“无法执行执行”。我附上了我正在使用的工作流程，如果您能看一下，我将不胜感激。 1.Initialize FlightControl

• python - SQLAlchemy核心engine.execute()与connection.execute()

  我正在 Python 中使用 SQLAlchemy 核心，并且我已多次阅读文档，但仍然需要有关 engine.execute() 的说明。与 connection.execute() . 据我了解，e

• php - Zend : Execute something before a controller is executed

  在我的 Zend 框架项目中，我想检查是否设置了 cookie。如果是这种情况，我想使用 cookie 内容登录用户。 由于我必须在调用任何 Controller 之前执行此自动登录，因此我尝试将其放

• MySQL : UNION is not getting executed when executed as a view

  我正在尝试为我创建的 2 个选择语句的 UNION 创建一个 View 。 UNION 在单独执行时工作正常 但问题是当我将它作为 View 执行时，只有 UNION 的第一部分被执行。 我正在使用的

• C++ | Q : cygwin exception when executing the executable |

  下面我写了一个简单的例子来演示我遇到的问题。执行代码后，我得到一个 cygwin 异常 7200。我环顾四周并尝试了一些事情，但没有解决。有人可以解释为什么我得到它，我该如何解决？感谢您抽出宝贵时间，

• python - 异步 Pool.execute 与 Connection.execute

  从池中获取连接然后在连接上调用 execute 而不是直接在池对象上调用 execute 的用例是什么？ 在 Pool 的文档中类，显示此示例: con = await pool.acquire()

• ms-access - Currentdb.Execute (Database.Execute) 不工作或抛出错误

  我正在尝试通过 SQL 将变量中的 2 个值插入表中，代码完成时没有错误，但条目未显示在表中。 我尝试在即时窗口中执行代码，但这给了我一个关于括号的错误(我真的不知道如何在那里正确输入提示)，所以我将

• 安卓广播接收器 : Can they execute simultaneously or do they always execute consecutively?

  我对广播接收器有点困惑。我有一个广播接收器，它在 TIME_SET 和 TIMEZONE_CHANGED 操作时触发(代码在下面给出)。我想知道的是，当 TIME_SET 和 TIMEZONE_CHA

• java - 在 RestTemplate 拦截器中调用 execution.execute() 两次

  我必须与需要随每个请求发送访问 token 的外部服务集成。访问 token 的到期时间很短(只有几个小时)。我决定以乐观的方式使用访问 token 。我将使用当前 token 调用外部服务。如果出现

• iOS swift : order of code execution/asynchronous execution

  如果我在 swift 中运行以下代码，步骤 1.、2.、3. 和 4. 是否始终按此顺序执行(它们应该如此)，或者如果循环存在异步执行的风险，排序等，花费的时间比预期的要长？ // 1. fo

• c++ - "Attempt to execute non-executable address"是什么意思？

  我在我的 C++ 应用程序中看到访问冲突错误。在发生违规并使用 !analyze 时将 windbg 附加到进程时，我发现访问违规是由于试图执行不可执行的地址。我知道导致此问题的正在执行的地址。什么可

• ubuntu - 查看 Linux "executable (application/x-executable)"文件的源代码？

  在使用 Ubuntu 大约一年之后，这对我来说是第一次。 我接手了一个跟踪维修的汽车服务项目。我可以看到每个文件的完整源代码，但是有一个没有扩展名的文件，但在 Ubuntu 中，属性显示为可执行文件(

• LinqPad "Auto Track Execution"和 "Jump to Execution Point"？

  什么是 LinqPad“自动跟踪执行”和“跳转到执行点”？如何使用它们，如果你能给出一个详细的例子将不胜感激。 最佳答案 这不是一个详细的示例，但它说明了该功能。如果你有一个像 "1".Dump()

• javascript - promise : How to execute async methods in parallel then execute method

  我使用 Q.js 来实现 promise 。在下面的代码中，每个方法都会进行 ajax 调用，然后返回一个 Promise。一切都按预期进行，每个方法在下一个方法开始之前执行并完成: function

• java - ExecutorService 和 Lambdas - .execute(() -> ...) 和 .execute() 之间的区别

  我有一个类，它实现了 Runnable接口(interface)，并且是一个一旦启动就会无限期运行的任务(长时间运行的线程)。 public class LongRunningTask impleme

• php - PDOStatement::execute() [pdostatement.execute]: SQLSTATE[HY093]: 无效

  PDOStatement::execute() [pdostatement.execute]: SQLSTATE[HY093]: 无效的参数数量:绑定(bind)变量的数量与标记数量不匹配 我收到此错

• python - 'builtin_function_or_method' 对象没有 cursor.execute(statement) 的属性 'execute'

  关闭。这个问题是not reproducible or was caused by typos .它目前不接受答案。 这个问题是由于错别字或无法再重现的问题引起的。虽然类似的问题可能是on-topi

• linux - 看点 : "execution time" on the every linux command executed

  想要为执行的每个 linux 命令添加 aspect:executionTime 有什么方法可以添加默认方面环境，以便必须为执行的 linux 命令获取 executionTime 最佳答案 根据 m

• linux - "executable: command not found"虽然"make executable"成功了

  我正在尝试安装一个名为 MFOC 的工具.我按照其网站中提到的说明进行操作，如下所示: ebrahim@ubuntu:~$ cd Desktop/mfoc-master/ ebrahim@ubuntu

• python - 数巴 : difference between first time execution and following executions

  我刚开始使用 numba 来提高我的程序的性能。我已经减少了我将要呈现的情况 import numba as nb import numpy as np from time import time d