|
|
@@ -61,47 +61,47 @@ namespace DotNetCore.CAP.Test |
|
|
|
|
|
|
|
private class MyProducerService : ICapPublisher |
|
|
|
{ |
|
|
|
public void Publish(string name, string content) |
|
|
|
public void Publish<T>(string name, T contentObj, string callbackName = null) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public void Publish<T>(string name, T contentObj) |
|
|
|
public void Publish<T>(string name, T contentObj, IDbConnection dbConnection, string callbackName = null, IDbTransaction dbTransaction = null) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public void Publish(string name, string content, IDbConnection dbConnection, IDbTransaction dbTransaction = null) |
|
|
|
public Task PublishAsync(string topic, string content) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public void Publish<T>(string name, T contentObj, IDbConnection dbConnection, IDbTransaction dbTransaction = null) |
|
|
|
public Task PublishAsync<T>(string topic, T contentObj) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public Task PublishAsync(string topic, string content) |
|
|
|
public Task PublishAsync(string topic, string content, IDbConnection dbConnection) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public Task PublishAsync<T>(string topic, T contentObj) |
|
|
|
public Task PublishAsync(string topic, string content, IDbConnection dbConnection, IDbTransaction dbTransaction) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public Task PublishAsync(string topic, string content, IDbConnection dbConnection) |
|
|
|
public Task PublishAsync<T>(string name, T contentObj, IDbConnection dbConnection, IDbTransaction dbTransaction = null) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public Task PublishAsync(string topic, string content, IDbConnection dbConnection, IDbTransaction dbTransaction) |
|
|
|
public Task PublishAsync<T>(string name, T contentObj, string callbackName = null) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|
|
|
|
|
public Task PublishAsync<T>(string name, T contentObj, IDbConnection dbConnection, IDbTransaction dbTransaction = null) |
|
|
|
public Task PublishAsync<T>(string name, T contentObj, IDbConnection dbConnection, string callbackName = null, IDbTransaction dbTransaction = null) |
|
|
|
{ |
|
|
|
throw new NotImplementedException(); |
|
|
|
} |
|
|
|