Configuration Manager Proxy

private static void displayBrokerNames(ConfigManagerProxy cmp)

{

try

{

TopologyProxy topology = cmp.getTopology();

if (topology != null)

{

Enumeration allBrokers = topology.getBrokers(null);

while (allBrokers.hasMoreElements())

{

BrokerProxy thisBroker =
(BrokerProxy) allBrokers.nextElement();

System.out.println("Broker "+
thisBroker.getName());

} //while

} //if

} //try

catch(ConfigManagerProxyPropertyNotInitializedException ex)

{

System.err.println("Comms problem! "+ex);

}



}

private static void deleteBroker(ConfigManagerProxy cmp,
String brokerName) {

try {

TopologyProxy topology = cmp.getTopology();

if (topology != null) {

topology.deleteBroker(brokerName);



} //if

} //try

catch (ConfigManagerProxyException ex) {

System.err.println("Problem! " + ex);

}

}

private static void displayBrokerEGs(ConfigManagerProxy cmp,

String brokerName) {

try {

TopologyProxy topology = cmp.getTopology();

if (topology != null) {

BrokerProxy broker =
topology.getBrokerByName(brokerName);



Enumeration executiongroups =
broker.getExecutionGroups(null);



while (executiongroups.hasMoreElements()) {

ExecutionGroupProxy executiongroup =
(ExecutionGroupProxy) executiongroups

.nextElement();

System.out.println("EG-> " +
executiongroup.getName());



Enumeration deployedObjects =
executiongroup.getDeployedObjects();



while (deployedObjects.hasMoreElements()) {

DeployedObject deployedObject =
(DeployedObject)
deployedObjects.nextElement();

System.out.println(deployedObject.getName()
+ " " + deployedObject.getFullName());

} //while

} //while

} //if

} //try

catch (ConfigManagerProxyPropertyNotInitializedException ex) {

System.err.println("Comms problem! " + ex);

}



}

private static void displayACLs(ConfigManagerProxy cmp)

{

AccessControlEntry[] ace = cmp.getAccessControlEntries();


for (int i=0; i<ace.length; i++)

{

System.out.println(ace[i].getType() + " " + ace[i].getName() +

" has " + ace[i].getPermission());

}

}

private static void createACL(ConfigManagerProxy cmp,
String user) {

AccessControlEntry acls[] = new AccessControlEntry[1];



AccessControlEntry acl = new AccessControlEntry(user,

AccessControlEntryPrincipalType.user,

AccessControlEntryPermission.fullControl);



acls[0] = acl;



try {

cmp.addAccessControlEntries(acls);

} catch (ConfigManagerProxyLoggedException e) {



e.printStackTrace();

}

}

private static void displaySubs(ConfigManagerProxy cmp)
throws Exception

{

String topics = null;

// all topics

//String brokers = "BROKER%";

String brokers = null;

// all brokers beginning 'BROKER'

String users = null;

// all users

String subsPoints = null;

// all subscriptions points

GregorianCalendar start = null;

// no start date

GregorianCalendar end = new GregorianCalendar();

// to the present

SubscriptionsProxy s = cmp.getSubscriptions(topics, brokers,
users, subsPoints, start, end);

Enumeration elements=s.elements();

for (Enumeration e = s.elements() ; e.hasMoreElements() ;)

{

System.out.println(e.nextElement());

}

}