1 18 package org.apache.activemq.command; 19 20 import org.apache.activemq.state.CommandVisitor; 21 import org.apache.activemq.util.IntrospectionSupport; 22 23 27 public class KeepAliveInfo extends BaseCommand { 28 29 public static final byte DATA_STRUCTURE_TYPE=CommandTypes.KEEP_ALIVE_INFO; 30 31 private transient Endpoint from; 32 private transient Endpoint to; 33 34 public byte getDataStructureType() { 35 return DATA_STRUCTURE_TYPE; 36 } 37 38 public boolean isResponse() { 39 return false; 40 } 41 42 public boolean isMessageDispatch() { 43 return false; 44 } 45 46 public boolean isMessage() { 47 return false; 48 } 49 50 public boolean isMessageAck() { 51 return false; 52 } 53 54 public boolean isBrokerInfo() { 55 return false; 56 } 57 58 public boolean isWireFormatInfo() { 59 return false; 60 } 61 62 65 public Endpoint getFrom() { 66 return from; 67 } 68 69 public void setFrom(Endpoint from) { 70 this.from = from; 71 } 72 73 76 public Endpoint getTo() { 77 return to; 78 } 79 80 public void setTo(Endpoint to) { 81 this.to = to; 82 } 83 84 85 public Response visit(CommandVisitor visitor) throws Exception { 86 return visitor.processKeepAlive( this ); 87 } 88 89 public boolean isMarshallAware() { 90 return false; 91 } 92 93 public boolean isMessageDispatchNotification(){ 94 return false; 95 } 96 97 public boolean isShutdownInfo(){ 98 return false; 99 } 100 101 public String toString() { 102 return IntrospectionSupport.toString(this, KeepAliveInfo.class); 103 } 104 } 105 | Popular Tags |