java - 在 Chronicle Queue 中使用方法读取器和写入器

Question

大家好，我在使用 Chronicle Queue for Journalling 的个人项目中面临困难。我有两种类型的消息要从队列本身读取和写入。我的问题是我正在使用使用方法读取器和写入器的策略来执行此操作，但是我需要为方法使用两个不同的名称才能使用 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());

标签： javadesign-patternschronicle-queue