public static String getTaskType(String queue) {

        if (StringUtils.isBlank(queue)) {
            return StringUtils.EMPTY;
        }

        int domainSeperatorIndex = StringUtils.indexOf(queue, DOMAIN_SEPARATOR);
        int startIndex;
        if (domainSeperatorIndex == -1) {
            startIndex = 0;
        } else {
            startIndex = domainSeperatorIndex + 1;
        }
        int endIndex = StringUtils.indexOf(queue, EXECUTION_NAME_SPACE_SEPARATOR);

        if (endIndex == -1) {
            endIndex = StringUtils.lastIndexOf(queue, ISOLATION_SEPARATOR);
        }
        if (endIndex == -1) {
            endIndex = queue.length();
        }

        return StringUtils.substring(queue, startIndex, endIndex);
    }
Creates a queue name string using <code>taskType</code>, <code>domain</code>, <code>
isolationGroupId</code> and <code>executionNamespace</code>.

@return domain:taskType@eexecutionNameSpace-isolationGroupId.
core/src/main/java/com/netflix/conductor/core/utils/QueueUtils.java