1 18 package org.apache.activemq.openwire.v2; 19 20 import java.io.DataInputStream ; 21 import java.io.DataOutputStream ; 22 import java.io.IOException ; 23 24 import org.apache.activemq.openwire.*; 25 import org.apache.activemq.command.*; 26 27 28 39 public class BrokerInfoTest extends BaseCommandTestSupport { 40 41 42 public static BrokerInfoTest SINGLETON = new BrokerInfoTest(); 43 44 public Object createObject() throws Exception { 45 BrokerInfo info = new BrokerInfo(); 46 populateObject(info); 47 return info; 48 } 49 50 protected void populateObject(Object object) throws Exception { 51 super.populateObject(object); 52 BrokerInfo info = (BrokerInfo) object; 53 54 info.setBrokerId(createBrokerId("BrokerId:1")); 55 info.setBrokerURL("BrokerURL:2"); 56 { 57 BrokerInfo value[] = new BrokerInfo[0]; 58 for( int i=0; i < 0; i++ ) { 59 value[i] = createBrokerInfo("PeerBrokerInfos:3"); 60 } 61 info.setPeerBrokerInfos(value); 62 } 63 info.setBrokerName("BrokerName:4"); 64 info.setSlaveBroker(true); 65 info.setMasterBroker(false); 66 info.setFaultTolerantConfiguration(true); 67 info.setDuplexConnection(false); 68 info.setNetworkConnection(true); 69 info.setConnectionId(1); 70 } 71 } 72 | Popular Tags |