272.7. Samples
라우팅 키 B를 사용하여 교환 A에 바인딩된 큐에서 메시지를 수신하려면
from("rabbitmq:A?routingKey=B")자동 승인이 비활성화된 단일 스레드가 있는 대기열에서 메시지를 수신하려면 다음을 수행합니다.
from("rabbitmq:A?routingKey=B&threadPoolSize=1&autoAck=false")C라는 교환으로 메시지를 보냅니다.
to("rabbitmq:C")헤더 교환 및 큐 선언
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");
}272.7.1. 교환 간 라우팅 시 문제( Camel 2.20.x 또는 이전 버전)
예를 들어 아래 예제에서 foo
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")-
또는 생산자에서
bridgeEndpoint모드를 켭니다.
from("rabbitmq:foo")
.to("rabbitmq:bar?bridgeEndpoint=true")
Camel 2.21 이후의 개선으로 인해 교환을 쉽게 라우팅할 수 있습니다. rabbitmq.EXCHANGE_NAME 헤더는 더 이상 생산자가 대상 교환을 재정의하는 데 사용되지 않습니다. 대신 새 헤더 rabbitmq.EXCHANGE_OVERRIDE_NAME 을 사용하여 다른 교환으로 보낼 수 있습니다. 예를 들어, Chess 교환으로 보내려면 다음을 수행할 수 있습니다.
from("rabbitmq:foo")
.setHeader("rabbitmq.EXCHANGE_OVERRIDE_NAME", constant("cheese"))
.to("rabbitmq:bar")