在 Chronicle Queue 中使用方法 reader 和 writter

编程问答 2022-05-15

问题描述

大家好，我在使用 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());

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

chronicle-queuedesign-patternsjavajava