code: function() {
          activemq = new PodActiveMQ({
            username: params.queueUsername,
            password: params.queuePassword,
            host: params.queueHost,
            port: params.queuePort,
            timeout: params.queueConnectionTimeout
          });
  
          activemq.on("init", function() {
            fireEvent("asyncReady");
  
            socketState = socketStateType.OPEN;
            fireEvent("stateChange", {
              queueState: socketState
            });
  
            pushSendDataQueueHandler();
  
            activemq.subscribe({
              destination: params.queueReceive,
              ack: "client-individual"
            }, function(message) {
              handleSocketMessage(JSON.parse(message));
              if (onReceiveLogging) {
                asyncLogger("Receive", JSON.parse(message));
              }
            });
  
          });
  
          activemq.on("error", function(msg) {
            fireEvent("error", msg);
  
            socketState = socketStateType.CLOSED;
  
            fireEvent("stateChange", {
              queueState: socketState
            });
          })
        }
docs: *****************************************************
  P R I V A T E   M E T H O D S            *
  *****************************************************