This project implements a replication process for the oraeventstore. It works by reading a source store's atom feed, and writing the events replicated from a remote instance into the local instance.
To simplify processing, each replication action, be it the 'catch up' phase or the reading of recent events, will be performed after acquiring a mutex via a table lock.
The table use for the lock is
create table t_aerl_replicator_lock (
ts TIMESTAMP
);
To Build:
docker run --rm -v $PWD:/go/src/github.com/xtracdev/es-atom-replicator -e DB_USER= -e DB_PASSWORD= -e DB_HOST= -e DB_PORT= -e DB_SVC= -w /go/src/github.com/xtracdev/es-atom-replicator xtracdev/goora bash -c "make -f Makefile"
For integration testing, you need to install the managed API schema which includes the above replicator lock (tables to be added to this project at some point).