public TabularData getQueue()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistPublisherJMX.java [82:101]

• 20 lines of code
• 4 McCabe index (conditional complexity)

    public TabularData getQueue(String queueName) throws MBeanException {
        try {
            String[] itemNames = new String[] {COL_ID, COL_OFFSET};
            OpenType<?>[] itemTypes = new OpenType[]{SimpleType.STRING, SimpleType.LONG};
            CompositeType rowType = new CompositeType("Offsets", "Queue Offsets", itemNames, itemNames, itemTypes);
            TabularType type = new TabularType("type", "desc", rowType, new String[] {COL_ID});
            TabularDataSupport table = new TabularDataSupport(type);
            DistributionQueue queue = distPublisher.getQueue(queueName);
            if (queue != null) {
                for (DistributionQueueEntry item : queue.getEntries(0, 1000)) {
                    CompositeData row = new CompositeDataSupport(rowType, itemNames,
                            new Object[] { item.getId(), item.getItem().get(COL_OFFSET)});
                    table.put(row);
                }
            }
            return table;
        } catch (OpenDataException e) {
            throw new MBeanException(e);
        }
    }