ConsumeJMS 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-jms-processors-nar
Descrição¶
Consome mensagem JMS do tipo BytesMessage, TextMessage, ObjectMessage, MapMessage ou StreamMessage transformando seu conteúdo em um FlowFile e fazendo a transição para a relação “success”. Atributos JMS como cabeçalhos e propriedades serão copiados como atributos FlowFile. MapMessages serão transformados em JSONs e depois em matrizes de bytes. Os outros tipos terão seus conteúdos brutos como matriz de bytes transferidos para o FlowFile.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Modo de reconhecimento |
O modo de reconhecimento JMS. O uso do reconhecimento automático pode fazer com que as mensagens sejam perdidas quando o NiFi for reiniciado, mas pode proporcionar melhor desempenho do que o reconhecimento pelo cliente. |
ID do cliente de conexão |
O ID do cliente a ser definido na conexão, se definido. Para consumidores duráveis não compartilhados, isso é obrigatório; para todos os outros, é opcional; normalmente, com consumidores compartilhados, não é desejável que seja definido. Para obter mais detalhes, consulte as especificações do JMS |
Serviço Connection Factory |
O Controller Service usado para obter a Connection Factory. Como alternativa, as propriedades “JNDI *“ ou “JMS *” também podem ser usadas para configurar a Connection Factory. |
Nome de destino |
O nome de destino do JMS. Geralmente fornecido pelo administrador (por exemplo, “topic://myTopic” ou “myTopic”). |
Tipo de destino |
O tipo do destino do JMS. Pode ser uma das opções “QUEUE” ou “TOPIC”. Geralmente fornecido pelo administrador. O padrão é “QUEUE” |
Assinatura durável |
Se o destino for um tópico, isso criará uma assinatura de consumidor durável. Consulte https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createDurableConsumer-jakarta.jms.Topic-java.lang.String- |
Nome da fila de erros |
O nome de uma fila JMS onde, se definido, as mensagens não processadas serão roteadas. Geralmente fornecido pelo administrador (por exemplo, “queue://myErrorQueue“ ou “myErrorQueue”). Somente aplicável se “Tipo de destino” estiver definido como “QUEUE“ |
Tamanho máximo de lote |
O número máximo de mensagens a serem publicadas ou consumidas em cada invocação do processador. |
Seletor de mensagem |
O seletor de mensagem JMS para filtrar as mensagens que o processador receberá |
Senha |
Senha usada para autenticação e autorização. |
Serviço de contexto SSL |
O serviço de contexto SSL usado para fornecer informações de certificado de cliente para conexões TLS/SSL. |
Assinatura compartilhada |
Se o destino for um tópico, isso criará uma assinatura de consumidor compartilhada. Consulte https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createSharedConsumer-jakarta.jms.Topic-java.lang.String- |
Nome da assinatura |
O nome da assinatura a ser usada se o destino for um tópico e for compartilhado ou durável. |
Tempo limite |
Quanto tempo você deve esperar para consumir uma mensagem do corretor remoto antes de desistir. |
Nome de usuário |
Nome de usuário usado para autenticação e autorização. |
broker |
URI apontando para o local da rede do corretor de mensagens JMS. Exemplo para ActiveMQ: “tcp://myhost:61616”. Exemplos para IBM MQ: “myhost(1414)” e “myhost01(1414),myhost02(1414)”. |
cf |
O nome totalmente qualificado da classe de implementação JMS ConnectionFactory (por exemplo, org.apache.activemq.ActiveMQConnectionFactory). |
cflib |
Caminho para o diretório com recursos adicionais (por exemplo, JARs, arquivos de configuração etc.) a serem adicionados ao caminho de classe (definido como uma lista de valores separados por vírgula). Esses recursos normalmente representam bibliotecas de clientes JMS de destino para a implementação do ConnectionFactory. |
character-set |
O nome do conjunto de caracteres a ser usado para construir ou interpretar TextMessages |
connection.factory.name |
O nome do objeto JNDI a ser pesquisado para a Connection Factory. |
java.naming.factory.initial |
O nome da classe totalmente qualificado da classe de fábrica de contexto inicial JNDI (java.naming.factory.initial). |
java.naming.provider.url |
O URL do provedor JNDI a ser usado como o valor para java.naming.provider.url. Consulte a documentação de detalhes adicionais para ver os esquemas de URL permitidos. |
java.naming.security.credentials |
As credenciais a serem usadas na autenticação com JNDI (java.naming.security.credentials). |
java.naming.security.principal |
A entidade a ser usada na autenticação com JNDI (java.naming.security.principal). |
naming.factory.libraries |
Especifica os arquivos e/ou diretórios jar a serem adicionados a ClassPath para carregar as bibliotecas de cliente JNDI/JMS. Deve ser uma lista separada por vírgulas de arquivos, diretórios e/ou URLs. Se for fornecido um diretório, todos os arquivos desse diretório serão incluídos, mas os subdiretórios não serão incluídos (ou seja, não é recursivo). |
output-strategy |
O formato usado para gerar a mensagem JMS em um registro FlowFile. |
record-reader |
O Record Reader a ser usado para analisar as mensagens JMS recebidas em registros. |
record-writer |
O Record Writer a ser usado para serializar registros antes de gravá-los em um FlowFile. |
Restrições¶
Permissão necessária |
Explicação |
|---|---|
recursos remotos de referência |
O local da biblioteca cliente pode referenciar recursos via HTTP |
Relações¶
Nome |
Descrição |
|---|---|
parse.failure |
Se uma mensagem não puder ser analisada usando o Record Reader configurado, o conteúdo da mensagem será encaminhado para essa relação como seu próprio FlowFile. |
success |
Todos os FlowFiles recebidos do destino JMS são encaminhados para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
jms_deliveryMode |
O JMSDeliveryMode do cabeçalho da mensagem. |
jms_expiration |
O JMSExpiration do cabeçalho da mensagem. |
jms_priority |
O JMSPriority do cabeçalho da mensagem. |
jms_redelivered |
O JMSRedelivered do cabeçalho da mensagem. |
jms_timestamp |
O JMSTimestamp do cabeçalho da mensagem. |
jms_correlationId |
O JMSCorrelationID do cabeçalho da mensagem. |
jms_messageId |
O JMSMessageID do cabeçalho da mensagem. |
jms_type |
O JMSType do cabeçalho da mensagem. |
jms_replyTo |
O JMSReplyTo do cabeçalho da mensagem. |
jms_destination |
O JMSDestination do cabeçalho da mensagem. |
jms.messagetype |
O tipo de mensagem JMS pode ser TextMessage, BytesMessage, ObjectMessage, MapMessage ou StreamMessage). |
outros atributos |
Cada propriedade da mensagem é gravada em um atributo. |