I hereby claim:
- I am mikegoldsmith on github.
- I am mgoldsmith (https://keybase.io/mgoldsmith) on keybase.
- I have a public key whose fingerprint is 1865 0AD4 AB3E 8B5F A065 EF14 819B 2121 230F 8A43
To claim this, I am signing this object:
public interface IServiceBusMessage<out TContent> : CorrelatedBy<Guid> | |
{ | |
TContent Content { get; } | |
bool ExpectsResponse { get; } | |
} | |
internal class ServiceBusMessage<TContent> : IServiceBusMessage<TContent> | |
{ | |
public Guid CorrelationId { get; set; } | |
public TContent Content { get; set; } |
public interface IQuery<TResult> | |
{ | |
} | |
public interface IQueryHandler<in TQuery, TResult> | |
where TQuery : IQuery<TResult> | |
{ | |
Task<TResult> Handle(TQuery query); | |
} | |
public class ServiceBusQueryHandler<TQuery, TResult> : IQueryHandler<TQuery, TResult> | |
where TQuery : class, IQuery<TResult> |
using System; | |
using Magnum.Extensions; | |
using MassTransit; | |
using MassTransit.QuartzIntegration; | |
using MassTransit.Scheduling; | |
using Quartz.Impl; | |
class Program | |
{ | |
static void Main() |
var view = _client.GetView("scheduling", "jobs_by_status_scheduledFor") | |
.StartKey(new object[] {JobStatus.Queued.ToString()}) | |
.EndKey(new object[] {JobStatus.Queued.ToString(), DateTime.UtcNow.ToString("O")}) | |
.GetPagedView(maxJobs); | |
while (jobs.Count < maxJobs && view.MoveNext()) | |
{ | |
foreach (var row in view) | |
{ | |
CasResult<object> casResult; |
using System; | |
using System.Collections.Generic; | |
using System.Linq; | |
using MassTransit; | |
using MassTransit.Serialization; | |
using Newtonsoft.Json; | |
namespace MT_Interface_Typing | |
{ | |
class Program |
public class Workflow | |
{ | |
public IEnumerable<INode> Nodes {get;set;} | |
// other properties | |
} | |
public interface INode | |
{ | |
Guid Id {get;} | |
} |
I hereby claim:
To claim this, I am signing this object:
<?xml version="1.0" encoding="utf-8"?> | |
<configuration> | |
<configSections> | |
<section name="couchbase" type="Couchbase.Configuration.Client.Providers.CouchbaseClientSection, Couchbase.NetClient" /> | |
</configSections> | |
<couchbase> | |
<servers> | |
<add uri="http://node1.example.com:8091/"/> | |
<add uri="http://node2.example.com:8091/"/> | |
</servers> |
<?xml version="1.0" encoding="utf-8"?> | |
<configuration> | |
<configSections> | |
<section name="couchbase" type="Couchbase.Configuration.Client.Providers.CouchbaseClientSection, Couchbase.NetClient" /> | |
</configSections> | |
<couchbase> | |
<serverResolver type=""/> | |
</couchbase> | |
// other configuration omitted for brevity | |
</configuration> |
_cbnodes._tcp.example.com. 0 IN SRV 20 0 8091 node2.example.com. | |
_cbnodes._tcp.example.com. 0 IN SRV 10 0 8091 node1.example.com. | |
_cbnodes._tcp.example.com. 0 IN SRV 30 0 8091 node3.example.com. |