1 18 19 package org.apache.activemq.openwire.v2; 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 ConnectionInfoMarshaller extends BaseCommandMarshaller { 42 43 47 public byte getDataStructureType() { 48 return ConnectionInfo.DATA_STRUCTURE_TYPE; 49 } 50 51 54 public DataStructure createObject() { 55 return new ConnectionInfo(); 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 ConnectionInfo info = (ConnectionInfo)o; 69 info.setConnectionId((org.apache.activemq.command.ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); 70 info.setClientId(tightUnmarshalString(dataIn, bs)); 71 info.setPassword(tightUnmarshalString(dataIn, bs)); 72 info.setUserName(tightUnmarshalString(dataIn, bs)); 73 74 if (bs.readBoolean()) { 75 short size = dataIn.readShort(); 76 org.apache.activemq.command.BrokerId value[] = new org.apache.activemq.command.BrokerId[size]; 77 for( int i=0; i < size; i++ ) { 78 value[i] = (org.apache.activemq.command.BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs); 79 } 80 info.setBrokerPath(value); 81 } 82 else { 83 info.setBrokerPath(null); 84 } 85 info.setBrokerMasterConnector(bs.readBoolean()); 86 info.setManageable(bs.readBoolean()); 87 info.setClientMaster(bs.readBoolean()); 88 89 } 90 91 92 95 public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { 96 97 ConnectionInfo info = (ConnectionInfo)o; 98 99 int rc = super.tightMarshal1(wireFormat, o, bs); 100 rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getConnectionId(), bs); 101 rc += tightMarshalString1(info.getClientId(), bs); 102 rc += tightMarshalString1(info.getPassword(), bs); 103 rc += tightMarshalString1(info.getUserName(), bs); 104 rc += tightMarshalObjectArray1(wireFormat, info.getBrokerPath(), bs); 105 bs.writeBoolean(info.isBrokerMasterConnector()); 106 bs.writeBoolean(info.isManageable()); 107 bs.writeBoolean(info.isClientMaster()); 108 109 return rc + 0; 110 } 111 112 119 public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { 120 super.tightMarshal2(wireFormat, o, dataOut, bs); 121 122 ConnectionInfo info = (ConnectionInfo)o; 123 tightMarshalCachedObject2(wireFormat, (DataStructure)info.getConnectionId(), dataOut, bs); 124 tightMarshalString2(info.getClientId(), dataOut, bs); 125 tightMarshalString2(info.getPassword(), dataOut, bs); 126 tightMarshalString2(info.getUserName(), dataOut, bs); 127 tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); 128 bs.readBoolean(); 129 bs.readBoolean(); 130 bs.readBoolean(); 131 132 } 133 134 141 public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { 142 super.looseUnmarshal(wireFormat, o, dataIn); 143 144 ConnectionInfo info = (ConnectionInfo)o; 145 info.setConnectionId((org.apache.activemq.command.ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); 146 info.setClientId(looseUnmarshalString(dataIn)); 147 info.setPassword(looseUnmarshalString(dataIn)); 148 info.setUserName(looseUnmarshalString(dataIn)); 149 150 if (dataIn.readBoolean()) { 151 short size = dataIn.readShort(); 152 org.apache.activemq.command.BrokerId value[] = new org.apache.activemq.command.BrokerId[size]; 153 for( int i=0; i < size; i++ ) { 154 value[i] = (org.apache.activemq.command.BrokerId) looseUnmarsalNestedObject(wireFormat,dataIn); 155 } 156 info.setBrokerPath(value); 157 } 158 else { 159 info.setBrokerPath(null); 160 } 161 info.setBrokerMasterConnector(dataIn.readBoolean()); 162 info.setManageable(dataIn.readBoolean()); 163 info.setClientMaster(dataIn.readBoolean()); 164 165 } 166 167 168 171 public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { 172 173 ConnectionInfo info = (ConnectionInfo)o; 174 175 super.looseMarshal(wireFormat, o, dataOut); 176 looseMarshalCachedObject(wireFormat, (DataStructure)info.getConnectionId(), dataOut); 177 looseMarshalString(info.getClientId(), dataOut); 178 looseMarshalString(info.getPassword(), dataOut); 179 looseMarshalString(info.getUserName(), dataOut); 180 looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); 181 dataOut.writeBoolean(info.isBrokerMasterConnector()); 182 dataOut.writeBoolean(info.isManageable()); 183 dataOut.writeBoolean(info.isClientMaster()); 184 185 } 186 } 187 | Popular Tags |