Function TEST_F

bolt/exec/tests/ExchangeClientTest.cpp:153–174

};

TEST_F(ExchangeClientTest, nonBoltCreateExchangeSourceException) {
  ExchangeSource::registerFactory(
      [](const auto& taskId, auto destination, auto queue, auto pool)
          -> std::shared_ptr<ExchangeSource> {
        throw std::runtime_error("Testing error");
      });

  auto client = std::make_shared<ExchangeClient>(
      "t", 1, ExchangeClient::kDefaultMaxQueuedBytes, pool(), executor());

  BOLT_ASSERT_THROW(
      client->addRemoteTaskId("task.1.2.3"),
      "Failed to create ExchangeSource: Testing error. Task ID: task.1.2.3.");

  // Test with a very long task ID. Make sure it is truncated.
  BOLT_ASSERT_THROW(
      client->addRemoteTaskId(std::string(1024, 'x')),
      "Failed to create ExchangeSource: Testing error. "
      "Task ID: xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx.");

  client->close();
}

TEST_F(ExchangeClientTest, stats) {
  auto data = {