20.4. 端点选项


Dataset 端点使用 URI 语法进行配置:

dataset:name

使用以下路径和查询参数:

20.4.1. 路径参数(1 参数)

Name描述默认值类型

name (common)

要在 registry 中查找 DataSet 所需的 名称。

 

DataSet

20.4.2. 查询参数(21 参数)

Name描述默认值类型

dataSetIndex (common)

控制 CamelDataSetIndex 标头的行为。对于 Consumers: - off = 标头不会设置 - strict/lenient = 标头将被设置为 For Producers: - off = 标头值不会被验证,如果没有包括标头值,则不会设置它。如果标头值不存在,标头值必须存在,并将验证 = lenient = 标头值(如果不存在)。

Enum 值:

  • strict
  • lenient
  • off

lenient

字符串

bridgeErrorHandler (consumer)

允许将消费者桥接到 Camel 路由错误处理程序,这意味着当消费者试图选择传入消息或类似信息时发生异常,现在将作为消息处理并由路由 Error Handler 处理。默认情况下,使用者将使用 org.apache.camel.spi.ExceptionHandler 来处理例外情况,该处理程序将被记录在 WARN 或 ERROR 级别,并忽略。

false

布尔值

initialDelay (consumer)

在开始发送消息前,millis 中的时间段。

1000

long

minRate (consumer)

等待 DataSet 至少包含这个数量的消息。

0

int

preloadSize (consumer)

设置在路由完成初始化前应预加载(sent)的消息数量。

0

long

produceDelay (consumer)

可以指定延迟,这会在消费者发送消息时造成延迟(模拟速度较慢的处理)。

3

long

exceptionHandler (consumer (advanced))

要让使用者使用自定义例外处理程序:请注意,如果启用了 bridgeErrorHandler 选项,则此选项不使用。默认情况下,消费者将处理异常,其记录在 WARN 或 ERROR 级别中,并忽略。

 

ExceptionHandler

exchangePattern (consumer (advanced))

在消费者创建交换时设置交换模式。

Enum 值:

  • InOnly
  • InOut
  • InOptionalOut
 

ExchangePattern

assertPeriod (producer)

设置一个宽限期,模拟端点将重新分配,以确保初始断言仍然有效。例如,这用于精确有多个消息到达的声明。例如,如果 expectedMessageCount (int)设为 5,则在 5 个或更多消息到达时满足断言。为确保完全 5 个消息到达,您需要等待少量周期以确保没有进一步的消息到达。这是您可以使用此方法。默认情况下禁用这个周期。

 

long

consumeDelay (producer)

可以指定延迟,在生成者消耗消息时(模拟速度较慢)时会导致延迟。

0

long

expectedCount (producer)

指定此端点应接收的消息交换数量。beware:如果要期望 0 个消息,然后在测试启动时进行额外的操作,因为测试启动时需要设置一个断言周期,以便测试可以在一段时间内运行,以确保仍没有到达的消息;对于使用 setAssertPeriod (long),您需要设置一个指定时间。另一种方法是使用 NotifyBuilder,并使用 notifier 知道 Camel 在对模拟调用 assertIsSatisfied ()方法之前,在路由某些消息前知道何时进行路由。这可让您不使用固定的断言周期来加快测试时间。如果您想成为完全 n 个消息到达这个模拟端点,请参阅 setAssertPeriod (long)方法以了解更多详细信息。

-1

int

failFast (producer)

设置是否 assertIsSatisfied ()是否应该在第一次检测到的失败时快速失败,同时可能会等待所有预期消息到达,然后再执行预期验证。默认为 true。设置为 false,以使用与 Camel 2.x 中一样的行为。

false

布尔值

lazyStartProducer (producer)

生成者是否应懒惰启动 (在第一个消息中)。通过懒惰启动,您可以使用此选项来允许 CamelContext 和路由在生成者启动期间启动,并导致路由启动失败。通过懒惰启动,启动失败可以在路由信息时通过 Camel 的路由错误处理程序进行处理。请注意,在处理第一个消息时,创建并启动生成者可能需要稍等时间,并延长处理的总处理时间。

false

布尔值

log (producer)

在模拟收到传入的消息时打开日志记录。这将仅记录传入消息的 INFO 级别一次。如需更详细的日志记录,请将 org.apache.camel.component.mock.MockEndpoint 类的日志记录器设置为 DEBUG 级别。

false

布尔值

reportGroup (producer)

用于根据大小组打开吞吐量日志的数字。

 

int

resultMinimumWaitTime (producer)

设置 assertIsSatisfied ()的最短预期时间(以 millis 为单位)。

 

long

resultWaitTime (producer)

设置 assertIsSatisfied ()在达到前等待的最大时间(以 millis 为单位)。

 

long

retainFirst (producer)

指定只保留前 n 个接收的交换数。这在使用大量数据进行测试时,通过不存储每个交换端点接收的每个交换的副本来减少内存消耗。重要:在使用这个限制时,getReceivedCounter ()仍会返回实际收到的交换数量。例如,如果我们收到 5000 Exchanges,并且配置为只保留前 10 个交换,则 getReceivedCounter ()仍会返回 5000,但 getExchanges ()中只有前 10 个交换,并且 getReceivedExchanges ()方法。使用此方法时,不支持一些其他预期方法,例如 expectedBodiesReceived (Object…​)在收到的第一个正文数量上设置预期。您可以配置 setRetainFirst (int)和 setRetainLast (int)方法,以限制第一个和最后一个接收的方法。

-1

int

retainLast (producer)

指定只保留最后 n 个接收的交换数。这在使用大量数据进行测试时,通过不存储每个交换端点接收的每个交换的副本来减少内存消耗。重要:在使用这个限制时,getReceivedCounter ()仍会返回实际收到的交换数量。例如,如果我们收到 5000 Exchanges,并且配置为只保留最后 20 个交换,则 getReceivedCounter ()仍会返回 5000,但 getExchanges ()中只有最后 20 个交换,并且 getReceivedExchanges ()方法。使用此方法时,不支持一些其他预期方法,例如 expectedBodiesReceived (Object…​)在收到的第一个正文数量上设置预期。您可以配置 setRetainFirst (int)和 setRetainLast (int)方法,以限制第一个和最后一个接收的方法。

-1

int

sleepForEmptyTest (producer)

当 expectedMessageCount (int)调用零时,允许指定 sleep 来等待此端点确实为空。

 

long

copyOnExchange (producer (advanced))

设置是否在这个模拟端点收到传入交换的深度副本。默认为 true。

true

布尔值

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.