HystrixHookBuggy.java

// Buggy code
public class HystrixHook extends HystrixCommandExecutionHook {
    
    private Integer id;

    @Override
    public <T> void onStart(HystrixInvokable<T> commandInstance) {
        getThreadLocals();
    }

    @Override
    public <T> void onExecutionStart(HystrixInvokable<T> commandInstance) {
        setThreadLocals();
    }

    @Override
    public <T> void onFallbackStart(HystrixInvokable<T> commandInstance) {
        setThreadLocals();
    }
    
    @Override
    public <T> void onExecutionSuccess(HystrixInvokable<T> commandInstance) {
        ThreadLocalUtil.clear();
        super.onExecutionSuccess(commandInstance);
    }

    @Override
    public <T> Exception onExecutionError(HystrixInvokable<T> commandInstance, Exception e) {
        ThreadLocalUtil.clear();
        return super.onExecutionError(commandInstance, e);
    }
    
     @Override
    public <T> Exception onFallbackError(HystrixInvokable<T> commandInstance, Exception e) {
        ThreadLocalUtil.clear();
        return super.onFallbackError(commandInstance, e);
    }

    @Override
    public <T> void onFallbackSuccess(HystrixInvokable<T> commandInstance) {
        ThreadLocalUtil.clear();
        super.onFallbackSuccess(commandInstance);
    }
    
     private void getThreadLocals() {
        id = ThreadLocalUtil.getId();
    }

    private void setThreadLocals() {
        ThreadLocalUtil.setId(id);
    }
}

// Register hystrix hook plugin
HystrixPlugins.getInstance().registerCommandExecutionHook(new HystrixHook());