AMQProtocolSessionMBean.java 文件源码

/**
 * Creates the list of channels in tabular form from the _channelMap.
 *
 * @return list of channels in tabular form.
 * @throws OpenDataException
 */
public TabularData channels() throws OpenDataException
{
    TabularDataSupport channelsList = new TabularDataSupport(_channelsType);
    List<AMQChannel> list = _protocolSession.getChannels();

    for (AMQChannel channel : list)
    {
        Object[] itemValues =
            {
                channel.getChannelId(), channel.isTransactional(),
                (channel.getDefaultQueue() != null) ? channel.getDefaultQueue().getNameShortString().asString() : null,
                channel.getUnacknowledgedMessageMap().size(), channel.getBlocking()
            };

        CompositeData channelData = new CompositeDataSupport(_channelType, 
                COMPOSITE_ITEM_NAMES_DESC.toArray(new String[COMPOSITE_ITEM_NAMES_DESC.size()]), itemValues);
        channelsList.put(channelData);
    }

    return channelsList;
}