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 值:
| 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 值:
| 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 | 布尔值 |