src/java/iotcloud/RejectedMessage.java

   1 package iotcloud;
   2 import java.nio.ByteBuffer;
   3
   4 class RejectedMessage extends Entry {
   5         private long machineid;
   6         private long seqnum;
   7         private boolean equalto;
   8
   9         RejectedMessage(long _machineid, long _seqnum, boolean _equalto) {
  10                 machineid=_machineid;
  11                 seqnum=_seqnum;
  12                 equalto=_equalto;
  13         }
  14
  15         static Entry decode(ByteBuffer bb) {
  16                 long machineid=bb.getLong();
  17                 long seqnum=bb.getLong();
  18                 byte equalto=bb.get();
  19                 return new RejectedMessage(machineid, seqnum, equalto==1);
  20         }
  21
  22         void encode(ByteBuffer bb) {
  23                 bb.put(Entry.TypeRejectedMessage);
  24                 bb.putLong(machineid);
  25                 bb.putLong(seqnum);
  26                 bb.put(equalto?(byte)1:(byte)0);
  27         }
  28
  29         int getSize() {
  30                 return 2*Long.BYTES + 2*Byte.BYTES;
  31         }
  32 }