1 18 19 package org.apache.activemq.openwire.v3; 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 ConsumerControlMarshaller extends BaseCommandMarshaller { 42 43 47 public byte getDataStructureType() { 48 return ConsumerControl.DATA_STRUCTURE_TYPE; 49 } 50 51 54 public DataStructure createObject() { 55 return new ConsumerControl(); 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 ConsumerControl info = (ConsumerControl)o; 69 info.setClose(bs.readBoolean()); 70 info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); 71 info.setPrefetch(dataIn.readInt()); 72 info.setFlush(bs.readBoolean()); 73 info.setStart(bs.readBoolean()); 74 info.setStop(bs.readBoolean()); 75 76 } 77 78 79 82 public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { 83 84 ConsumerControl info = (ConsumerControl)o; 85 86 int rc = super.tightMarshal1(wireFormat, o, bs); 87 bs.writeBoolean(info.isClose()); 88 rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getConsumerId(), bs); 89 bs.writeBoolean(info.isFlush()); 90 bs.writeBoolean(info.isStart()); 91 bs.writeBoolean(info.isStop()); 92 93 return rc + 4; 94 } 95 96 103 public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { 104 super.tightMarshal2(wireFormat, o, dataOut, bs); 105 106 ConsumerControl info = (ConsumerControl)o; 107 bs.readBoolean(); 108 tightMarshalNestedObject2(wireFormat, (DataStructure)info.getConsumerId(), dataOut, bs); 109 dataOut.writeInt(info.getPrefetch()); 110 bs.readBoolean(); 111 bs.readBoolean(); 112 bs.readBoolean(); 113 114 } 115 116 123 public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { 124 super.looseUnmarshal(wireFormat, o, dataIn); 125 126 ConsumerControl info = (ConsumerControl)o; 127 info.setClose(dataIn.readBoolean()); 128 info.setConsumerId((org.apache.activemq.command.ConsumerId) looseUnmarsalNestedObject(wireFormat, dataIn)); 129 info.setPrefetch(dataIn.readInt()); 130 info.setFlush(dataIn.readBoolean()); 131 info.setStart(dataIn.readBoolean()); 132 info.setStop(dataIn.readBoolean()); 133 134 } 135 136 137 140 public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { 141 142 ConsumerControl info = (ConsumerControl)o; 143 144 super.looseMarshal(wireFormat, o, dataOut); 145 dataOut.writeBoolean(info.isClose()); 146 looseMarshalNestedObject(wireFormat, (DataStructure)info.getConsumerId(), dataOut); 147 dataOut.writeInt(info.getPrefetch()); 148 dataOut.writeBoolean(info.isFlush()); 149 dataOut.writeBoolean(info.isStart()); 150 dataOut.writeBoolean(info.isStop()); 151 152 } 153 } 154 | Popular Tags |