I have decoded the data from the host in Consumer. But how to keep a long connection to the host? such as heartbeat sending(I found it by using channel.ping() in ETAJ doc, but I don't konw how to do in EMAJ Consumer). Will the host send heartbeat package? if yes, how to deal with it?