1 18 package org.apache.activemq.command; 19 20 import org.apache.activemq.state.CommandVisitor; 21 28 public class ConnectionControl extends BaseCommand{ 29 public static final byte DATA_STRUCTURE_TYPE=CommandTypes.CONNECTION_CONTROL; 30 protected boolean suspend; 31 protected boolean resume; 32 protected boolean close; 33 protected boolean exit; 34 protected boolean faultTolerant; 35 36 public byte getDataStructureType(){ 37 return DATA_STRUCTURE_TYPE; 38 } 39 40 public Response visit(CommandVisitor visitor) throws Exception { 41 return visitor.processConnectionControl(this); 42 } 43 44 48 public boolean isClose(){ 49 return close; 50 } 51 52 56 public void setClose(boolean close){ 57 this.close=close; 58 } 59 60 64 public boolean isExit(){ 65 return exit; 66 } 67 68 72 public void setExit(boolean exit){ 73 this.exit=exit; 74 } 75 76 80 public boolean isFaultTolerant(){ 81 return faultTolerant; 82 } 83 84 88 public void setFaultTolerant(boolean faultTolerant){ 89 this.faultTolerant=faultTolerant; 90 } 91 92 96 public boolean isResume(){ 97 return resume; 98 } 99 100 104 public void setResume(boolean resume){ 105 this.resume=resume; 106 } 107 108 112 public boolean isSuspend(){ 113 return suspend; 114 } 115 116 120 public void setSuspend(boolean suspend){ 121 this.suspend=suspend; 122 } 123 } 124 | Popular Tags |