PublishJMS 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-jms-processors-nar
Descrição¶
Cria uma mensagem JMS a partir do conteúdo de um FlowFile e a envia para um destino JMS (fila ou tópico) como JMS BytesMessage ou TextMessage. Os atributos do FlowFile serão adicionados como cabeçalhos e/ou propriedades JMS à mensagem JMS de saída.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
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” |
Tamanho máximo de lote |
O número máximo de mensagens a serem publicadas ou consumidas em cada invocação do processador. |
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. |
Nome de usuário |
Nome de usuário usado para autenticação e autorização. |
allow-illegal-chars-in-jms-header-names |
Especifica se os caracteres ilegais nos nomes de cabeçalho devem ser enviados para o corretor JMS. Normalmente, hífens e pontos finais. |
attributes-to-send-as-jms-headers-regex |
Especifica a expressão regular que determina os nomes dos atributos do FlowFile que devem ser enviados como cabeçalhos JMS |
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). |
message-body-type |
O tipo de corpo da mensagem JMS a ser construído. |
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). |
record-reader |
O Record Reader a ser usado para analisar o FlowFile de entrada em registros. |
record-writer |
O Record Writer a ser usado para serializar registros antes de publicá-los como uma mensagem JMS. |
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 |
|---|---|
failure |
Todos os FlowFiles que não podem ser enviados ao destino JMS são encaminhados para essa relação |
success |
Todos os FlowFiles que são enviados ao destino do JMS são roteados para essa relação |