micdenny

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using EasyNetQ;
using EasyNetQ.ConnectionString;
using EasyNetQ.Consumer;
using EasyNetQ.Interception;
using EasyNetQ.Loggers;
using EasyNetQ.Producer;

micdenny

Waiting until the support for slave-read-only on StackExchange.Redis, I would like to share my solution to fail-over a node with a minimum write interruption, maintaining data consistency, reducing (eliminating?) possible false write acknowledgment (on the node that is failing). You can lose some write because there's a window where both nodes are slaves. I feel that you can still have some false write ack because you can receive an ack while setting the master as slave and that write could be lost.

redis-slaveof-kvs01.txt

MULTI
SLAVEOF kvs01 6379
CONFIG REWRITE
PUBLISH "__Booksleeve_MasterChanged" "*"
EXEC

micdenny

void Main()
{
	var stopHandle = new ManualResetEventSlim();
	
	var consumer = new Thread(() =>
	{
		var bus = RabbitHutch.CreateBus("host=localhost", x => x.Register<IEasyNetQLogger>(s => new EasyNetQ.Loggers.ConsoleLogger()));
		
		bus.RespondAsync<MyRequest, MyResponse>(async request => 
		{

micdenny

using System;
using System.Threading;
using System.Threading.Tasks;
using EasyNetQ;
 
namespace EasynetQ.SubRpc.Deadlock
{
    internal class Program
    {
        private static void Main(string[] args)

micdenny

Enabling PowerShell remoting on the server

Open PowerShell console and type the following command to enable PowerShell remoting:

Enable-PSRemoting -Force

Change scripts execution policy to allow remote scripts:

Set-ExecutionPolicy RemoteSigned

micdenny

# --- settings ---
$feedUrlBase = "https://www.nuget.org/api/v2/"
# the rest will be params when converting to funclet
$latest = $true
$overwrite = $false
$top = 5000 #use $top = $null to grab all
$destinationDirectory = join-path ([Environment]::GetFolderPath("MyDocuments")) "NuGetLocal"

# --- locals ---
$webClient = New-Object System.Net.WebClient

micdenny

Octopus.Acquire.MaxParallelism
Octopus.Action[Deploy Cardio API - Host].Azure.CertificateBytes
Octopus.Action[Deploy Cardio API - Host].Azure.CertificateThumbprint
Octopus.Action[Deploy Cardio API - Host].Azure.CloudServiceName
Octopus.Action[Deploy Cardio API - Host].Azure.Endpoint
Octopus.Action[Deploy Cardio API - Host].Azure.Slot
Octopus.Action[Deploy Cardio API - Host].Azure.StorageAccountName
Octopus.Action[Deploy Cardio API - Host].Azure.SubscriptionId
Octopus.Action[Deploy Cardio API - Host].Azure.SwapIfPossible
Octopus.Action[Deploy Cardio API - Host].Azure.UploadedPackageUri

micdenny

using System;
using System.Threading;
using System.Threading.Tasks;
using EasyNetQ;

namespace ConsoleApplication5
{
    class Program
    {
        static void Main(string[] args)

micdenny

using System;
using System.Timers;
using Castle.MicroKernel.Registration;
using Castle.Windsor;
using Topshelf;

namespace TopshelfBootstrapper
{
    internal class Program
    {

micdenny

using System;
using System.Collections;
using System.Collections.Generic;
using System.Runtime.CompilerServices;
using System.Threading;

namespace System.Threading.Tasks
{
    internal static class TaskHelpers
    {