CREATE UNIQUE INDEX `messages_source_idx` ON `messages` (`event_id`,`source`,`source_id`);