import java.lang.management.ManagementFactory;
import javax.management.MBeanServer;
import javax.management.ObjectName;
public class Example
{
public static void main(String[] args) throws Exception
{
MBeanServer server = ManagementFactory.getPlatformMBeanServer();
ObjectName objectName = Names.QMAN_OBJECT_NAME;
String host = "qpid.host.com";
int port = 2005;
String username ="qpid_username";
String password ="qpid_password";
String virtualHost = "qpid_virtualhost";
int initialPoolCapacity = 3; int maxPoolCapacity = 4; int maxWaitTimeout = 2000;
server.invoke(
objectName,
"addBroker",
new Object []{
host,
port,
username,
password,
virtualHost,
initialPoolCapacity,
maxPoolCapacity,
maxWaitTimeout},
new String[] {
String.class.getName(),
int.class.getName(),
String.class.getName(),
String.class.getName(),
String.class.getName(),
int.class.getName(),
int.class.getName(),
long.class.getName()
});
}
}