本文整理汇总了C#中IChannelSender类的典型用法代码示例。如果您正苦于以下问题:C# IChannelSender类的具体用法?C# IChannelSender怎么用?C# IChannelSender使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
IChannelSender类属于命名空间,在下文中一共展示了IChannelSender类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: Add
internal void Add(IChannelSender sender)
{
if (!this._senders.Contains(sender))
lock (this._senders)
if (!this._senders.Contains(sender))
this._senders.Add(sender);
}
开发者ID:fengxianqi,项目名称:Youbang,代码行数:7,代码来源:EndpointProxy.cs
示例2: GetChannel
private IClientChannel GetChannel(IChannelSender sender)
{
var channel = sender as IClientChannel;
if (channel.OnMessage == null)
channel.OnMessage = this._onMessage;
return channel;
}
开发者ID:fengxianqi,项目名称:Youbang,代码行数:7,代码来源:EndpointHandler.cs
示例3: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
IClientChannelSink nextSink = null;
if (nextProvider != null)
nextSink = nextProvider.CreateSink(channel, url, remoteChannelData);
return new ClientChannelImpersonationSink(nextSink, username, password);
}
开发者ID:H1GHGuY,项目名称:ServerCheckerV4,代码行数:7,代码来源:ClientChannelImpersonationSink.cs
示例4: ClientSinkData
public ClientSinkData(SinkProviderData configurationData, IChannelSender channel, string url, object remoteChannelData)
{
this.Channel = channel;
this.Url = url;
this.RemoteChannelData = remoteChannelData;
this.ConfigurationData = configurationData;
}
开发者ID:sanjayshah89,项目名称:Remoting,代码行数:7,代码来源:SinkData.cs
示例5: Transmit
void Transmit(IChannelSender channelSender, Site targetSite, CallType callType, IDictionary<string,string> headers, Stream data)
{
headers[HeaderMapper.NServiceBus + HeaderMapper.CallType] = Enum.GetName(typeof(CallType), callType);
headers[HttpHeaders.ContentMd5Key] = Hasher.Hash(data);
Logger.DebugFormat("Sending message - {0} to: {1}", callType, targetSite.Address);
channelSender.Send(targetSite.Address, headers, data);
}
开发者ID:Jpattom,项目名称:NServiceBus,代码行数:9,代码来源:IdempotentSender.cs
示例6: MSMQClientTransportSink
private Sender m_Sender; // channel
#endregion Fields
#region Constructors
public MSMQClientTransportSink(IChannelSender channel, string url)
{
// state
m_Sender = channel as Sender; // parent
m_LogicalUri = url; // url address trimed by channel name
// echo
Trace.WriteLine(string.Format("[{0}]MSMQClientTransportSink has been contructed", m_Sender.ChannelName));
}
开发者ID:yallie,项目名称:zyan,代码行数:15,代码来源:SenderMessageSink.cs
示例7: CreateSink
public IClientChannelSink CreateSink( IChannelSender channel,
string url,
object remoteChannelData)
{
IClientChannelSink _nextSink = _nextClientChannelSinkProvider.CreateSink(channel, url, remoteChannelData);
SoapClientFormatterSink scfs = new SoapClientFormatterSink(_nextSink);
scfs.SoapCore = _soapCore;
return scfs;
}
开发者ID:nlhepler,项目名称:mono,代码行数:10,代码来源:SoapClientFormatterSinkProvider.cs
示例8: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
if (this.Next != null)
{
var nextChannelSink = Next.CreateSink(channel, url, remoteChannelData);
if (nextChannelSink != null)
return new JsonClientFormatterSink(nextChannelSink);
}
return null;
}
开发者ID:wsky,项目名称:top-link,代码行数:10,代码来源:JsonClientFormatterSinkProvider.cs
示例9: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
IClientChannelSink nextSink = null;
if (_nextProvider != null)
// создаем следующий приемник в цепи
nextSink = _nextProvider.CreateSink(channel, url, remoteChannelData);
// добавляем наш приемник в цепь
return new IpFixClientChannelSink(nextSink, _serverHostNameOrIp);
}
开发者ID:Dennis-Petrov,项目名称:Cash,代码行数:11,代码来源:IpFixClientChannelSinkProvider.cs
示例10: CreateSink
/// <summary>
/// Creates a sink chain.
/// </summary>
public IClientChannelSink CreateSink (IChannelSender channel, string url, object remoteChannelData) {
// Create next sink:
IClientChannelSink nextSink = next.CreateSink(channel,url,remoteChannelData);
// Return current sink chained to next sink:
IMessageSink nextMessageSink = nextSink as IMessageSink;
if (nextMessageSink != null) {
return new RemotingMockingSink(nextMessageSink);
} else {
throw new RemotingException(String.Format("Remoting configuration error : the '{0}' provider should be defined as provider in the clientProviders section of the channel, before any formatter.", this.GetType()));
}
}
开发者ID:codetuner,项目名称:Arebis.Common,代码行数:14,代码来源:RemotingMockingSink.cs
示例11: Transmit
void Transmit(IChannelSender channelSender, Site targetSite, CallType callType,
IDictionary<string, string> headers, Stream data)
{
headers[GatewayHeaders.IsGatewayMessage] = Boolean.TrueString;
headers["NServiceBus.CallType"] = Enum.GetName(typeof(CallType), callType);
headers[HttpHeaders.ContentMD5] = Hasher.Hash(data);
Logger.DebugFormat("Sending message - {0} to: {1}", callType, targetSite.Channel.Address);
channelSender.Send(targetSite.Channel.Address, headers, data);
}
开发者ID:ramonsmits,项目名称:NServiceBus.Gateway,代码行数:11,代码来源:SingleCallChannelForwarder.cs
示例12: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
TcpClientTransportSink sink = new TcpClientTransportSink(url, (TcpClientChannel) channel);
if (this._prop != null)
{
foreach (object obj2 in this._prop.Keys)
{
sink[obj2] = this._prop[obj2];
}
}
return sink;
}
开发者ID:pritesh-mandowara-sp,项目名称:DecompliedDotNetLibraries,代码行数:12,代码来源:TcpClientTransportSinkProvider.cs
示例13: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, String url, Object remoteChannelData)
{
IClientChannelSink nextSink = null;
if (_next != null)
{
nextSink = _next.CreateSink(channel, url, remoteChannelData);
if (nextSink == null)
return null;
}
return new ClientChannelSink(url, nextSink);
}
开发者ID:virl,项目名称:yttrium,代码行数:12,代码来源:ClientChannelSinkProvider.cs
示例14: SendAndWait
internal IDictionary<string, object> SendAndWait(EndpointProxy e
, IChannelSender sender
, Message message
, int timeout)
{
SendCallback callback = new SendCallback(e);
this.Send(message, sender, callback);
callback.WaitReturn(timeout);
if (callback.Error != null)
throw callback.Error;
return callback.Return;
}
开发者ID:fengxianqi,项目名称:Youbang,代码行数:12,代码来源:EndpointHandler.cs
示例15: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
// create the Message Sink
IClientChannelSink sink = new MSMQClientTransportSink(channel, url);
// echo
Trace.WriteLine(string.Format("[{0}]MSMQClientProvider.CreateSink has been initiated. url={1}",
channel.ChannelName, url));
// successful result
return sink;
}
开发者ID:yallie,项目名称:zyan,代码行数:12,代码来源:SenderMessageSink.cs
示例16: Send
public void Send(Message message, IChannelSender sender, SendCallback callback)
{
if (callback != null)
{
message.Flag = System.Threading.Interlocked.Increment(ref this._flag);
this._callbacks.Add(message.Flag, callback);
}
using (var s = new MemoryStream())
{
MessageIO.WriteMessage(s, message);
this.GetChannel(sender).Send(s.ToArray());
}
}
开发者ID:fengxianqi,项目名称:Youbang,代码行数:13,代码来源:EndpointHandler.cs
示例17: CreateSink
public IClientChannelSink CreateSink(
IChannelSender channel_in,
string url_in,
object remoteChannelData_in
) {
IClientChannelSink _next = next_.CreateSink(
channel_in,
url_in,
remoteChannelData_in
);
return new CompressionClientSink(_next);
}
开发者ID:BackupTheBerlios,项目名称:ogen-svn,代码行数:13,代码来源:CompressionClientSinkProvider.cs
示例18: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
IClientChannelSink nextSink = null;
if (_next != null) {
// Call CreateSink on the next sink provier in the chain. This will return
// to us the actual next sink object. If the next sink is null, uh oh!
if ((nextSink = _next.CreateSink(channel, url, remoteChannelData)) == null) return null;
}
// Create this sink, passing to it the previous sink in the chain so that it knows
// to whom messages should be passed.
return new CompressedClientChannelSink(nextSink);
}
开发者ID:anand-ajmera,项目名称:cornell-urban-challenge,代码行数:14,代码来源:CompressedClientChannelSinkProvider.cs
示例19: CreateSink
// public methods
/// <summary>
///
/// </summary>
/// <param name="channel"></param>
/// <param name="url"></param>
/// <param name="remoteChannelData"></param>
/// <returns></returns>
public IClientChannelSink CreateSink(
IChannelSender channel,
string url,
object remoteChannelData)
{
IClientChannelSink ccs = null;
if (m_next != null)
{
ccs = m_next.CreateSink(channel, url, remoteChannelData);
if (ccs == null)
return null;
}
return new XmlRpcClientFormatterSink(ccs);
}
开发者ID:Orvid,项目名称:Zutubi.Pulse.Api,代码行数:22,代码来源:XmlRpcClientFormatterSinkProvider.cs
示例20: CreateSink
public IClientChannelSink CreateSink(IChannelSender channel, string url, object remoteChannelData)
{
IClientChannelSink nextSink = null;
if (this._next != null)
{
nextSink = this._next.CreateSink(channel, url, remoteChannelData);
if (nextSink == null)
{
return null;
}
}
SinkChannelProtocol protocol = CoreChannel.DetermineChannelProtocol(channel);
return new SoapClientFormatterSink(nextSink) { IncludeVersioning = this._includeVersioning, StrictBinding = this._strictBinding, ChannelProtocol = protocol };
}
开发者ID:pritesh-mandowara-sp,项目名称:DecompliedDotNetLibraries,代码行数:14,代码来源:SoapClientFormatterSinkProvider.cs
注:本文中的IChannelSender类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论