5.5. AMQP 구성 요소 구성

Camel 2.16.1부터 AMQPComponent#amqp10Component(String connectionURI) loading 메서드를 사용하여 사전 구성된 주제 접두사로 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) 는 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 의 인스턴스를 레지스트리에 추가할 수도 있습니다. 예를 들어 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 생산자 메서드를 사용할 수도 있습니다.

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에 옵션을 추가하여 amqp.traceECDHEs 를 활성화해야 하는 경우:

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

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

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

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links