DROP INDEX IF EXISTS message_store.messages_category;
CREATE INDEX messages_category ON message_store.messages (
message_store.category(stream_name), global_position, message_store.category(metadata->>'correlationStreamName')
);
DROP INDEX IF EXISTS message_store.messages_category;
CREATE INDEX messages_category ON message_store.messages (
message_store.category(stream_name), global_position, message_store.category(metadata->>'correlationStreamName')
);