在 Chronicle Queue 中使用方法 reader 和 writter

如何解决在 Chronicle Queue 中使用方法 reader 和 writter

大家好，我在使用 Chronicle Queue 进行日志记录的个人项目上遇到了困难。我有两种类型的消息要从队列本身读取和写入。我的问题是我正在使用使用方法读取器和写入器的策略来执行此操作，但是我需要为方法使用两个不同的名称来执行 Chronicle Queue 的操作。当我尝试使用传递接口的两个实现的方法读取器来读取具有相同名称的方法时，只有第一个从 Chronicle Abstraction 中查找。我想要一种方法只维护一个方法名称来从 Chronicle Queue 读取和写入不同的消息

为了更清楚，我将分享这个问题：

interface Message1Listener{
    void message(Message1 message);
}

interface Message2Listener{
    void message(Message2 message);
}

public class Messag1 extends SelfDescribingMarshallable{
    ByteBuffer text;
    
    public Message1(ByteBuffer text){
        this.text = text;
    }
}

public class Messag2 extends SelfDescribingMarshallable{
    ByteBuffer email;
    int uniqueKey;

    public Message1(ByteBuffer email,int uniqueKey){
        this.email = email;
        this.uniqueKey = uniqueKey;
    }
}

public Message1Processor implements Message1Listener{
    public void message(Message1 message){
        //do something with message
    }
}

public Message2Processor implements Message2Listener{
    public void message(Message2 message){
        //do something with message
    }
}

//write the messages
Message1Listener writer1 = queue.acquireAppender().methodWriter(Message1Listener.class);
Message2Listener writer2 = queue.acquireAppender().methodWriter(Message2Listener.class);

//read the messages
MethodReader reader = queue.createTailer().methodReader(new Message1Processor(),new Message2Processor());