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) 팩토리 메서드가 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.AMQPConnection Details 의 인스턴스를 레지스트리에 추가할 수도 있습니다. 예를 들어 Spring Boot의 경우 metrics을 정의하기만 하면 됩니다.

AMQP 연결 세부 정보 자동 구성

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

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

마찬가지로 Camel-CDI 사용 시 CDI 생산자 메서드를 사용할 수도 있습니다.

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 클라이언트 구성을 참조하십시오.