publish funtion:
 only make connection if it is not yet established
 only disconnect if there's no consumer using the same connection

consume function:
 only make connection if it is not yet established
 adding _consuming variable to keep tracking if the connection needs to be alive