2.37. JMS
JMS Queue 또는 Topic에서/에 메시지를 전송 및 수신합니다.
2.37.1. 내부 내용 링크 복사링크가 클립보드에 복사되었습니다!
-
JMS 구성 요소, URI 구문:
jms:destinationType:destinationName
사용 및 설정 세부 사항은 위의 링크를 참조하십시오.
2.37.2. Maven 조정 링크 복사링크가 클립보드에 복사되었습니다!
code.quarkus.redhat.com에서 이 확장 기능을 사용하여 새 프로젝트를 생성합니다.
또는 기존 프로젝트에 좌표를 추가합니다.
<dependency> <groupId>org.apache.camel.quarkus</groupId> <artifactId>camel-quarkus-jms</artifactId> </dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-jms</artifactId>
</dependency>
2.37.3. 사용법 링크 복사링크가 클립보드에 복사되었습니다!
2.37.3.1. org.w3c.dom.Node를 사용한 메시지 매핑 링크 복사링크가 클립보드에 복사되었습니다!
Camel JMS 구성 요소는 javax.jms.Message
와 org.apache.camel.Message
간의 메시지 매핑을 지원합니다. Camel 메시지 본문 유형의 org.w3c.dom.Node
를 변환하려면 classpath에 camel-quarkus-jaxp
확장이 있는지 확인해야 합니다.
2.37.3.2. javax.jms.ObjectMessage 기본 모드 지원 링크 복사링크가 클립보드에 복사되었습니다!
JMS 메시지 페이로드를 javax.jms.ObjectMessage
로 전송하는 경우 관련 클래스에 @RegisterForReflection(serialization = true)
을 사용하여 등록할 관련 클래스에 주석을 달아야 합니다. 이 확장은 자동으로 quarkus.camel.native.reflection.serialization-enabled = true
를 설정합니다. 자세한 내용은 기본 모드 사용자 가이드를 참조하십시오.
2.37.3.3. 연결 풀링 및 X/Open XA 분산 트랜잭션 지원 링크 복사링크가 클립보드에 복사되었습니다!
연결 풀링은 Camel Extensions for Quarkus 릴리스의 기술 프리뷰 기능입니다.
camel-quarkus-jms
구성 요소에서 연결 풀링을 사용하려면 io.quarkiverse.artemis:quarkus-artemis
및 io.quarkiverse.messaginghub:quarkus-pooled-jms
를 pom.xml에 추가하고 다음 구성을 설정해야 합니다.
quarkus.pooled-jms.max-connections = 8
quarkus.pooled-jms.max-connections = 8
quarkus-pooled-jms
확장을 사용하여 JMS 연결에 대한 풀링 및 XA 지원을 받을 수 있습니다. 자세한 내용은 quarkus-pooled-jms 확장 설명서를 참조하십시오. 현재는 quarkus-artemis-jms
확장에서만 작동합니다. 이 두 가지 종속성을 pom.xml
에 추가하십시오.
풀링은 기본적으로 활성화되어 있습니다.
XA를 활성화하려면 application.properties
에 다음 구성을 추가해야 합니다.
quarkus.pooled-jms.xa.enabled=true
quarkus.pooled-jms.xa.enabled=true
Pooling 연결
이 지원되지 않습니다. 에서는 ClientID
및 hugepagesSubscriptionNamesetClientID
가 풀에서 재사용
된 연결에서 호출되는 경우 IllegalStateException
이 발생합니다. Cause: setClientID와 같은 일부 오류 메시지는 연결이 생성된 후에만 호출할 수 있습니다
.
2.37.4. 기본 모드인 transferException 옵션 링크 복사링크가 클립보드에 복사되었습니다!
기본 모드에서 transferException
옵션을 사용하려면 개체 직렬화에 대한 지원을 활성화해야 합니다. 자세한 내용은 기본 모드 사용자 가이드를 참조하십시오.
또한 직렬화를 사용 하도록 설정 하려는 예외 클래스에 대해 직렬화를 사용 하도록 설정 해야 합니다.You will also need to enable serialization for the exception classes that you intend to serialize. 예를 들면 다음과 같습니다.
@RegisterForReflection(targets = { IllegalStateException.class, MyCustomException.class }, serialization = true)
@RegisterForReflection(targets = { IllegalStateException.class, MyCustomException.class }, serialization = true)