JAVA J2EE 4 U

 #!/bin/bash

# Database connection details

PGUSER="your_user"

PGPASSWORD="your_password"

PGDATABASE="your_database"

PGHOST="your_primary_host"

PGPORT="your_port"

# Get replication lag in seconds

LAG=$(PGPASSWORD=$PGPASSWORD psql -U $PGUSER -d $PGDATABASE -h $PGHOST -p $PGPORT -Atc "SELECT EXTRACT(EPOCH FROM (now() - pg_last_xact_replay_timestamp()))::int FROM pg_stat_replication;")

# Check if lag is 0

if [[ "$LAG" -eq 0 ]]; then

    echo "Replication lag is 0. Proceeding..."

    # Add your proceeding steps here

else

    echo "Replication lag is $LAG seconds. Failing..."

    exit 1

fi