fix(consumer): use connection_id as connection name (#49)