 
 	WHILE i < size LOOP
 		insert into {databaseSchema}.mt_rolling_buffer 
-			(slot, message_id, timestamp, events, stream_id, reference_count)
+			(slot, message_id, timestamp, event_id, stream_id, reference_count)
 		values
-			(i + 1, 0, timestamp, ARRAY[0], empty, 0);
+			(i + 1, 0, timestamp, empty, empty, 0);
 
 		i := i + 1;
 	END LOOP;

	slot				integer CONSTRAINT pk_mt_rolling_buffer PRIMARY KEY,
	message_id			integer NOT NULL,
	timestamp			timestamp without time zone default (now() at time zone 'utc') NOT NULL,
	events				UUID[] NOT NULL,
	stream_id			UUID NOT NULL,
	reference_count		integer NOT NULL	
);

				SET
					timestamp = current_timestamp,
					message_id = id,
					event_id = event,
					stream_id = stream,
					reference_count = reference_count + 1
				WHERE
