1 18 19 package org.apache.activemq.openwire.v1; 20 21 import java.io.DataInput ; 22 import java.io.DataOutput ; 23 import java.io.IOException ; 24 25 import org.apache.activemq.openwire.*; 26 import org.apache.activemq.command.*; 27 28 29 30 41 public class BrokerInfoMarshaller extends BaseCommandMarshaller { 42 43 47 public byte getDataStructureType() { 48 return BrokerInfo.DATA_STRUCTURE_TYPE; 49 } 50 51 54 public DataStructure createObject() { 55 return new BrokerInfo(); 56 } 57 58 65 public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { 66 super.tightUnmarshal(wireFormat, o, dataIn, bs); 67 68 BrokerInfo info = (BrokerInfo)o; 69 info.setBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); 70 info.setBrokerURL(tightUnmarshalString(dataIn, bs)); 71 72 if (bs.readBoolean()) { 73 short size = dataIn.readShort(); 74 org.apache.activemq.command.BrokerInfo value[] = new org.apache.activemq.command.BrokerInfo[size]; 75 for( int i=0; i < size; i++ ) { 76 value[i] = (org.apache.activemq.command.BrokerInfo) tightUnmarsalNestedObject(wireFormat,dataIn, bs); 77 } 78 info.setPeerBrokerInfos(value); 79 } 80 else { 81 info.setPeerBrokerInfos(null); 82 } 83 info.setBrokerName(tightUnmarshalString(dataIn, bs)); 84 info.setSlaveBroker(bs.readBoolean()); 85 info.setMasterBroker(bs.readBoolean()); 86 info.setFaultTolerantConfiguration(bs.readBoolean()); 87 88 } 89 90 91 94 public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { 95 96 BrokerInfo info = (BrokerInfo)o; 97 98 int rc = super.tightMarshal1(wireFormat, o, bs); 99 rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getBrokerId(), bs); 100 rc += tightMarshalString1(info.getBrokerURL(), bs); 101 rc += tightMarshalObjectArray1(wireFormat, info.getPeerBrokerInfos(), bs); 102 rc += tightMarshalString1(info.getBrokerName(), bs); 103 bs.writeBoolean(info.isSlaveBroker()); 104 bs.writeBoolean(info.isMasterBroker()); 105 bs.writeBoolean(info.isFaultTolerantConfiguration()); 106 107 return rc + 0; 108 } 109 110 117 public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { 118 super.tightMarshal2(wireFormat, o, dataOut, bs); 119 120 BrokerInfo info = (BrokerInfo)o; 121 tightMarshalCachedObject2(wireFormat, (DataStructure)info.getBrokerId(), dataOut, bs); 122 tightMarshalString2(info.getBrokerURL(), dataOut, bs); 123 tightMarshalObjectArray2(wireFormat, info.getPeerBrokerInfos(), dataOut, bs); 124 tightMarshalString2(info.getBrokerName(), dataOut, bs); 125 bs.readBoolean(); 126 bs.readBoolean(); 127 bs.readBoolean(); 128 129 } 130 131 138 public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { 139 super.looseUnmarshal(wireFormat, o, dataIn); 140 141 BrokerInfo info = (BrokerInfo)o; 142 info.setBrokerId((org.apache.activemq.command.BrokerId) looseUnmarsalCachedObject(wireFormat, dataIn)); 143 info.setBrokerURL(looseUnmarshalString(dataIn)); 144 145 if (dataIn.readBoolean()) { 146 short size = dataIn.readShort(); 147 org.apache.activemq.command.BrokerInfo value[] = new org.apache.activemq.command.BrokerInfo[size]; 148 for( int i=0; i < size; i++ ) { 149 value[i] = (org.apache.activemq.command.BrokerInfo) looseUnmarsalNestedObject(wireFormat,dataIn); 150 } 151 info.setPeerBrokerInfos(value); 152 } 153 else { 154 info.setPeerBrokerInfos(null); 155 } 156 info.setBrokerName(looseUnmarshalString(dataIn)); 157 info.setSlaveBroker(dataIn.readBoolean()); 158 info.setMasterBroker(dataIn.readBoolean()); 159 info.setFaultTolerantConfiguration(dataIn.readBoolean()); 160 161 } 162 163 164 167 public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { 168 169 BrokerInfo info = (BrokerInfo)o; 170 171 super.looseMarshal(wireFormat, o, dataOut); 172 looseMarshalCachedObject(wireFormat, (DataStructure)info.getBrokerId(), dataOut); 173 looseMarshalString(info.getBrokerURL(), dataOut); 174 looseMarshalObjectArray(wireFormat, info.getPeerBrokerInfos(), dataOut); 175 looseMarshalString(info.getBrokerName(), dataOut); 176 dataOut.writeBoolean(info.isSlaveBroker()); 177 dataOut.writeBoolean(info.isMasterBroker()); 178 dataOut.writeBoolean(info.isFaultTolerantConfiguration()); 179 180 } 181 } 182 | Popular Tags |