@Override
    protected void execute() {
        publish(Utility.GenerateRandomTask());
        
        try {
            channel.close();
            channel = connection.createChannel();
        } catch (IOException ex) {
            System.err.println(ex.getMessage());
        }
    }