PublishJMS
PublishJMS
FlowFile 내용에서 JMS 메시지를 만들고 JMS Destination(큐 또는 토픽)으로 JMS BytesMessage 또는 TextMessage로 보내는 프로세서예요.
본문
번들 (Bundle)
org.apache.nifi | nifi-jms-processors-nar
설명
FlowFile 내용에서 JMS 메시지를 만들어 JMS Destination(큐 또는 토픽)으로 JMS BytesMessage 또는 TextMessage로 보내요. FlowFile 속성은 나가는 JMS 메시지에 JMS 헤더 및/또는 속성으로 추가돼요.
태그
jms, message, publish, put, send
입력 요구 사항 (Input Requirement)
REQUIRED — 입력 FlowFile이 필요해요.
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false — 지원하지 않아요.
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Connection Client ID | 설정하면 연결에 설정할 client id예요. 지속적인 비공유 소비자에는 필수이며, 그 외에는 선택 사항이에요. 공유 소비자에서는 설정하지 않는 것이 보통 좋아요. 자세한 내용은 JMS 사양을 참고하세요. |
| Connection Factory Service | Connection Factory를 얻는 데 사용하는 Controller Service예요. 또는 'JNDI *' 또는 'JMS *' 속성으로 Connection Factory를 구성할 수도 있어요. |
| Destination Name | JMS Destination의 이름이에요. 보통 관리자가 제공해요(예: 'topic://myTopic' 또는 'myTopic'). |
| Destination Type | JMS Destination의 유형이에요. 'QUEUE' 또는 'TOPIC' 중 하나일 수 있어요. 보통 관리자가 제공하며 기본값은 'QUEUE'예요. |
| Maximum Batch Size | 프로세서 호출마다 게시하거나 소비할 최대 메시지 수예요. |
| Password | 인증 및 권한 부여에 사용되는 암호예요. |
| SSL Context Service | TLS/SSL 연결을 위한 클라이언트 인증서 정보를 제공하는 SSL Context Service예요. |
| User Name | 인증 및 권한 부여에 사용되는 사용자 이름이에요. |
| allow-illegal-chars-in-jms-header-names | 헤더 이름의 불법 문자(보통 하이픈과 마침표)를 JMS broker로 보낼지 여부를 지정해요. |
| attributes-to-send-as-jms-headers-regex | JMS 헤더로 보내야 할 FlowFile 속성의 이름을 결정하는 정규식을 지정해요. |
| broker URI | JMS Message broker의 네트워크 위치를 가리키는 URI예요. ActiveMQ 예: 'tcp://myhost:61616'. IBM MQ 예: 'myhost(1414)' 및 'myhost01(1414),myhost02(1414)'. |
| cf | JMS ConnectionFactory 구현 클래스의 정규화된 이름이에요(예: org.apache.activemq.ActiveMQConnectionFactory). |
| cflib | 클래스패스에 추가할 추가 리소스(예: JAR, 구성 파일 등)가 있는 디렉터리 경로(쉼표로 구분된 값 목록으로 정의)예요. 이러한 리소스는 보통 ConnectionFactory 구현을 위한 대상 JMS 클라이언트 라이브러리를 나타내요. |
| character-set | TextMessage를 구성하거나 해석하는 데 사용할 문자 집합의 이름이에요. |
| connection.factory.name | Connection Factory를 위해 조회할 JNDI Object의 이름이에요. |
| java.naming.factory.initial | JNDI Initial Context Factory Class의 정규화된 클래스 이름(java.naming.factory.initial)이에요. |
| java.naming.provider.url | java.naming.provider.url의 값으로 사용할 JNDI Provider의 URL이에요. 허용되는 URL 스킴은 추가 세부 문서를 참고하세요. |
| java.naming.security.credentials | JNDI 인증 시 사용할 자격 증명(java.naming.security.credentials)이에요. |
| java.naming.security.principal | JNDI 인증 시 사용할 Principal(java.naming.security.principal)이에요. |
| message-body-type | 구성할 JMS 메시지 본문의 유형이에요. |
| naming.factory.libraries | JNDI / JMS 클라이언트 라이브러리를 로드하기 위해 ClassPath에 추가할 jar 파일 및/또는 디렉터리를 지정해요. 파일, 디렉터리, 및/또는 URL의 쉼표로 구분된 목록이어야 해요. 디렉터리가 주어지면 해당 디렉터리의 파일이 포함되지만 하위 디렉터리는 포함되지 않아요(재귀적이지 않음). |
| record-reader | 들어오는 FlowFile을 Records로 파싱하는 데 사용할 Record Reader예요. |
| record-writer | JMS 메시지로 게시하기 전에 Records를 직렬화하는 데 사용할 Record Writer예요. |
제한 사항 (Restrictions)
| 요구 권한 | 설명 |
|---|---|
| reference remote resources | Client Library Location이 HTTP를 통해 원격 리소스를 참조할 수 있어요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
failure |
JMS 목적지로 보낼 수 없는 모든 FlowFile이 이 관계로 라우팅돼요. |
success |
JMS 목적지로 전송된 모든 FlowFile이 이 관계로 라우팅돼요. |
더 보기 (See also)
org.apache.nifi.jms.processors.ConsumeJMS