Signed-off-by: Eric Zhao <sczyh16@gmail.com>master
@@ -20,6 +20,7 @@ import com.alibaba.csp.sentinel.EntryType; | |||||
import com.alibaba.csp.sentinel.SphU; | import com.alibaba.csp.sentinel.SphU; | ||||
import com.alibaba.csp.sentinel.Tracer; | import com.alibaba.csp.sentinel.Tracer; | ||||
import com.alibaba.csp.sentinel.context.ContextUtil; | import com.alibaba.csp.sentinel.context.ContextUtil; | ||||
import com.alibaba.csp.sentinel.log.RecordLog; | |||||
import com.alibaba.csp.sentinel.slots.block.BlockException; | import com.alibaba.csp.sentinel.slots.block.BlockException; | ||||
import com.alibaba.csp.sentinel.slots.block.SentinelRpcException; | import com.alibaba.csp.sentinel.slots.block.SentinelRpcException; | ||||
import com.alibaba.dubbo.common.extension.Activate; | import com.alibaba.dubbo.common.extension.Activate; | ||||
@@ -42,6 +43,10 @@ import com.alibaba.dubbo.rpc.RpcException; | |||||
@Activate(group = "consumer") | @Activate(group = "consumer") | ||||
public class SentinelDubboConsumerFilter extends AbstractDubboFilter implements Filter { | public class SentinelDubboConsumerFilter extends AbstractDubboFilter implements Filter { | ||||
public SentinelDubboConsumerFilter() { | |||||
RecordLog.info("Sentinel Dubbo consumer filter initialized"); | |||||
} | |||||
@Override | @Override | ||||
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { | public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { | ||||
Entry interfaceEntry = null; | Entry interfaceEntry = null; | ||||
@@ -20,6 +20,7 @@ import com.alibaba.csp.sentinel.EntryType; | |||||
import com.alibaba.csp.sentinel.SphU; | import com.alibaba.csp.sentinel.SphU; | ||||
import com.alibaba.csp.sentinel.Tracer; | import com.alibaba.csp.sentinel.Tracer; | ||||
import com.alibaba.csp.sentinel.context.ContextUtil; | import com.alibaba.csp.sentinel.context.ContextUtil; | ||||
import com.alibaba.csp.sentinel.log.RecordLog; | |||||
import com.alibaba.csp.sentinel.slots.block.BlockException; | import com.alibaba.csp.sentinel.slots.block.BlockException; | ||||
import com.alibaba.csp.sentinel.slots.block.SentinelRpcException; | import com.alibaba.csp.sentinel.slots.block.SentinelRpcException; | ||||
import com.alibaba.dubbo.common.extension.Activate; | import com.alibaba.dubbo.common.extension.Activate; | ||||
@@ -42,6 +43,10 @@ import com.alibaba.dubbo.rpc.RpcException; | |||||
@Activate(group = "provider") | @Activate(group = "provider") | ||||
public class SentinelDubboProviderFilter extends AbstractDubboFilter implements Filter { | public class SentinelDubboProviderFilter extends AbstractDubboFilter implements Filter { | ||||
public SentinelDubboProviderFilter() { | |||||
RecordLog.info("Sentinel Dubbo provider filter initialized"); | |||||
} | |||||
@Override | @Override | ||||
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { | public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { | ||||
// Get origin caller. | // Get origin caller. | ||||