chronicle

    0

    1답변

    나는 최신 V4 문서를 읽기 시작했다. 원격 추가 및 꼬리를 제안하는 경우 chronicle-engine을 사용하는 것이 좋습니다. 해당 기능 세트에 대한 엔터프라이즈 지원이 필요합니까? chronicle-engine의 테스트 패키지를 둘러 보았고이 테스트 클래스를 발견했습니다. WireRemoteStatelessQueueClientTest.java은 관련

    0

    1답변

    나는 크로니클을 가지고 노는 것을 시작했고 기본적으로 크로니클 큐를 듣고 그걸로 뭔가를하는 프로세스를 썼다. 다시 시작할 때마다 파일의 모든 이벤트를 다시 처리 할 것입니다 ... 내가 처리 한 곳에서 계속 유지할 수있는 최선의 방법은 무엇일까? 어떻게하면 우리가 "색인"을 유지할 것을 추천하겠습니까? 앞으로 나아가는 방법이 있습니까?

    2

    1답변

    백업을 취하는 개념에서 하나의 크로니클 큐에서 다른 큐로 데이터를 복사해야합니다. 하나의 대기열에서 다른 대기열로 전체 Bytes 객체를 직접 복사하는 것이 안전할까요? 것을 등 documentContext(). 와이어(). 바이트(). (byte_buffer) 판독하고 documentContext()로 byte_store 쓰기 에이 byte_buffer

    1

    1답변

    그래서 jms msg를 청취하고 수정 태그에 따라 다른 기록 대기열에 기록하는 간단한 코드가 있습니다. public void onEvent(InputEvent inputEvent) { String msg = ((SimpleInputEvent) inputEvent).getMessage(); int start = msg.indexOf("\u0

    0

    1답변

    필자는 시장 데이터를 쓰고 읽는 데 크로니클 4.5.27을 사용하고 있습니다. 나는 한 명의 작가이지만 여러 명의 독자가있다. 개발 OS는 Windows이고 Prod 배포를 위해서는 Linux가 뒤 따른다. 다음 사례를 구현하는 방법은 무엇입니까? 마지막 읽기 위치에서 큐 읽기를 시작하는 방법은 무엇입니까? 예 : 독자가 100 개의 레코드가있는 파일에서

    0

    1답변

    크로니클 바이트 버전 1.7.22를 사용하고 있습니다. off-heap 캐싱과 대용량 미디어 (예 : 이미지, 비디오)의 지속성을 위해 Bytes를 사용하고 싶습니다. 다음과 같이 현재 나는 바이트를 만드는 오전 : Bytes.elasticByteBuffer(); 또는 MappedBytes.mappedBytes(file, 64); (지속성) 나는 미

    2

    1답변

    크로니클지도의 원 자성 의미에 대해 궁금합니다. 두 개의 노드 (서버)에서 공유 된 크로니클 맵이 있고이 키를 두 노드에서 동시에이 맵에 삽입하려고하면 트랜잭션 의미는 무엇입니까? 첫 번째 put은 성공하고 두 번째 put은 실패합니까? 크로니클 맵이 Apache Zookeeper와 동일한 트랜잭션 의미를 보장하는지 궁금합니다. 내 usecase에서 nod

    0

    1답변

    하나의 큐에 메시지를 쓰려고합니다. 하위 주제 기능을 사용하여 재단사가 하나의 주제 아래에있는 모든 하위 주제를 선택하거나 특정 하위 주제를 선택하여 읽을 수 있도록하고 싶습니다. 설명서에는 기본 주제 아래의 디렉토리에서 하위 주제가 지원되므로 하위 주제를 읽으려면 새 대기열을 작성하고 하위 주제 경로를 지정합니까? SingleChronicleQueue q

    1

    1답변

    chronicle-queue 바이너리를 최신 버전으로 업그레이드하고 새로운 파일을 발견했습니다. (아마도 새로운 것은 아니지만 이전에는 본 적이 없습니다) - directory-listing.cq4t. SingleChronicleQueueBuilder으로 정규 대기열을 생성 한 다음 몇 가지 작업을 수행하고 닫는 테스트가 있습니다. 마지막 단계로서 데이터로

    1

    1답변

    지속 된 값을 업데이트해야합니다. 는 말은 : ////// 클래스 InfoEquipoCache는 class InfoEquipoCache implements BytesMarshallable { private EquipoCache equipoCache; public void actualiza() { ..... equipo