AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 78089086
Accepted
rb612
rb612
Asked: 2024-03-02 00:21:00 +0800 CST2024-03-02 00:21:00 +0800 CST 2024-03-02 00:21:00 +0800 CST

Simulando um transporte duplex Clássico com federação em Artemis?

  • 772

Estou tentando migrar do ActiveMQ Classic para o ActiveMQ Artemis e tenho um conector TCP duplex configurado no Classic.

Tentei definir uma configuração de federação e vejo que os endereços multicast são retransmitidos corretamente. Não vejo endereços anycast recebendo uma cópia. Posso ver por que isso é esperado, dada a definição de anycast, mas quero ser capaz de reproduzir a mesma semântica do Classic (onde eu tinha uma fila do Classic que encaminhava todas as suas mensagens).

Para maior clareza, tenho dois corretores, A e B, e tenho o corretor B (secundário) configurado com um upstream de A e um downstream para A com uma referência upstream de B. Tenho uma política de endereço de correspondência de todos os endereços em esse. O corretor A não tem configuração de federação.

Estou observando que os endereços multicast criados em A parecem ser replicados em B, o que mostra que o upstream de B para A parece funcionar. Mas anycast (filas JMS criadas em vez de tópicos) não parece ser criado em B. Espero que isso funcione como um duplex correspondendo a todas as filas/tópicos no Classic.

Minha expectativa é que cada mensagem enviada para a fila do corretor A seja recebida por alguém inscrito na mesma fila pelo nome no corretor B. Em outras palavras, espero que, ao produzir em A e consumir em B, receberei as mesmas mensagens como se Eu estava consumindo em A. Na verdade, quero que todas as mensagens publicadas em A sejam retransmitidas para B e vice-versa para todos os endereços.

Vejo que a documentação afirma:

Um endereço federado pode replicar mensagens publicadas de um endereço upstream para um endereço local. Nota: Isto só é suportado com endereços multicast.

activemq-artemis
  • 1 1 respostas
  • 31 Views

1 respostas

  • Voted
  1. Best Answer
    Justin Bertram
    2024-03-02T04:20:52+08:002024-03-02T04:20:52+08:00

    A documentação que você citou refere-se especificamente à capacidade da federação de replicar ou copiar mensagens enviadas para um endereço multicast em um corretor para o mesmo endereço multicast em outros corretores federados. Dessa forma, você pode obter semântica de pub/sub (ou seja, tópico JMS) em toda uma rede de corretores federados.

    Esse comportamento específico não funciona com endereços anycast porque eles aderem à semântica ponto a ponto (ou seja, fila JMS). Todos os consumidores em uma fila JMS compartilham (ou seja, competem por) as mensagens dessa fila. Replicar ou copiar essas mensagens para outros nós federados quebraria a semântica básica de entrega.

    No entanto, retransmitir ou encaminhar uma mensagem de um intermediário para outro via federação funcionará para endereços anycast, mas não é o mesmo que replicar ou copiar essas mensagens. O encaminhamento de mensagens é baseado na demanda do consumidor.

    Além disso, vale a pena notar que os clientes JMS não se inscrevem em uma fila como fariam com um tópico. Eles simplesmente criam um consumidor.

    • 2

relate perguntas

  • Propriedades impressas do filtro de log de auditoria do ActiveMQ Artemis

  • Conexão do corretor ActiveMQ Artemis

  • Implementando ferramenta de monitoramento Grafana para ActiveMQ Artemis

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Por que esse código Java simples e pequeno roda 30x mais rápido em todas as JVMs Graal, mas não em nenhuma JVM Oracle?

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Quando devo usar um std::inplace_vector em vez de um std::vector?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Marko Smith

    Estou tentando fazer o jogo pacman usando apenas o módulo Turtle Random e Math

    • 1 respostas
  • Martin Hope
    Aleksandr Dubinsky Por que a correspondência de padrões com o switch no InetAddress falha com 'não cobre todos os valores de entrada possíveis'? 2024-12-23 06:56:21 +0800 CST
  • Martin Hope
    Phillip Borge Por que esse código Java simples e pequeno roda 30x mais rápido em todas as JVMs Graal, mas não em nenhuma JVM Oracle? 2024-12-12 20:46:46 +0800 CST
  • Martin Hope
    Oodini Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores? 2024-12-12 06:27:11 +0800 CST
  • Martin Hope
    sleeptightAnsiC `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso? 2024-11-09 07:18:53 +0800 CST
  • Martin Hope
    The Mad Gamer Quando devo usar um std::inplace_vector em vez de um std::vector? 2024-10-29 23:01:00 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST
  • Martin Hope
    MarkB Por que o GCC gera código que executa condicionalmente uma implementação SIMD? 2024-02-17 06:17:14 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve