Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-795

Implement prefixing in AMQP

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • None
    • AMQ 7.0.2.GA
    • None
    • None
    • Hide

      Connect a receiver to FQQN with prefix: prefix://address::topic.
      --------------------------------------------------------------------------------------------------------

      • Download AMQ Broker zip
      • Unzip it
      • Create instance with command:
        [...]/artemis create --http-host=0.0.0.0 --force --nio --role=amq --user=admin --allow-anonymous --password=admin --java-options="-Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.rmi.port=1099 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false " --name=amq <some_path>
        
      • Add multicast prefix to the end of amqp acceptor:
        ;multicastPrefix=topic://
        
      • Add multicast/topic address to the addresses section in broker.xml:
                 <address name="address1">
                    <multicast>
                       <queue name="topic1" />
                    </multicast>
                 </address>
        
      • Run broker:
        <some_path>/bin/artemis run
        
      • Install packages:
        • qpid-proton-cpp (0.16.0-3)
        • qpid-proton-cpp-devel (0.16.0-3)
        • qpid-proton-cpp-docs (0.16.0-3)
      • Go to path /usr/share/proton-0.16.0/examples/cpp
      • Run:
        cmake .
        
      • Run:
        make simple_recv
        
      • Run:
        ./simple_recv "<IP>:5672/topic://address1::topic1"
        
      Show
      Connect a receiver to FQQN with prefix: prefix://address::topic . -------------------------------------------------------------------------------------------------------- Download AMQ Broker zip Unzip it Create instance with command: [...]/artemis create --http-host=0.0.0.0 --force --nio --role=amq --user=admin --allow-anonymous --password=admin --java-options="-Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.rmi.port=1099 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false " --name=amq <some_path> Add multicast prefix to the end of amqp acceptor: ;multicastPrefix=topic:// Add multicast/topic address to the addresses section in broker.xml: <address name="address1"> <multicast> <queue name="topic1" /> </multicast> </address> Run broker: <some_path>/bin/artemis run Install packages: qpid-proton-cpp (0.16.0-3) qpid-proton-cpp-devel (0.16.0-3) qpid-proton-cpp-docs (0.16.0-3) Go to path /usr/share/proton-0.16.0/examples/cpp Run: cmake . Run: make simple_recv Run: ./simple_recv "<IP>:5672/topic://address1::topic1"

      Unable to use prefix in AMQP. Prefix is the only way how to consume from multicast/topic with C++ clients (non-JMS clients), because there is not something to specify that I want consume from multicast/topic, not queue.

              mtaylor1@redhat.com Martyn Taylor (Inactive)
              rkubis_kafka_devexp Radim Kubis
              Radim Kubis Radim Kubis
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: