271.7. 샘플
라우팅 키 B를 사용하여 교환 A에 바인딩된 큐에서 메시지를 수신하려면,
from("rabbitmq:A?routingKey=B")
from("rabbitmq:A?routingKey=B")
자동 승인이 비활성화된 단일 스레드가 있는 대기열에서 메시지를 수신하려면 다음을 수행합니다.
from("rabbitmq:A?routingKey=B&threadPoolSize=1&autoAck=false")
from("rabbitmq:A?routingKey=B&threadPoolSize=1&autoAck=false")
C라는 교환으로 메시지를 보내려면
to("rabbitmq:C")
to("rabbitmq:C")
헤더 교환 및 큐 선언
from("rabbitmq:ex?exchangeType=headers&queue=q&bindingArgs=#bindArgs")
from("rabbitmq:ex?exchangeType=headers&queue=q&bindingArgs=#bindArgs")
그리고 레지스트리에 "bindArgs"의 ID를 사용하여 해당 Map<String, Object
>를 배치합니다.
예를 들어 Spring에서 메서드를 선언합니다.
@Bean(name="bindArgs") public Map<String, Object> bindArgsBuilder() { return Collections.singletonMap("foo", "bar"); }
@Bean(name="bindArgs")
public Map<String, Object> bindArgsBuilder() {
return Collections.singletonMap("foo", "bar");
}
271.7.1. 교환 간 라우팅 시 문제 ( Camel 2.20.x 이상) 링크 복사링크가 클립보드에 복사되었습니다!
예를 들어 foo
from("rabbitmq:foo") .to("rabbitmq:bar")
from("rabbitmq:foo")
.to("rabbitmq:bar")
그런 다음 Camel이 메시지를 자체적으로 (예: foo rabbitmq.EXCHANGE_NAME
을 교환 이름(예: foo
)과 함께 제공하기 때문입니다. 그리고 Camel 프로듀서가 bar
에 메시지를 전송하면 rabbitmq.EXCHANGE_NAME
헤더가 이를 재정의하고 대신 foo
로 메시지를 보냅니다.
이를 방지하려면 다음 중 하나를 수행해야 합니다.
- 헤더를 제거합니다.
from("rabbitmq:foo") .removeHeader("rabbitmq.EXCHANGE_NAME") .to("rabbitmq:bar")
from("rabbitmq:foo")
.removeHeader("rabbitmq.EXCHANGE_NAME")
.to("rabbitmq:bar")
-
또는 생산자에서
bridgeEndpoint
모드를 켭니다.
from("rabbitmq:foo") .to("rabbitmq:bar?bridgeEndpoint=true")
from("rabbitmq:foo")
.to("rabbitmq:bar?bridgeEndpoint=true")
Camel 2.21 이상에서 이 기능이 개선되어 교환 사이에 쉽게 라우팅할 수 있습니다. rabbitmq.EXCHANGE_NAME
헤더는 프로듀서에서 대상 교환을 재정의하는 데 더 이상 사용되지 않습니다. 대신 새 헤더 rabbitmq.EXCHANGE_OVERRIDE_NAME
을 사용하여 다른 교환으로 보낼 수 있습니다. 예를 들어, 유독성 교환으로 보내려면 다음을 수행할 수 있습니다.
from("rabbitmq:foo") .setHeader("rabbitmq.EXCHANGE_OVERRIDE_NAME", constant("cheese")) .to("rabbitmq:bar")
from("rabbitmq:foo")
.setHeader("rabbitmq.EXCHANGE_OVERRIDE_NAME", constant("cheese"))
.to("rabbitmq:bar")