Feature/ravendb4

Hangfire.Raven.sln

@@ -1,7 +1,7 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
-VisualStudioVersion = 15.0.27004.2005
+VisualStudioVersion = 15.0.27130.2026
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "_", "_", "{8CF2D2F6-BEFE-47FE-B141-0017FC6F97D8}"
 	ProjectSection(SolutionItems) = preProject

samples/Hangfire.Raven.Samples.AspNetCore/Hangfire.Raven.Samples.AspNetCore.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
-    <TargetFrameworks>netstandard2.0</TargetFrameworks>
+    <TargetFrameworks>netcoreapp2.2</TargetFrameworks>
     <Version>3.2.0</Version>
     <AssemblyVersion>3.2.0.0</AssemblyVersion>
     <FileVersion>3.2.0.0</FileVersion>
@@ -16,15 +16,14 @@
     <PackageTags>Hangfire;AspNet;MVC;OWIN;RavenDB;Long-Running;Background;Fire-And-Forget;Delayed;Recurring;Tasks;Jobs;Scheduler;Threading;Queues</PackageTags>
     <RepositoryType>git</RepositoryType>
     <RepositoryUrl>https://github.com/CadyIO/hangfire-ravendb</RepositoryUrl>
+    <StartupObject>Hangfire.Raven.Samples.AspNetCore.Program</StartupObject>
+    <ApplicationIcon />
+    <OutputType>Exe</OutputType>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="Hangfire.AspNetCore" Version="1.6.17" />
-    <PackageReference Include="Microsoft.AspNetCore" Version="2.0.0" />
-    <PackageReference Include="Microsoft.AspNetCore.Mvc" Version="2.0.0" />
-    <PackageReference Include="Microsoft.AspNetCore.StaticFiles" Version="2.0.0" />
-    <PackageReference Include="Microsoft.Extensions.Logging.Debug" Version="2.0.0" />
-    <PackageReference Include="Microsoft.VisualStudio.Web.BrowserLink" Version="2.0.0" />
-    <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
+    <PackageReference Include="Hangfire.AspNetCore" Version="1.6.21" />
+    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.2.1" />
+    <PackageReference Include="Newtonsoft.Json" Version="12.0.1" />
   </ItemGroup>
   <ItemGroup>
     <DotNetCliToolReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Tools" Version="1.0.0" />

samples/Hangfire.Raven.Samples.AspNetCore/Startup.cs

@@ -1,17 +1,16 @@
 using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
 using Hangfire.Raven.Storage;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 
-namespace Hangfire.Raven.Samples.AspNetCore
-{
-    public class Startup
-    {
-        public Startup(IHostingEnvironment env)
-        {
+namespace Hangfire.Raven.Samples.AspNetCore {
+    public class Startup {
+        public Startup(IHostingEnvironment env) {
             var builder = new ConfigurationBuilder()
                 .SetBasePath(env.ContentRootPath)
                 .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
@@ -23,8 +22,7 @@ public Startup(IHostingEnvironment env)
         public IConfigurationRoot Configuration { get; }
 
         // This method gets called by the runtime. Use this method to add services to the container.
-        public void ConfigureServices(IServiceCollection services)
-        {
+        public void ConfigureServices(IServiceCollection services) {
             // Add framework services.
             services.AddMvc();
 
@@ -36,37 +34,45 @@ public void ConfigureServices(IServiceCollection services)
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
-        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
-        {
+        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory) {
             loggerFactory.AddConsole(Configuration.GetSection("Logging"));
             loggerFactory.AddDebug();
 
-            if (env.IsDevelopment())
-            {
+            if (env.IsDevelopment()) {
                 app.UseDeveloperExceptionPage();
                 app.UseBrowserLink();
-            }
-            else
-            {
+            } else {
                 app.UseExceptionHandler("/Home/Error");
             }
 
             app.UseStaticFiles();
 
             // Add Hangfire Server and Dashboard support
-            app.UseHangfireServer();
+            app.UseHangfireServer(new BackgroundJobServerOptions() { Queues = new[] { "default", "testing" } });
             app.UseHangfireDashboard();
 
             // Run once
             BackgroundJob.Enqueue(() => System.Console.WriteLine("Background Job: Hello, world!"));
 
-            BackgroundJob.Enqueue(() => Test());
+            BackgroundJob.Enqueue(() => QueueTest());
+
+            BackgroundJob.Schedule(() => System.Console.WriteLine("Scheduled Job: Hello, I am delayed world!"), new System.TimeSpan(0, 1, 0));
+
+            BackgroundJob.Enqueue(() => FailingTest());
 
             // Run every minute
-            RecurringJob.AddOrUpdate(() => Test(), Cron.Minutely);
+            RecurringJob.AddOrUpdate(() => CronTest(), Cron.Minutely);
+
+
+            Task.Delay(1000).ContinueWith((task) => {
+                for (int i = 0; i < 50; i++)
+                    BackgroundJob.Enqueue(() => System.Console.WriteLine("Background Job: Hello stressed world!"));
 
-            app.UseMvc(routes =>
-            {
+                for (int i = 0; i < 100; i++)
+                    BackgroundJob.Enqueue(() => WorkerCountTest());
+            });
+
+            app.UseMvc(routes => {
                 routes.MapRoute(
                     name: "default",
                     template: "{controller=Home}/{action=Index}/{id?}");
@@ -75,11 +81,25 @@ public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerF
 
         public static int x = 0;
 
-        [AutomaticRetry(Attempts = 2, LogEvents = true, OnAttemptsExceeded = AttemptsExceededAction.Delete)]
-        public static void Test()
-        {
+        [AutomaticRetry(Attempts = 2, LogEvents = true, OnAttemptsExceeded = AttemptsExceededAction.Fail)]
+        public static void CronTest() {
             Debug.WriteLine($"{x++} Cron Job: Hello, world!");
-            //throw new ArgumentException("fail");
+        }
+
+        [Queue("testing")]
+        public static void QueueTest() {
+            Debug.WriteLine($"{x++} Queue test Job: Hello, world!");
+        }
+
+        [Queue("testing")]
+        public static void FailingTest() {
+            Debug.WriteLine($"{x++} Requeue test!");
+            throw new System.Exception();
+        }
+
+
+        public static void WorkerCountTest() {
+            Thread.Sleep(5000);
         }
     }
 }

samples/Hangfire.Raven.Samples.AspNetCore/appsettings.Development.json

@@ -8,8 +8,8 @@
         }
     },
     "ConnectionStrings": {
-        "RavenDebug": "URL=http://localhost:9090;Database=HangfireAspNetCore",
-        "RavenDebugUrl": "http://localhost:9090",
+        "RavenDebug": "URL=http://localhost:8080;Database=HangfireAspNetCore",
+        "RavenDebugUrl": "http://localhost:8080",
         "RavenDebugDatabase": "HangfireAspNetCore"
     }
 }

samples/Hangfire.Raven.Samples.Console/Hangfire.Raven.Samples.Console.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup Label="Configuration" Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
-    <OutputType>exe</OutputType>
+    <OutputType>Exe</OutputType>
   </PropertyGroup>
 
   <PropertyGroup>
@@ -22,25 +22,18 @@
     <RepositoryUrl>https://github.com/CadyIO/hangfire-ravendb</RepositoryUrl>
     <ApplicationIcon />
     <OutputTypeEx>exe</OutputTypeEx>
-    <StartupObject />
+    <StartupObject></StartupObject>
+    <OutputType>Exe</OutputType>
   </PropertyGroup>
-
-  <ItemGroup>
-    <None Remove="app.config" />
-  </ItemGroup>
-
-  <ItemGroup>
-    <Content Include="app.config" />
-  </ItemGroup>
-
+
   <ItemGroup>
     <ProjectReference Include="..\..\src\Hangfire.Raven\Hangfire.Raven.csproj" />
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Hangfire.Core" Version="1.6.17" />
-    <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
-    <PackageReference Include="RavenDB.Client" Version="3.5.4" />
+    <PackageReference Include="Hangfire.Core" Version="1.6.21" />
+    <PackageReference Include="Newtonsoft.Json" Version="12.0.1" />
+    <PackageReference Include="RavenDB.Client" Version="4.1.3" />
   </ItemGroup>
 
 </Project>

samples/Hangfire.Raven.Samples.Console/Program.cs

@@ -11,14 +11,14 @@ public static void Main()
         {
             try {
                 // you can use Raven Storage and specify the connection string name
-                GlobalConfiguration.Configuration
-                    .UseColouredConsoleLogProvider()
-                    .UseRavenStorage("RavenDebug");
-
-                // you can use Raven Storage and specify the connection string and database name
                 //GlobalConfiguration.Configuration
                 //    .UseColouredConsoleLogProvider()
-                //    .UseRavenStorage("http://localhost:9090", "HangfireConsole");
+                //    .UseRavenStorage("RavenDebug");
+
+                // you can use Raven Storage and specify the connection string and database name
+                GlobalConfiguration.Configuration
+                    .UseColouredConsoleLogProvider()
+                    .UseRavenStorage("http://localhost:8080", "HangfireConsole");
 
                 // you can use Raven Embedded Storage which runs in memory!
                 //GlobalConfiguration.Configuration