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 ConnectionControlMarshaller extends BaseCommandMarshaller { 42 43 47 public byte getDataStructureType() { 48 return ConnectionControl.DATA_STRUCTURE_TYPE; 49 } 50 51 54 public DataStructure createObject() { 55 return new ConnectionControl(); 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 ConnectionControl info = (ConnectionControl)o; 69 info.setClose(bs.readBoolean()); 70 info.setExit(bs.readBoolean()); 71 info.setFaultTolerant(bs.readBoolean()); 72 info.setResume(bs.readBoolean()); 73 info.setSuspend(bs.readBoolean()); 74 75 } 76 77 78 81 public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { 82 83 ConnectionControl info = (ConnectionControl)o; 84 85 int rc = super.tightMarshal1(wireFormat, o, bs); 86 bs.writeBoolean(info.isClose()); 87 bs.writeBoolean(info.isExit()); 88 bs.writeBoolean(info.isFaultTolerant()); 89 bs.writeBoolean(info.isResume()); 90 bs.writeBoolean(info.isSuspend()); 91 92 return rc + 0; 93 } 94 95 102 public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { 103 super.tightMarshal2(wireFormat, o, dataOut, bs); 104 105 ConnectionControl info = (ConnectionControl)o; 106 bs.readBoolean(); 107 bs.readBoolean(); 108 bs.readBoolean(); 109 bs.readBoolean(); 110 bs.readBoolean(); 111 112 } 113 114 121 public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { 122 super.looseUnmarshal(wireFormat, o, dataIn); 123 124 ConnectionControl info = (ConnectionControl)o; 125 info.setClose(dataIn.readBoolean()); 126 info.setExit(dataIn.readBoolean()); 127 info.setFaultTolerant(dataIn.readBoolean()); 128 info.setResume(dataIn.readBoolean()); 129 info.setSuspend(dataIn.readBoolean()); 130 131 } 132 133 134 137 public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { 138 139 ConnectionControl info = (ConnectionControl)o; 140 141 super.looseMarshal(wireFormat, o, dataOut); 142 dataOut.writeBoolean(info.isClose()); 143 dataOut.writeBoolean(info.isExit()); 144 dataOut.writeBoolean(info.isFaultTolerant()); 145 dataOut.writeBoolean(info.isResume()); 146 dataOut.writeBoolean(info.isSuspend()); 147 148 } 149 } 150 | Popular Tags |