public class org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin extends org.apache.activemq.partition.PartitionBrokerPlugin
{
java.lang.String zkAddress;
java.lang.String zkPassword;
java.lang.String zkPath;
java.lang.String zkSessionTmeout;
public void <init>()
{
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
specialinvoke v.<org.apache.activemq.partition.PartitionBrokerPlugin: void <init>()>();
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkAddress> = "127.0.0.1:2181";
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkPath> = "/broker-assignments";
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkSessionTmeout> = "10s";
return;
}
public org.apache.activemq.broker.Broker installPlugin(org.apache.activemq.broker.Broker) throws java.lang.Exception
{
org.apache.activemq.broker.Broker v;
org.apache.activemq.partition.ZooKeeperPartitionBroker v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v := @parameter: org.apache.activemq.broker.Broker;
v = new org.apache.activemq.partition.ZooKeeperPartitionBroker;
specialinvoke v.<org.apache.activemq.partition.ZooKeeperPartitionBroker: void <init>(org.apache.activemq.broker.Broker,org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin)>(v, v);
return v;
}
public java.lang.String getZkAddress()
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v = v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkAddress>;
return v;
}
public void setZkAddress(java.lang.String)
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v := @parameter: java.lang.String;
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkAddress> = v;
return;
}
public java.lang.String getZkPassword()
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v = v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkPassword>;
return v;
}
public void setZkPassword(java.lang.String)
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v := @parameter: java.lang.String;
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkPassword> = v;
return;
}
public java.lang.String getZkPath()
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v = v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkPath>;
return v;
}
public void setZkPath(java.lang.String)
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v := @parameter: java.lang.String;
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkPath> = v;
return;
}
public java.lang.String getZkSessionTmeout()
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v = v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkSessionTmeout>;
return v;
}
public void setZkSessionTmeout(java.lang.String)
{
java.lang.String v;
org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin v;
v := @this: org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin;
v := @parameter: java.lang.String;
v.<org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin: java.lang.String zkSessionTmeout> = v;
return;
}
}