diff --git a/integration/dubbo/pom.xml b/integration/dubbo/pom.xml index 3f0a666b5919ca945ba33554c7f28494706f35e9..92f9c9864e571e3ae48f87701bfa3ba2df73923c 100644 --- a/integration/dubbo/pom.xml +++ b/integration/dubbo/pom.xml @@ -11,6 +11,7 @@ net.dubboclub cat-monitor + 0.0.7 diff --git a/integration/dubbo/src/main/java/net/dubboclub/catmonitor/CatTransaction.java b/integration/dubbo/src/main/java/net/dubboclub/catmonitor/CatTransaction.java index 0d11e8d83a3da3729bc2ec46e28b460f1d0b1432..8d6f2bedc1c7138f13fdb275784b291ed1d6e97a 100644 --- a/integration/dubbo/src/main/java/net/dubboclub/catmonitor/CatTransaction.java +++ b/integration/dubbo/src/main/java/net/dubboclub/catmonitor/CatTransaction.java @@ -9,7 +9,6 @@ import com.alibaba.dubbo.rpc.*; import com.alibaba.dubbo.rpc.support.RpcUtils; import com.dianping.cat.Cat; import com.dianping.cat.message.*; -import com.dianping.cat.message.internal.AbstractMessage; import net.dubboclub.catmonitor.constants.CatConstants; import org.apache.commons.lang.StringUtils; @@ -186,8 +185,7 @@ public class CatTransaction implements Filter { } private void completeEvent(Event event){ - AbstractMessage message = (AbstractMessage) event; - message.setCompleted(true); + event.complete(); } private void createProviderCross(URL url,Transaction transaction){