5.4. AMQP 구성 요소 구성

Camel 2.16.1부터 AMQPComponent#amqp10Component(String connectionURI) 팩토리 메서드를 사용하여 사전 구성된 주제 접두사가 있는 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) 팩토리 방법(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");

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

Copy to Clipboard

Toggle word wrap

AMQP 구성 요소를 자동으로 구성하기 위해 Camel 2.17부터 레지스트리에 org.apache.camel.component.amqp.AMQPConnectionDetails 인스턴스를 추가할 수도 있습니다. 예를 들어 Spring Boot의 경우 빈을 정의해야 합니다.

AMQP 연결 세부 정보 자동 구성

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

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

Copy to Clipboard

Toggle word wrap

마찬가지로 Camel-CDI를 사용할 때 CDI 생산자 방법을 사용할 수도 있습니다.

AMQP 연결 세부 정보 CDI의 자동 구성

@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 연결 세부 정보를 읽을 수도 있습니다. 팩토리 방법 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 관련 옵션 활성화

예를 들어, 다음 예제 와 같이 옵션을 URI에 추가하여mqp.traceFrames 를 활성화해야 합니다.

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.4. AMQP 구성 요소 구성

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links