WCF中的发布-订阅服务

public abstract class SubscriptionManager<T> where T : class 
{ 
static void AddPersistent(string address,string eventsContract, 
string eventOperation) 
{ 
//使用ADO.NET在 SQL Server中存储订阅 
} 

static void RemovePersistent(string address,string eventsContract, 
string eventOperation) 
{ 
//使用ADO.NET将订阅从SQL Server中移除 
} 

[OperationBehavior(TransactionScopeRequired = true)] 
public void Unsubscribe(string address,string eventsContract, 
string eventOperation) 
{ 
if(String.IsNullOrEmpty(eventOperation) == false) 
{ 
RemovePersistent(address,eventsContract,eventOperation); 
} 
else 
{ 
string[] methods = GetOperations( ); 
Action<string> removePersistent = delegate(string methodName) 
{ 
RemovePersistent(address,eventsContract,methodName); 
}; 
Array.ForEach(methods,removePersistent); 
} 
} 
[OperationBehavior(TransactionScopeRequired = true)] 
public void Subscribe(string address,string eventsContract, 
string eventOperation) 
{ 
if(String.IsNullOrEmpty(eventOperation) == false) 
{ 
AddPersistent(address,eventsContract,eventOperation); 
} 
else 
{ 
string[] methods = GetOperations( ); 
Action<string> addPersistent = delegate(string methodName) 
{ 
AddPersistent(address,eventsContract,methodName); 
}; 
Array.ForEach(methods,addPersistent); 
} 
} 
//更多成员 
} 

上一页  [1] [2] [3] [4] [5] [6] 下一页

【责编:Zenghui】