Uploaded image for project: 'AMQ Clients'
  1. AMQ Clients
  2. ENTMQCL-412

nodejs rhea client stucks with amq7 with user without permissions

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Won't Do
    • Icon: Critical Critical
    • None
    • None
    • amqp-javascript-client
    • None
    • Hide

      1) install AMQ7-ER8 broker and configure artemis-roles.properties artemis-users.properties and broker.xml like in attached files.
      2) start AMQ7-ER8 broker
      3) create queue
      4) try this client code with user nobody with password nobody

      var container = require('rhea');
      
      var args = require('yargs').options({
            'm': { alias: 'messages', default: 10, describe: 'number of messages to send'},
            'n': { alias: 'address', default: 'jms.queue.examples_nevim_neco_pepa', describe: 'name of node (e.g. queue) to which messages are sent'},
            'p': { alias: 'port', default: 5672, describe: 'port to connect to'},
            'h': { alias: 'host', default: "10.34.124.125", describe: 'ip host'},
            'u': { alias: 'username', default: "admin", describe: 'username'},
            's': { alias: 'password', default: "admin", describe: 'password'},
          }).help('help').argv;
      
      var confirmed = 0, sent = 0;
      var total = args.messages;
      
      var message = {};
      message['body'] = {};
      
      //body
      message.body = "test string message"
      
      container.on('sendable', function (context) {
          while (context.sender.sendable() && sent < total) {
              sent++;
              console.log('sent ' + sent);
              context.sender.send(message);
          }
      });
      container.on('accepted', function (context) {
          if (++confirmed === total) {
              console.log("all messages confirmed")
              context.connection.close()
          }
      });
      container.on('disconnected', function (context) {
          sent = confirmed;
      });
      
      container.connect({'username': args.username, 'password': args.password, 'host': args.host, 'port':args.port}).open_sender(args.address);
      
      Show
      1) install AMQ7-ER8 broker and configure artemis-roles.properties artemis-users.properties and broker.xml like in attached files. 2) start AMQ7-ER8 broker 3) create queue 4) try this client code with user nobody with password nobody var container = require( 'rhea' ); var args = require( 'yargs' ).options({ 'm' : { alias: 'messages' , default : 10, describe: 'number of messages to send' }, 'n' : { alias: 'address' , default : 'jms.queue.examples_nevim_neco_pepa' , describe: 'name of node (e.g. queue) to which messages are sent' }, 'p' : { alias: 'port' , default : 5672, describe: 'port to connect to' }, 'h' : { alias: 'host' , default : "10.34.124.125" , describe: 'ip host' }, 'u' : { alias: 'username' , default : "admin" , describe: 'username' }, 's' : { alias: 'password' , default : "admin" , describe: 'password' }, }).help( 'help' ).argv; var confirmed = 0, sent = 0; var total = args.messages; var message = {}; message[ 'body' ] = {}; //body message.body = "test string message" container.on( 'sendable' , function (context) { while (context.sender.sendable() && sent < total) { sent++; console.log( 'sent ' + sent); context.sender.send(message); } }); container.on( 'accepted' , function (context) { if (++confirmed === total) { console.log( "all messages confirmed" ) context.connection.close() } }); container.on( 'disconnected' , function (context) { sent = confirmed; }); container.connect({ 'username' : args.username, 'password' : args.password, 'host' : args.host, 'port' :args.port}).open_sender(args.address);

      When I try send message with user, which doesn't permissions for sending and receiving messages from AMQ7 broker, client stuck.

        1. artemis_log.txt
          84 kB
        2. artemis-roles.properties
          0.0 kB
        3. artemis-users.properties
          0.1 kB
        4. broker.xml
          2 kB
        5. login.config
          0.2 kB

            gordonsim Gordon Sim
            dkornel@redhat.com David Kornel
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: