package com.dobbinsoft.fw.support.mq;
|
|
import java.io.Serializable;
|
import java.util.concurrent.FutureTask;
|
|
/**
|
* ClassName: ReliableMessageHandler
|
* Description: 可靠队列消息处理器
|
*
|
* @author: e-weichaozheng
|
* @date: 2021-05-25
|
*/
|
public interface ReliableMessageHandler<T extends Serializable> {
|
|
/**
|
* @param t
|
* @param bytes 直接过来的字节流
|
* @return 返回true，表示Message确认，返回false，表示不确认。同时，true表示此次消息事务处理提交。
|
*/
|
public boolean handle(T t, byte[] bytes);
|
|
public String getTopic();
|
|
public Class<T> getMessageClass();
|
|
}
|
