1 4 package com.tc.net.protocol.delivery; 5 6 import com.tc.bytes.TCByteBuffer; 7 import com.tc.exception.ImplementMe; 8 import com.tc.net.protocol.TCNetworkHeader; 9 import com.tc.net.protocol.TCNetworkMessage; 10 import com.tc.net.protocol.delivery.OOOProtocolMessage; 11 12 15 public class TestProtocolMessage implements OOOProtocolMessage { 16 public TCNetworkMessage msg; 17 public long sent; 18 public long ack; 19 public boolean isAckRequest = false; 20 public boolean isSend = false; 21 22 public TestProtocolMessage(TCNetworkMessage msg, long sent, long ack) { 23 this.msg = msg; 24 this.sent = sent; 25 this.ack = ack; 26 } 27 28 public TestProtocolMessage() { 29 } 31 32 public long getAckSequence() { 33 return ack; 34 } 35 36 public long getSent() { 37 return sent; 38 } 39 40 public boolean isAckRequest() { 41 return isAckRequest; 42 } 43 44 public boolean isSend() { 45 return isSend; 46 } 47 48 51 52 public TCNetworkHeader getHeader() { 53 throw new ImplementMe(); 54 } 55 56 public TCNetworkMessage getMessagePayload() { 57 throw new ImplementMe(); 58 } 59 60 public TCByteBuffer[] getPayload() { 61 throw new ImplementMe(); 62 } 63 64 public TCByteBuffer[] getEntireMessageData() { 65 throw new ImplementMe(); 66 } 67 68 public boolean isSealed() { 69 throw new ImplementMe(); 70 } 71 72 public void seal() { 73 throw new ImplementMe(); 74 } 75 76 public int getDataLength() { 77 throw new ImplementMe(); 78 } 79 80 public int getHeaderLength() { 81 throw new ImplementMe(); 82 } 83 84 public int getTotalLength() { 85 throw new ImplementMe(); 86 } 87 88 public void wasSent() { 89 throw new ImplementMe(); 90 } 91 92 public void setSentCallback(Runnable callback) { 93 throw new ImplementMe(); 94 } 95 96 public Runnable getSentCallback() { 97 throw new ImplementMe(); 98 } 99 100 public void recycle() { 101 throw new ImplementMe(); 102 } 103 } | Popular Tags |