|
@@ -1,5 +1,5 @@ |
|
|
using System; |
|
|
using System; |
|
|
using System.Data; |
|
|
|
|
|
|
|
|
using System.Threading; |
|
|
using System.Threading.Tasks; |
|
|
using System.Threading.Tasks; |
|
|
using DotNetCore.CAP.Abstractions; |
|
|
using DotNetCore.CAP.Abstractions; |
|
|
using DotNetCore.CAP.Models; |
|
|
using DotNetCore.CAP.Models; |
|
@@ -119,62 +119,15 @@ namespace DotNetCore.CAP.Test |
|
|
|
|
|
|
|
|
private class MyProducerService : ICapPublisher |
|
|
private class MyProducerService : ICapPublisher |
|
|
{ |
|
|
{ |
|
|
public void Publish<T>(string name, T contentObj, string callbackName = null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
public ICapTransaction CapTransaction { get; } |
|
|
|
|
|
|
|
|
public void Publish<T>(string name, T contentObj, IDbTransaction dbTransaction, string callbackName = null) |
|
|
|
|
|
|
|
|
public Task PublishAsync<T>(string name, T contentObj, string callbackName = null, |
|
|
|
|
|
CancellationToken cancellationToken = default(CancellationToken)) |
|
|
{ |
|
|
{ |
|
|
throw new NotImplementedException(); |
|
|
throw new NotImplementedException(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public void Publish<T>(string name, T contentObj, object mongoSession, string callbackName = null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync(string topic, string content) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync<T>(string topic, T contentObj) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync(string topic, string content, IDbConnection dbConnection) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync(string topic, string content, IDbConnection dbConnection, IDbTransaction dbTransaction) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync<T>(string name, T contentObj, IDbConnection dbConnection, IDbTransaction dbTransaction = null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync<T>(string name, T contentObj, string callbackName = null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishAsync<T>(string name, T contentObj, IDbTransaction dbTransaction, string callbackName = null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public void PublishWithMongo<T>(string name, T contentObj, IMongoTransaction mongoTransaction = null, string callbackName = null) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new NotImplementedException(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Task PublishWithMongoAsync<T>(string name, T contentObj, IMongoTransaction mongoTransaction = null, string callbackName = null) |
|
|
|
|
|
|
|
|
public void Publish<T>(string name, T contentObj, string callbackName = null) |
|
|
{ |
|
|
{ |
|
|
throw new NotImplementedException(); |
|
|
throw new NotImplementedException(); |
|
|
} |
|
|
} |
|
|