public class DmsConsumeRecord
extends java.lang.Object
构造器和说明 |
---|
DmsConsumeRecord()
构造函数
|
DmsConsumeRecord(java.lang.Object storeRecord)
构造函数
|
限定符和类型 | 方法和说明 |
---|---|
int |
getFailedCount() |
java.lang.String |
getHandler()
getHandler
|
byte[] |
getKeyBytes() |
int |
getKeyByteSize() |
DmsProduceRecord |
getMessage()
返回 message
|
byte[] |
getMessageBytes()
返回 messageBytes
|
int |
getMessageByteSize()
返回 messageByteSize
|
long |
getMsLoadTick() |
long |
getOffset()
返回 offset
|
java.lang.Integer |
getRedeliverTimes()
返回 getRedeliverTimes
|
java.lang.Object |
getStoreRecord() |
int |
incFailedCount()
失败次数加1
|
void |
setHandler(java.lang.String handler)
对handler进行赋值
|
void |
setKeyBytes(byte[] keyBytes) |
void |
setKeyByteSize(int keyByteSize) |
void |
setMessage(DmsProduceRecord message)
对message进行赋值
|
void |
setMessageBytes(byte[] messageBytes)
对messageBytes进行赋值
|
void |
setMessageByteSize(int messageByteSize)
对messageByteSize进行赋值
|
void |
setMsLoadTick(long msLoadTick) |
void |
setOffset(long offset)
对offset进行赋值
|
void |
setRedeliverTimes(java.lang.Integer redeliverTimes)
对getRedeliverTimes进行赋值
|
void |
setStoreRecord(java.lang.Object storeRecord) |
java.lang.String |
toString() |
public DmsConsumeRecord()
public DmsConsumeRecord(java.lang.Object storeRecord)
storeRecord
- storeRecordpublic java.lang.String getHandler()
public void setHandler(java.lang.String handler)
handler
- handlerpublic DmsProduceRecord getMessage()
public void setMessage(DmsProduceRecord message)
message
- messagepublic long getOffset()
public void setOffset(long offset)
offset
- offsetpublic int getMessageByteSize()
public void setMessageByteSize(int messageByteSize)
messageByteSize
- messageByteSizepublic byte[] getMessageBytes()
public int getKeyByteSize()
public void setKeyByteSize(int keyByteSize)
public void setMessageBytes(byte[] messageBytes)
messageBytes
- messageBytespublic int getFailedCount()
public int incFailedCount()
public java.lang.Object getStoreRecord()
public void setStoreRecord(java.lang.Object storeRecord)
public byte[] getKeyBytes()
public void setKeyBytes(byte[] keyBytes)
public long getMsLoadTick()
public void setMsLoadTick(long msLoadTick)
public java.lang.Integer getRedeliverTimes()
public void setRedeliverTimes(java.lang.Integer redeliverTimes)
redeliverTimes
- redeliverTimespublic java.lang.String toString()
toString
在类中 java.lang.Object