5.5. 配置 AMQP 组件

从 Camel 2.16.1 开始，您还可以使用 AMQPComponent#amqp10Component (String connectionURI) 工厂方法返回带有预配置的主题前缀的 AMQP 1.0 组件：

创建 AMQP 1.0 组件

 AMQPComponent amqp = AMQPComponent.amqp10Component("amqp://guest:guest@localhost:5672");

请记住，从 Camel 2.17 开始，AMQPComponent#amqp10Component (String connectionURI) factory 方法已弃用，代表 AMQPComponent#amqpComponent (String connectionURI) ：

创建 AMQP 1.0 组件

AMQPComponent amqp = AMQPComponent.amqpComponent("amqp://localhost:5672");

AMQPComponent authorizedAmqp = AMQPComponent.amqpComponent("amqp://localhost:5672", "user", "password");

从 Camel 2.17 开始，为了自动配置 AMQP 组件，您还可以将 org.apache.camel.component.amqp.AMQPConnectionDetails 的实例添加到 registry。例如，对于 Spring Boot，您只需要定义 bean：

AMQP 连接详情自动配置

@Bean
AMQPConnectionDetails amqpConnection() {
  return new AMQPConnectionDetails("amqp://localhost:5672");
}

@Bean
AMQPConnectionDetails securedAmqpConnection() {
  return new AMQPConnectionDetails("amqp://localhost:5672", "username", "password");
}

同样，在使用 Camel-CDI 时也可以使用 CDI producer 方法

AMQP 连接详情自动配置 CDI

@Produces
AMQPConnectionDetails amqpConnection() {
  return new AMQPConnectionDetails("amqp://localhost:5672");
}

您还可以依赖 Camel 属性 来读取 AMQP 连接详情。工厂方法 AMQPConnectionDetails.discoverAMQP （） 试图以类似于 Kubernetes 的惯例读取 Camel 属性，如以下代码片段所示：

AMQP 连接详情自动配置

export AMQP_SERVICE_HOST = "mybroker.com"
export AMQP_SERVICE_PORT = "6666"
export AMQP_SERVICE_USERNAME = "username"
export AMQP_SERVICE_PASSWORD = "password"

...

@Bean
AMQPConnectionDetails amqpConnection() {
  return AMQPConnectionDetails.discoverAMQP();
}

启用 AMQP 具体选项

例如，如果您需要启用 amqp.traceFrames，您可以通过将选项附加到 URI 来完成此操作，如下例所示：

AMQPComponent amqp = AMQPComponent.amqpComponent("amqp://localhost:5672?amqp.traceFrames=true");

仅供参考，请查看 QPID JMS 客户端配置