本文整理汇总了C#中EndpointAddress类的典型用法代码示例。如果您正苦于以下问题:C# EndpointAddress类的具体用法?C# EndpointAddress怎么用?C# EndpointAddress使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
EndpointAddress类属于命名空间,在下文中一共展示了EndpointAddress类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: CreateSubscriptionRequest
static MessagePayload CreateSubscriptionRequest(EndpointAddress subscriberAddress, EndpointAddress publisherAddress)
{
return new MessagePayload()
.SetFromEndpointAddress(subscriberAddress)
.SetToEndpointAddress(publisherAddress)
.AsSubscriptionRequest();
}
开发者ID:SystemDot,项目名称:SystemDotServiceBus,代码行数:7,代码来源:WithPublisherSubject.cs
示例2: ClientWebSocketTransportDuplexSessionChannel
public ClientWebSocketTransportDuplexSessionChannel(HttpChannelFactory<IDuplexSessionChannel> channelFactory, ClientWebSocketFactory connectionFactory, EndpointAddress remoteAddresss, Uri via, ConnectionBufferPool bufferPool)
: base(channelFactory, remoteAddresss, via, bufferPool)
{
Contract.Assert(channelFactory != null, "connection factory must be set");
_channelFactory = channelFactory;
_connectionFactory = connectionFactory;
}
开发者ID:noodlese,项目名称:wcf,代码行数:7,代码来源:ClientWebSocketTransportDuplexSessionChannel.cs
示例3: IssuedSecurityTokenParameters
public IssuedSecurityTokenParameters (string tokenType,
EndpointAddress issuerAddress, Binding issuerBinding)
{
token_type = tokenType;
issuer_address = issuerAddress;
binding = issuerBinding;
}
开发者ID:calumjiao,项目名称:Mono-Class-Libraries,代码行数:7,代码来源:IssuedSecurityTokenParameters.cs
示例4: CreateQueue
public static MessageQueue CreateQueue(EndpointAddress address, bool isTransactional = true)
{
var name = address.GetQueueName();
var queue = MessageQueue.Create(name, isTransactional);
SetQueuePermissions(queue);
return queue;
}
开发者ID:Zapote,项目名称:EzBus,代码行数:7,代码来源:MsmqUtilities.cs
示例5: DuplexClientRuntimeChannel
public DuplexClientRuntimeChannel (ServiceEndpoint endpoint,
ChannelFactory factory, EndpointAddress remoteAddress, Uri via)
: base (endpoint, factory, remoteAddress, via)
{
var ed = new EndpointDispatcher (remoteAddress, endpoint.Contract.Name, endpoint.Contract.Namespace);
ed.InitializeServiceEndpoint (true, null, endpoint);
Runtime.CallbackDispatchRuntime = ed.DispatchRuntime;
}
开发者ID:kumpera,项目名称:mono,代码行数:8,代码来源:DuplexClientRuntimeChannel.cs
示例6: DirectChannelConfiguration
public DirectChannelConfiguration(EndpointAddress address, MessagingConfiguration messagingConfiguration)
{
Contract.Requires(messagingConfiguration != null);
Contract.Requires(address != null);
this.messagingConfiguration = messagingConfiguration;
this.address = address;
}
开发者ID:SystemDot,项目名称:SystemDotServiceBus,代码行数:8,代码来源:DirectChannelConfiguration.cs
示例7: AdjustAddress
static void AdjustAddress(ref EndpointAddress reference, Uri via)
{
// if we don't have an identity and we have differing Uris, we should use the Via
if (reference.Identity == null && reference.Uri != via)
{
reference = new EndpointAddress(via);
}
}
开发者ID:TerabyteX,项目名称:wcf,代码行数:8,代码来源:IdentityVerifier.cs
示例8: CallbackContextMessageProperty
public CallbackContextMessageProperty(EndpointAddress callbackAddress)
{
if (callbackAddress == null)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("callbackAddress");
}
this.callbackAddress = callbackAddress;
}
开发者ID:iskiselev,项目名称:JSIL.NetFramework,代码行数:8,代码来源:CallbackContextMessageProperty.cs
示例9: SenderAuthenticationSessionAttacher
public SenderAuthenticationSessionAttacher(
AuthenticationSessionCache cache,
AuthenticatedServerRegistry registry,
EndpointAddress address) : base(cache, registry)
{
Contract.Requires(address != null);
this.address = address;
}
开发者ID:SystemDot,项目名称:SystemDotServiceBus,代码行数:8,代码来源:SenderAuthenticationSessionAttacher.cs
示例10: ServiceEndpoint
public ServiceEndpoint(ContractDescription contract, Binding binding, EndpointAddress address)
{
if (contract == null)
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("contract");
_contract = contract;
_binding = binding;
_address = address;
}
开发者ID:SoumikMukherjeeDOTNET,项目名称:wcf,代码行数:9,代码来源:ServiceEndpoint.cs
示例11: Send
public void Send(EndpointAddress destination, ChannelMessage channelMessage)
{
var queueName = destination.QueueName;
if (!namespaceManager.QueueExists(queueName)) throw new Exception(string.Format("Destination {0} does not exist.", destination));
var sendingClient = QueueClient.Create(queueName);
var message = CreateBrokeredMessage(channelMessage);
sendingClient.Send(message);
}
开发者ID:Zapote,项目名称:EzBus,代码行数:9,代码来源:ServiceBusSendingChannel.cs
示例12: WebSocketTransportDuplexSessionChannel
public WebSocketTransportDuplexSessionChannel(HttpChannelFactory<IDuplexSessionChannel> channelFactory, EndpointAddress remoteAddresss, Uri via)
: base(channelFactory, channelFactory, EndpointAddress.AnonymousAddress, channelFactory.MessageVersion.Addressing.AnonymousUri, remoteAddresss, via)
{
Fx.Assert(channelFactory.WebSocketSettings != null, "channelFactory.WebSocketTransportSettings should not be null.");
_webSocketSettings = channelFactory.WebSocketSettings;
_transferMode = channelFactory.TransferMode;
_maxBufferSize = channelFactory.MaxBufferSize;
_transportFactorySettings = channelFactory;
}
开发者ID:weshaggard,项目名称:wcf,代码行数:9,代码来源:WebSocketTransportDuplexSessionChannel.cs
示例13: CreateEndpointSettings
public CreateEndpointSettings(IEndpointAddress address)
: this()
{
Guard.Against.Null(address, "The address cannot be null");
Address = new EndpointAddress(address.Uri);
SetDefaultErrorAddress();
}
开发者ID:KevM,项目名称:MassTransit,代码行数:9,代码来源:CreateEndpointSettings.cs
示例14: MessageTransmitTraceRecord
MessageTransmitTraceRecord(Message message, string addressElementName, EndpointAddress address)
:
this(message, addressElementName)
{
if (address != null)
{
this.address = address.Uri;
}
}
开发者ID:iskiselev,项目名称:JSIL.NetFramework,代码行数:9,代码来源:MessageTransmitTraceRecord.cs
示例15: FreeUpSlot
void FreeUpSlot(Guid messageId, EndpointAddress address, PersistenceUseType useType)
{
if (useType != cache.UseType || address != cache.Address) return;
MessagePayload message;
sentMessages.TryRemove(messageId, out message);
SendMessages();
}
开发者ID:SystemDot,项目名称:SystemDotServiceBus,代码行数:9,代码来源:LoadBalancer.cs
示例16: EnsureOutgoingIdentity
internal void EnsureOutgoingIdentity(EndpointAddress serviceReference, ReadOnlyCollection<IAuthorizationPolicy> authorizationPolicies)
{
if (authorizationPolicies == null)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("authorizationPolicies");
}
AuthorizationContext ac = AuthorizationContext.CreateDefaultAuthorizationContext(authorizationPolicies);
EnsureIdentity(serviceReference, ac, SR.IdentityCheckFailedForOutgoingMessage);
}
开发者ID:TerabyteX,项目名称:wcf,代码行数:9,代码来源:IdentityVerifier.cs
示例17: PublisherConfiguration
public PublisherConfiguration(EndpointAddress address, MessagingConfiguration messagingConfiguration)
: base(messagingConfiguration)
{
schema = new PublisherChannelSchema
{
FromAddress = address,
MessageFilterStrategy = new PassThroughMessageFilterStategy()
};
}
开发者ID:SystemDot,项目名称:SystemDotServiceBus,代码行数:9,代码来源:PublisherConfiguration.cs
示例18: AnnouncementEndpoint
public AnnouncementEndpoint(DiscoveryVersion discoveryVersion, Binding binding, EndpointAddress address)
: base(GetAnnouncementContract(discoveryVersion))
{
// Send replies async to maintain performance
this.EndpointBehaviors.Add(new DispatcherSynchronizationBehavior { AsynchronousSendEnabled = true });
this.discoveryVersion = discoveryVersion;
base.Address = address;
base.Binding = binding;
}
开发者ID:nlh774,项目名称:DotNetReferenceSource,代码行数:10,代码来源:AnnouncementEndpoint.cs
示例19: ResolveCriteria
public ResolveCriteria(EndpointAddress address)
{
if (address == null)
{
throw FxTrace.Exception.ArgumentNull("address");
}
this.endpointAddress = address;
this.duration = ResolveCriteria.defaultDuration;
}
开发者ID:krytht,项目名称:DotNetReferenceSource,代码行数:10,代码来源:ResolveCriteria.cs
示例20: MessageAddresser
public MessageAddresser(
EndpointAddress fromAddress,
EndpointAddress toAddress)
{
Contract.Requires(fromAddress != null);
Contract.Requires(toAddress != null);
this.fromAddress = fromAddress;
this.toAddress = toAddress;
}
开发者ID:SystemDot,项目名称:SystemDotServiceBus,代码行数:10,代码来源:MessageAddresser.cs
注:本文中的EndpointAddress类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论