Javaクロニクルメッセージは読み込み後に削除されません

Question

Javaクロニクル1.9.2を使用してメッセージの書き込み/読み取りを試みています。私は新しいバージョンが利用可能であることを知っているが、私はそれに多くの時間を投資する前にいくつかの質問があります。

クロニクルからの抜粋を読んだら、メッセージを削除する必要があります。 もし私の読者が再び始めるなら、それは最初に戻らない。 また、私はそれを読んで、それを削除したいと思っても、メッセージは役に立たない。

オプションはありますか？私は次のコードをしようとしていると私はリーダーを開始するたびに、私は再びすべてのメッセージを取得します。 また、特定の期間の後に自動的に削除されるように、有効期間を設定するメッセージを入れるオプションがあります。

WRITER -

 String tempPath = System.getProperty("java.io.tmpdir"); 
     String basePrefix = tempPath + "chronicle"; 
     System.out.println("base prefix: " + basePrefix); 
     Chronicle chr = new IndexedChronicle(basePrefix); 
     final Excerpt excerpt = chr.createExcerpt(); 
     excerpt.startExcerpt(this.getmsgtext().length() + 4); 
     excerpt.writeBytes(this.getmsgtext()); 
     excerpt.finish(); 
     chr.close(); 

READER -

 String tempPath = System.getProperty("java.io.tmpdir"); 
     String basePrefix = tempPath + "chronicle"; 
     System.out.println("base prefix: " + basePrefix); 
     Chronicle chr = new IndexedChronicle(basePrefix); 
     final Excerpt excerpt = chr.createExcerpt(); 

     while (excerpt.nextIndex()) { 
       System.out.println("Read string from chronicle: " + excerpt.readByteString()); 
     } 
     chr.close(); 

Answer 1

私は私がクロニクルからの抜粋を読んでたら、メッセージを削除する必要があります。

これを削除する唯一の方法はファイルローリングです。あなたはIndexedChronicleでこれを行うことができます。またはVanillaChronicleまたは現在のSingleChronicleQueueを使用することができます。

私の読者が再び始まると、最初に戻らなくなります。私はそれを削除したいので、私はそれを読むと、メッセージは役に立たないです。

標準の方法は、ソースIDを含む結果をクロニクルに書き込むことです。この方法で、どのメッセージが正常に処理されたかを常に知ることができます。例えばメッセージを読み取ることはできますが、クラッシュが発生した場合は処理されません。

私は次のコードを試しています。私がリーダーを開始するたびに、私はすべてのメッセージを再度取得します。

これはデフォルトで行われるように設計されています。どのメッセージが正しく処理されたかを把握する方法はあなた次第です。 （別のキューにこれを記録し、そのインデックスを見つけるために最後のメッセージを読むことをお勧めしますが）

Time to Liveメッセージを入れるという選択肢がありますので、一定時間後に自動的に削除されます。

各メッセージにタイムスタンプを追加して古いメッセージを無視できます。

クロニクルキューv4.1.0は最新リリースです。