1 18 package org.apache.activemq.openwire.v3; 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 ConnectionControlTest extends BaseCommandTestSupport { 40 41 42 public static ConnectionControlTest SINGLETON = new ConnectionControlTest(); 43 44 public Object createObject() throws Exception { 45 ConnectionControl info = new ConnectionControl(); 46 populateObject(info); 47 return info; 48 } 49 50 protected void populateObject(Object object) throws Exception { 51 super.populateObject(object); 52 ConnectionControl info = (ConnectionControl) object; 53 54 info.setClose(true); 55 info.setExit(false); 56 info.setFaultTolerant(true); 57 info.setResume(false); 58 info.setSuspend(true); 59 } 60 } 61 | Popular Tags |