ConsumeJMS 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-jms-processors-nar

설명¶

BytesMessage, TextMessage, ObjectMessage, MapMessage 또는 StreamMessage 유형의 JMS 메시지를 소비하여 그 내용을 FlowFile 로 변환하고 ‘성공’ 관계로 전환합니다. JMS 헤더 및 속성과 같은 속성은 FlowFile 속성으로 복사본이 복사됩니다. MapMessages 는 JSONs 로 변환된 다음 바이트 배열로 변환됩니다. 다른 유형은 원시 내용을 바이트 배열로 flowfile에 전송합니다.

태그¶

consume, get, jms, message, receive

입력 요구 사항¶

FORBIDDEN

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Acknowledgement Mode	JMS 승인 모드입니다. 자동 승인을 사용하면 NiFi 재시작 시 메시지가 손실될 수 있지만 클라이언트 승인보다 더 나은 성능을 제공할 수 있습니다.
Connection Client ID	연결에 설정할 클라이언트 ID(설정된 경우)입니다. 내구성이 있는 비공유 컨슈머의 경우 필수이며, 다른 모든 컨슈머의 경우 선택 사항이며 일반적으로 공유 컨슈머의 경우 설정하는 것이 바람직하지 않습니다. 자세한 내용은 JMS 사양을 참조하십시오
Connection Factory Service	연결 팩토리를 얻는 데 사용되는 컨트롤러 서비스입니다. 아니면 ‘JNDI ’ 또는 ‘JMS ’ 속성을 사용하여 연결 팩토리를 구성할 수도 있습니다.
Destination Name	JMS 대상의 이름입니다. 일반적으로 관리자가 제공합니다(예: ‘topic://myTopic’ 또 는’myTopic’).
Destination Type	JMS 대상의 유형입니다. ‘QUEUE’ 또는 ‘TOPIC’ 중 하나일 수 있습니다. 일반적으로 관리자가 제공합니다. 기본값은 ‘QUEUE’입니다.
Durable subscription	대상이 항목이면 컨슈머 내구성으로 생성합니다. @참조: https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createDurableConsumer-jakarta.jms.Topic-java.lang.String-
Error Queue Name	설정된 경우 처리되지 않은 메시지가 라우팅되는 JMS 큐의 이름입니다. 일반적으로 관리자가 제공합니다(예: ‘queue://myErrorQueue’ 또는 ‘myErrorQueue). ‘대상 유형’이 ‘QUEUE’로 설정된 경우에만 적용됩니다
Maximum Batch Size	프로세서를 호출할 때마다 게시하거나 소비할 최대 메시지 수입니다.
Message Selector	JMS 메시지 선택기를 사용하여 프로세서가 수신할 메시지를 필터링할 수 있습니다
비밀번호	인증 및 승인에 사용되는 비밀번호입니다.
SSL 컨텍스트 서비스	SSL 컨텍스트 서비스는 TLS/SSL 연결에 대한 클라이언트 인증서 정보를 제공하는 데 사용됩니다.
Shared subscription	대상이 항목인 경우 이를 컨슈머 공유로 설정합니다. @참조: https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createSharedConsumer-jakarta.jms.Topic-java.lang.String-
Subscription Name	대상이 항목이고 공유 또는 영구인 경우 사용할 구독의 이름입니다.
Timeout	포기하기 전에 원격 브로커의 메시지를 소비하기 위해 기다리는 시간입니다.
사용자 이름	인증 및 승인에 사용되는 사용자 이름입니다.
broker	URI JMS 메시지 브로커의 네트워크 위치를 가리킵니다. ActiveMQ 의 예: ‘tcp://myhost:61616’. IBM MQ 의 예: ‘myhost(1414)’ and ‘myhost01(1414),myhost02(1414)’.
cf	JMS ConnectionFactory 구현 클래스의 정규화된 이름(예: org.apache.activemq.ActiveMQConnectionFactory).
cflib	클래스 경로에 추가할 추가 리소스(예: JARs, 구성 파일 등)가 있는 디렉터리 경로(쉼표로 구분된 값 목록으로 정의됨). 이러한 리소스는 일반적으로 ConnectionFactory 구현을 위한 대상 JMS 클라이언트 라이브러리를 나타냅니다.
character-set	TextMessages 구성 또는 해석에 사용할 문자 세트의 이름입니다.
connection.factory.name	연결 팩토리를 조회할 JNDI 오브젝트의 이름입니다.
java.naming.factory.initial	JNDI Initial Context Factory 클래스(java.naming.factory.initial)의 정규화된 클래스 이름입니다.
java.naming.provider.url	JNDI 공급자의 URL 을 java.naming.provider.url의 값으로 사용합니다. 허용되는 URL 체계에 대한 자세한 내용은 추가 설명서를 참조하십시오.
java.naming.security.credentials	JNDI (java.naming.security.credentials)로 인증할 때 사용할 자격 증명입니다.
java.naming.security.principal	JNDI (java.naming.security.principal)로 인증할 때 사용할 주체입니다.
naming.factory.libraries	JNDI/JMS 클라이언트 라이브러리를 로딩하기 위해 ClassPath 에 추가할 jar 파일 및/또는 디렉터리를 지정합니다. 파일, 디렉터리 및/또는 URLs 로 쉼표로 구분된 목록이어야 합니다. 디렉터리가 지정되면 해당 디렉터리에 있는 모든 파일이 포함되지만 하위 디렉터리는 포함되지 않습니다(즉, 재귀적이지 않음).
output-strategy	JMS 메시지를 FlowFile 레코드로 출력하는 데 사용되는 형식입니다.
record-reader	수신된 JMS 메시지를 레코드로 구문 분석하는 데 사용할 Record Reader입니다.
record-writer	FlowFile 에 쓰기 전에 레코드를 직렬화하는 데 사용할 Record Writer입니다.

제한 사항¶

필수 권한	설명
reference remote resources	클라이언트 라이브러리 위치는 HTTP 를 통해 리소스를 참조할 수 있습니다.

관계¶

이름	설명
parse.failure	구성된 Record Reader를 사용하여 메시지를 구문 분석할 수 없는 경우 메시지 내용은 이 관계로 개별 FlowFile 로 라우팅됩니다.
성공	JMS 대상에서 수신되는 모든 FlowFiles 은 이 관계로 라우팅됩니다

Writes 특성¶

이름	설명
jms_deliveryMode	메시지 헤더의 JMSDeliveryMode 입니다.
jms_expiration	메시지 헤더의 JMSExpiration 입니다.
jms_priority	메시지 헤더의 JMSPriority 입니다.
jms_redelivered	메시지 헤더의 JMSRedelivered 입니다.
jms_timestamp	메시지 헤더의 JMSTimestamp 입니다.
jms_correlationId	메시지 헤더의 JMSCorrelationID 입니다.
jms_messageId	메시지 헤더의 JMSMessageID 입니다.
jms_type	메시지 헤더의 JMSType 입니다.
jms_replyTo	메시지 헤더의 JMSReplyTo 입니다.
jms_destination	메시지 헤더의 JMSDestination 입니다.
jms.messagetype	JMS 메시지 유형은 TextMessage, BytesMessage, ObjectMessage, MapMessage 또는 StreamMessage 입니다.
기타 특성	각 메시지 속성은 특성에 기록됩니다.

참고 항목¶

org.apache.nifi.jms.processors.PublishJMS