(pillow_id='case_messaging_sync_pillow', topics=None,
                         num_processes=1, process_num=0,
                         processor_chunk_size=DEFAULT_PROCESSOR_CHUNK_SIZE, **kwargs)
return ConstructedPillow(
        name=pillow_id,
        change_feed=change_feed,
        checkpoint=checkpoint,
        change_processed_event_handler=event_handler,
        processor=[CaseMessagingSyncProcessor()],
        processor_chunk_size=processor_chunk_size
    )
Pillow for synchronizing messaging data with case data.

        Processors:
          - :py:class:`corehq.messaging.pillow.CaseMessagingSyncProcessor`
Pillow for synchronizing messaging data with case data.
Pillow for synchronizing messaging data with case data .
def get_case_messaging_sync_pillow(pillow_id='case_messaging_sync_pillow', topics=None,
                         num_processes=1, process_num=0,
                         processor_chunk_size=DEFAULT_PROCESSOR_CHUNK_SIZE, **kwargs):
    """Pillow for synchronizing messaging data with case data.

        Processors:
          - :py:class:`corehq.messaging.pillow.CaseMessagingSyncProcessor`
    """
    if topics:
        assert set(topics).issubset(CASE_TOPICS), set(topics) - set(CASE_TOPICS)
    topics = topics or CASE_TOPICS
    change_feed = KafkaChangeFeed(
        topics, client_id=pillow_id, num_processes=num_processes, process_num=process_num
    )
    checkpoint = KafkaPillowCheckpoint(pillow_id, topics)
    event_handler = KafkaCheckpointEventHandler(
        checkpoint=checkpoint, checkpoint_frequency=1000, change_feed=change_feed,
    )
    return ConstructedPillow(
        name=pillow_id,
        change_feed=change_feed,
        checkpoint=checkpoint,
        change_processed_event_handler=event_handler,
        processor=[CaseMessagingSyncProcessor()],
        processor_chunk_size=processor_chunk_size
    )
def get_case_messaging_sync_pillow ( pillow_id = 'case_messaging_sync_pillow' , topics = None , num_processes = 1 , process_num = 0 , processor_chunk_size = DEFAULT_PROCESSOR_CHUNK_SIZE , * * kwargs ) : if topics : assert set ( topics ) . issubset ( CASE_TOPICS ) , set ( topics ) - set ( CASE_TOPICS ) topics = topics or CASE_TOPICS change_feed = KafkaChangeFeed ( topics , client_id = pillow_id , num_processes = num_processes , process_num = process_num ) checkpoint = KafkaPillowCheckpoint ( pillow_id , topics ) event_handler = KafkaCheckpointEventHandler ( checkpoint = checkpoint , checkpoint_frequency = 1000 , change_feed = change_feed , ) return ConstructedPillow ( name = pillow_id , change_feed = change_feed , checkpoint = checkpoint , change_processed_event_handler = event_handler , processor = [ CaseMessagingSyncProcessor ( ) ] , processor_chunk_size = processor_chunk_size )