import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
/**
 * Creates the authorization pluging
 * 
 * @param queueName
 *            the name of the queue
 * @param replyQueueName
 *            the name of the reply queue
 * @return the plugin
 * @throws Exception
 *             exception
 */
public static AuthorizationPlugin createAuthorizationPlugin(String queueName,
        String replyQueueName)
        throws Exception {
    AuthorizationEntry cntQueueEntry = new AuthorizationEntry();
    cntQueueEntry.setQueue(queueName);
    cntQueueEntry.setAdmin("users");
    cntQueueEntry.setRead("users");
    cntQueueEntry.setWrite("users");

    AuthorizationEntry cntQueuereplyEntry = new AuthorizationEntry();
    cntQueuereplyEntry.setQueue(replyQueueName + QUEUE_NAME_MATCH_ALL);
    cntQueuereplyEntry.setAdmin("users");
    cntQueuereplyEntry.setRead("users");
    cntQueuereplyEntry.setWrite("users");

    AuthorizationEntry advisoryEntry = new AuthorizationEntry();
    advisoryEntry.setTopic("ActiveMQ.Advisory" + QUEUE_NAME_MATCH_ALL);
    advisoryEntry.setAdmin("admins, users");
    advisoryEntry.setRead("admins, users");
    advisoryEntry.setWrite("admins, users");

    @SuppressWarnings("rawtypes")
    List<DestinationMapEntry> entries = new ArrayList<DestinationMapEntry>();

    entries.add(cntQueueEntry);
    entries.add(cntQueuereplyEntry);
    entries.add(advisoryEntry);

    DefaultAuthorizationMap defaultAuthorizationMap = new DefaultAuthorizationMap();
    defaultAuthorizationMap.setAuthorizationEntries(entries);

    AuthorizationPlugin authorizationPlugin = new AuthorizationPlugin();
    authorizationPlugin.setMap(defaultAuthorizationMap);

    return authorizationPlugin;
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
/**
 *
 * @org.apache.xbean.InitMethod
 */
@Override
public void afterPropertiesSet() throws Exception {
    for (DestinationMapEntry entry : authorizationEntries) {
        if (((XBeanAuthorizationEntry)entry).getGroupClass() == null) {
            ((XBeanAuthorizationEntry)entry).setGroupClass(groupClass);
        }
        ((XBeanAuthorizationEntry)entry).afterPropertiesSet();
    }
    super.setEntries(authorizationEntries);
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
/**
 * Sets the individual entries on the authorization map
 *
 * @org.apache.xbean.ElementType class="org.apache.activemq.security.AuthorizationEntry"
 */
@Override
@SuppressWarnings("rawtypes")
public void setAuthorizationEntries(List<DestinationMapEntry> entries) {
    this.authorizationEntries = entries;
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public DefaultAuthorizationMap(List<DestinationMapEntry> authorizationEntries) {
    setAuthorizationEntries(authorizationEntries);

}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
/**
 * Sets the individual entries on the authorization map
 */
@SuppressWarnings("rawtypes")
public void setAuthorizationEntries(List<DestinationMapEntry> entries) {
    super.setEntries(entries);
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
protected Class<? extends DestinationMapEntry> getEntryClass() {
    return AuthorizationEntry.class;
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
protected Class<? extends DestinationMapEntry> getEntryClass() {
    return PolicyEntry.class;
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
protected Class<? extends DestinationMapEntry> getEntryClass() {
    return RedeliveryPolicy.class;
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
@Override
public String toString() {
    return IntrospectionSupport.toString(this, DestinationMapEntry.class, null);
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
public void setEntries(List<DestinationMapEntry>  entries) {
    super.setEntries(entries);
}
 

import org.apache.activemq.filter.DestinationMapEntry; //导入依赖的package包/类
@Override
protected Class<? extends DestinationMapEntry> getEntryClass() {
   return PolicyEntry.class;
}