private final DaemonCommandExecution execution;
    private final BlockingQueue<Object> queue = new LinkedBlockingQueue<Object>();
    private final ForwardEvents forwarder = new ForwardEvents();

    public DaemonConnectionBackedEventConsumer(DaemonCommandExecution execution) {
        this.execution = execution;
        forwarder.start();
    }

    @Override