Also run integration tests (#97)

* Also run integration tests

* more rabbit junk

* oof

* logging

* oof

* use threading primitives

Author: jonnii

.appveyor.yml

@@ -9,10 +9,43 @@ configuration: Release
 
 install:
   - choco install gitversion.portable -pre -y
+  - choco install -y rabbitmq
+  - ps: |
+      write-host "Discovering rabbitmq installation location"
+      $regPath = "HKLM:\SOFTWARE\Microsoft\Windows\CurrentVersion\Uninstall\RabbitMQ"
+      if (Test-Path "HKLM:\SOFTWARE\Wow6432Node\") { $regPath = "HKLM:\SOFTWARE\Wow6432Node\Microsoft\Windows\CurrentVersion\Uninstall\RabbitMQ" }
+      $path = Split-Path -Parent (Get-ItemProperty $regPath "UninstallString").UninstallString
+      $version = (Get-ItemProperty $regPath "DisplayVersion").DisplayVersion
+      [Environment]::SetEnvironmentVariable("RABBITMQ_HOME", "$path\rabbitmq_server-$version", "Machine")
+      $env:RABBITMQ_HOME = "$path\rabbitmq_server-$version"
+      [Environment]::SetEnvironmentVariable("RABBITMQ_RABBITMQCTL_PATH", "$path\rabbitmq_server-$version\sbin\rabbitmqctl.bat", "Machine")
+      
+      $env:RABBITMQ_RABBITMQCTL_PATH = "$path\rabbitmq_server-$version\sbin\rabbitmqctl.bat"
+      $env:RABBITMQ_RABBITMQSERVER_PATH = "$path\rabbitmq_server-$version\sbin\rabbitmq-service.bat"
+
+      write-host $env:RABBITMQ_RABBITMQCTL_PATH
+      write-host $env:RABBITMQ_RABBITMQSERVER_PATH
+
+      $uninstall = "cmd.exe /C '$env:RABBITMQ_RABBITMQSERVER_PATH' remove"
+      $install = "cmd.exe /C '$env:RABBITMQ_RABBITMQSERVER_PATH' install"
+      $start = "cmd.exe /C '$env:RABBITMQ_RABBITMQSERVER_PATH' start"
+
+      write-host "Removing rabbitmq"
+      Invoke-Expression -Command:$uninstall
+      Start-Sleep 2
+
+      write-host "Installing rabbitmq"
+      Invoke-Expression -Command:$install
+      Start-Sleep 2
+
+      write-host "Starting rabbitmq"
+      Invoke-Expression -Command:$start
+      Start-Sleep 2
+
+before_build:
   - cmd: dotnet restore src\Chinchilla.sln
   - ps: gitversion /l console /output buildserver
 
-
 dotnet_csproj:
   patch: true
   file: 'src\**\*.csproj'

build/run-tests.ps1

@@ -6,4 +6,12 @@ Get-ChildItem src\*.Specifications `
 	dotnet test "src\\$_" -c Release --no-build --logger trx --results-directory (Join-Path $(pwd) test_results)
 	$testExitCode += $LASTEXITCODE
 }
+
+Get-ChildItem src\*.Integration `
+| select -ExpandProperty Name `
+| % {
+	dotnet test "src\\$_" -c Release --no-build --logger trx --results-directory (Join-Path $(pwd) test_results)
+	$testExitCode += $LASTEXITCODE
+}
+
 if ($testExitCode -ne 0) { $host.SetShouldExit($testExitCode); throw; }

src/Chinchilla.Integration/Features/SubscribeFeature.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Linq;
+using System.Threading;
 using Chinchilla.Api;
 using Chinchilla.Integration.Features.Messages;
 using Chinchilla.Integration.Features.MessageTypeFactories;
@@ -47,7 +48,7 @@ public void ShouldReceivedPublishedMessage()
                 bus.Subscribe((HelloWorldMessage hwm) =>
                 {
                     lastReceived = hwm;
-                    ++numReceived;
+                    Interlocked.Increment(ref numReceived);
                 });
 
                 for (var i = 0; i < 100; ++i)