 		v_i_replayed		integer;
 		v_i_skipped		integer;
 		v_i_ddl		integer;
+		v_i_evt_replay	bigint[];
+		v_i_evt_queue		bigint[];
 	BEGIN
 		v_b_loop:=FALSE;
 		v_i_replayed:=0;

);

CREATE UNIQUE INDEX idx_schema_table_source ON sch_chameleon.t_index_def(i_id_source,v_schema,v_table,v_index);

--FUNCTIONS
CREATE OR REPLACE FUNCTION sch_chameleon.fn_refresh_parts() 

				i_id_batch=v_i_id_batch
			;

			DELETE FROM sch_chameleon.t_batch_events
			WHERE
				i_id_batch=v_i_id_batch
			;

			v_b_loop=False;
		ELSE
