How to write a callback function to continuously receive the messages from subscription topics?

[yaocl]

Following the code sample in readme, "receive .... end." only can receive a message from subscription topics. Can we register a callback function to "ConnPid" in order to continuously receive the messages from subscription topics?