private void sendUpdates() throws Exception {
  log.info("sendUpdates");
  String sql="SELECT rt.AD_Table_ID, rt.ReplicationType, t.TableName, rt.AD_ReplicationTable_ID " + "FROM AD_ReplicationTable rt" + " INNER JOIN AD_Table t ON (rt.AD_Table_ID=t.AD_Table_ID) "+ "WHERE rt.IsActive='Y' AND t.IsActive='Y'"+ " AND AD_ReplicationStrategy_ID=?"+ " AND rt.ReplicationType='R' "+ "ORDER BY t.LoadSeq";
  RowSet rowset=getRowSet(sql,new Object[]{new Integer(m_replication.getAD_ReplicationStrategy_ID())});
  try {
    while (rowset.next())     sendUpdatesTable(rowset.getInt(1),rowset.getString(3),rowset.getInt(4));
    rowset.close();
  }
 catch (  SQLException ex) {
    log.log(Level.SEVERE,"sendUpdates",ex);
    m_replicated=false;
  }
}

private void sendUpdates ( ) throws Exception { log . info ( "sendUpdates" ) ; String sql = "SELECT rt.AD_Table_ID, rt.ReplicationType, t.TableName, rt.AD_ReplicationTable_ID " + "FROM AD_ReplicationTable rt" + " INNER JOIN AD_Table t ON (rt.AD_Table_ID=t.AD_Table_ID) " + "WHERE rt.IsActive='Y' AND t.IsActive='Y'" + " AND AD_ReplicationStrategy_ID=?" + " AND rt.ReplicationType='R' " + "ORDER BY t.LoadSeq" ; RowSet rowset = getRowSet ( sql , new Object [ ] { new Integer ( m_replication . getAD_ReplicationStrategy_ID ( ) ) } ) ; try { while ( rowset . next ( ) ) sendUpdatesTable ( rowset . getInt ( 1 ) , rowset . getString ( 3 ) , rowset . getInt ( 4 ) ) ; rowset . close ( ) ; } catch ( SQLException ex ) { log . log ( Level . SEVERE , "sendUpdates" , ex ) ; m_replicated = false ; } }
send updates to remote ( i . e . r / o on remote )
