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 ConnectionInfoTest extends BaseCommandTestSupport { 40 41 42 public static ConnectionInfoTest SINGLETON = new ConnectionInfoTest(); 43 44 public Object createObject() throws Exception { 45 ConnectionInfo info = new ConnectionInfo(); 46 populateObject(info); 47 return info; 48 } 49 50 protected void populateObject(Object object) throws Exception { 51 super.populateObject(object); 52 ConnectionInfo info = (ConnectionInfo) object; 53 54 info.setConnectionId(createConnectionId("ConnectionId:1")); 55 info.setClientId("ClientId:2"); 56 info.setPassword("Password:3"); 57 info.setUserName("UserName:4"); 58 { 59 BrokerId value[] = new BrokerId[2]; 60 for( int i=0; i < 2; i++ ) { 61 value[i] = createBrokerId("BrokerPath:5"); 62 } 63 info.setBrokerPath(value); 64 } 65 info.setBrokerMasterConnector(true); 66 info.setManageable(false); 67 info.setClientMaster(true); 68 } 69 } 70 | Popular Tags |