1.6. 配置 AMQP 组件
创建 AMQP 1.0 组件
AMQPComponent amqp = AMQPComponent.amqpComponent("amqp://localhost:5672");
AMQPComponent authorizedAmqp = AMQPComponent.amqpComponent("amqp://localhost:5672", "user", "password");
您还可以将 org.apache.camel.component.amqp.amqpConnectionDetails 的实例 添加到 registry 中，以便自动配置 AMQP 组件。例如，对于 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 方法
CDI 的 AMQP 连接详情自动配置
@Produces
AMQPConnectionDetails amqpConnection() {
return new AMQPConnectionDetails("amqp://localhost:5672");
}
您还可以依赖 来读取 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 客户端配置。
