5.5. 配置 AMQP 组件

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

创建 AMQP 1.0 组件

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

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

Copy to Clipboard

Toggle word wrap

请记住，从 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");

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

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

Copy to Clipboard

Toggle word wrap

从 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");
}

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

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

Copy to Clipboard

Toggle word wrap

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

CDI 的 AMQP 连接详情自动配置

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

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

Copy to Clipboard

Toggle word wrap

您还可以依赖 Camel 属性来读取 AMQP 连接详情。factory 方法 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();
}

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();
}

Copy to Clipboard

Toggle word wrap

启用 AMQP 特定选项

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

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

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

Copy to Clipboard

Toggle word wrap

要进行参考，请查看 QPID JMS 客户端配置

返回顶部

5.5. 配置 AMQP 组件

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links