Get the (internal) Queue name for this message process.
491561
public String getQueueName(boolean bDefaultIfNone)
    {
        String strName = null;
        Record recQueueName = ((ReferenceField)this.getField(MessageProcessInfo.QUEUE_NAME_ID)).getReference();
        if ((recQueueName != null) && (recQueueName.getEditMode() == DBConstants.EDIT_CURRENT))
            strName = recQueueName.getField(QueueName.CODE).toString();
        if ((strName == null) || (strName.length() == 0))
            if (bDefaultIfNone)
        {
            int iMessageInfoType = MessageInfoType.REQUEST_ID;
            Record recMessageInfo = ((ReferenceField)this.getField(MessageProcessInfo.MESSAGE_INFO_ID)).getReference();
            if ((recMessageInfo != null) && (recMessageInfo.getEditMode() == DBConstants.EDIT_CURRENT))
                iMessageInfoType = (int)recMessageInfo.getField(MessageInfo.MESSAGE_INFO_TYPE_ID).getValue();
            if (iMessageInfoType == MessageInfoType.REQUEST_ID)
                strName = MessageConstants.TRX_SEND_QUEUE;
            else
                strName = MessageConstants.TRX_RECEIVE_QUEUE;
        }
        return strName;
    }
1099968
def process_messages_loop_internal(self):
        
        logging.info("Starting work queue loop.")
        self.connection.receive_loop_with_callback(self.queue_name, self.process_message)
887936
protected function getQueueNameListForMonitor(){

        $queueNameListInRedis = $this->redisClientForQueue->keys('queues:*');

        $excludeQueueNameList = Config::get('queue_monitor')['excludeQueues'];
        $excludeFullQueueNameList = [];

        if (!empty($excludeQueueNameList)) {
            foreach ($excludeQueueNameList as $excludeQueueName){
                $excludeFullQueueNameList[] = 'queues:'.$excludeQueueName;
                $excludeFullQueueNameList[] = 'queues:'.$excludeQueueName.':delayed';
                $excludeFullQueueNameList[] = 'queues:'.$excludeQueueName.':reserved';
            }
        }

        return  array_diff($queueNameListInRedis , $excludeFullQueueNameList);
    }
1266458
HashSet getQueuePointGuessSet()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getQueuePointGuessSet");

    HashSet theQueuePoints = null;

    synchronized (_queuePointsGuessSet)
    {
      theQueuePoints = (HashSet) _queuePointsGuessSet.clone();
    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getQueuePointGuessSet", theQueuePoints);

    return theQueuePoints;
  }
752649
def queue(self):
        """"""
        entry = self._proto.commandQueueEntry
        if entry.HasField('queueName'):
            return entry.queueName
        return None
946528
def get_internal_queue(self, thread_id):
        
        if thread_id.startswith('__frame__'):
            thread_id = thread_id[thread_id.rfind('|') + 1:]
        return self._cmd_queue[thread_id]
867196
public long getNumberOfQueuedMessages() {
		if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
			SibTr.entry(tc, "getNumberOfQueuedMessages");

		long depth = itemStream.getTotalMsgCount();

		if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
			SibTr.exit(tc, "getNumberOfQueuedMessages", Long.valueOf(depth));

		return depth;
	}
175258
public static String getMEName(Object o) {
        String meName;

    if (!threadLocalStack.isEmpty()) {
      meName = threadLocalStack.peek();
    } else {
      meName = DEFAULT_ME_NAME;
    }

    String str = "";

    if (o != null) {
      str = "/" + Integer.toHexString(System.identityHashCode(o));
    }
  // Defect 91793 to avoid SIBMessage in Systemout.log starting with [:] 
    return "";
  }
996267
def xq_name(queue_name):
    
    if queue_name.endswith(".XQ"):
        return queue_name

    if queue_name.endswith(".DQ"):
        queue_name = queue_name[:-3]
    return queue_name + ".XQ"
1260165
def name(self):
        """"""
        return ffi.string(lib.EnvGetDefmessageHandlerName(
            self._env, self._cls, self._idx)).decode()
538045
public synchronized Name getServiceName() {
        if (size() < 2) {
            return null;
        }
        if (cachedServiceName == null) {
            cachedServiceName = getCompositeKey().getPrefix(size() - 1);
        }
        return cachedServiceName;
    }
87205
def get_queues(self):
        """"""
        res = self.celery.control.inspect().active_queues() or dict()
        return [result.get('name') for host in res.values() for result in host]
305056
def dq_name(queue_name):
    
    if queue_name.endswith(".DQ"):
        return queue_name

    if queue_name.endswith(".XQ"):
        queue_name = queue_name[:-3]
    return queue_name + ".DQ"
287770
def names(self):
        
        data = None
        if not self.connected:
            raise ConnectionError('Queue is not connected')

        try:
            data = self.rdb.keys("retaskqueue-*")
        except redis.exceptions.ConnectionError as err:
            raise ConnectionError(str(err))

        return [name[12:] for name in data]
369263
protected String checkHeap() {
    for(int i = 1; i < size; i++) {
      final int parent = (i - 1) >>> 1;
      if(comparator.compare(queue[parent], queue[i]) > 0) {
        return "@" + parent + ": " + queue[parent] + " < @" + i + ": " + queue[i];
      }
    }
    return null;
  }
858104
public String getMEName()
   {
     if (tc.isEntryEnabled())
       SibTr.entry(tc, "getMEName");
     
     String meName = _messageProcessor.getMessagingEngineName();
     
     if (tc.isEntryEnabled())
       SibTr.exit(tc, "getMEName", meName);
     return meName;
   }
749204
public MessageProcessInfoModel getMessageProcessInfo(String strMessageInfoType, String strContactType, String strRequestType, String strMessageProcessType, String strProcessType)
    {
        return null;    // No thin impl
    }