@@ -0,0 +1,129 @@
+package my.queue;%0A%0A/**%0A * %E5%9B%9E%E8%B0%83%E5%87%BD%E6%95%B0%EF%BC%8C%E5%BD%93%E6%9C%89%E6%95%B0%E6%8D%AE%E7%9A%84%E6%97%B6%E5%80%99%EF%BC%8C%E5%B0%86%E6%95%B0%E6%8D%AE%E4%BC%A0%E9%80%92%E7%BB%99%E5%85%B7%E4%BD%93%E4%B8%9A%E5%8A%A1%E3%80%82%0A */%0Apublic interface ConsumerCallback %7B%0A    void onMessage(String message);%0A%7D%0A

update queue， add callback