1 18 package org.apache.activemq.openwire.v1; 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 DestinationInfoTest extends BaseCommandTestSupport { 40 41 42 public static DestinationInfoTest SINGLETON = new DestinationInfoTest(); 43 44 public Object createObject() throws Exception { 45 DestinationInfo info = new DestinationInfo(); 46 populateObject(info); 47 return info; 48 } 49 50 51 protected void populateObject(Object object) throws Exception { 52 super.populateObject(object); 53 DestinationInfo info = (DestinationInfo) object; 54 info.setConnectionId(createConnectionId("ConnectionId:1")); 55 info.setDestination(createActiveMQDestination("Destination:2")); 56 info.setOperationType((byte) 1); 57 info.setTimeout(1); 58 59 { 60 BrokerId value[] = new BrokerId[2]; 61 for( int i=0; i < 2; i++ ) { 62 value[i] = createBrokerId("BrokerPath:3"); 63 } 64 info.setBrokerPath(value); 65 } 66 67 } 68 } 69 | Popular Tags |