AMQQueueMBean.java 文件源码

/**
 * initialises the openmbean data types
 */
private static void init() throws OpenDataException
{
    _msgContentAttributeTypes[0] = SimpleType.LONG; // For message id
    _msgContentAttributeTypes[1] = SimpleType.STRING; // For MimeType
    _msgContentAttributeTypes[2] = SimpleType.STRING; // For Encoding
    _msgContentAttributeTypes[3] = new ArrayType(1, SimpleType.BYTE); // For message content
    _msgContentType = new CompositeType("Message Content", "AMQ Message Content",
                VIEW_MSG_CONTENT_COMPOSITE_ITEM_NAMES_DESC.toArray(new String[VIEW_MSG_CONTENT_COMPOSITE_ITEM_NAMES_DESC.size()]),
                VIEW_MSG_CONTENT_COMPOSITE_ITEM_NAMES_DESC.toArray(new String[VIEW_MSG_CONTENT_COMPOSITE_ITEM_NAMES_DESC.size()]),
                _msgContentAttributeTypes);

    _msgAttributeTypes[0] = SimpleType.LONG; // For message id
    _msgAttributeTypes[1] = new ArrayType(1, SimpleType.STRING); // For header attributes
    _msgAttributeTypes[2] = SimpleType.LONG; // For size
    _msgAttributeTypes[3] = SimpleType.BOOLEAN; // For redelivered
    _msgAttributeTypes[4] = SimpleType.LONG; // For queue position

    _messageDataType = new CompositeType("Message", "AMQ Message", 
            VIEW_MSGS_COMPOSITE_ITEM_NAMES_DESC.toArray(new String[VIEW_MSGS_COMPOSITE_ITEM_NAMES_DESC.size()]),
            VIEW_MSGS_COMPOSITE_ITEM_NAMES_DESC.toArray(new String[VIEW_MSGS_COMPOSITE_ITEM_NAMES_DESC.size()]), _msgAttributeTypes);
    _messagelistDataType = new TabularType("Messages", "List of messages", _messageDataType,
                                            VIEW_MSGS_TABULAR_UNIQUE_INDEX.toArray(new String[VIEW_MSGS_TABULAR_UNIQUE_INDEX.size()]));
}