System\ServiceModel\Channels\PeerNodeImplementation.cs (19)
348if (-1 != message.Headers.FindHeader(PeerStrings.MessageId, PeerStrings.Namespace))
350if (-1 != message.Headers.FindHeader(PeerOperationNames.PeerTo, PeerStrings.Namespace))
352if (-1 != message.Headers.FindHeader(PeerOperationNames.PeerVia, PeerStrings.Namespace))
354if (-1 != message.Headers.FindHeader(PeerOperationNames.Flood, PeerStrings.Namespace, PeerOperationNames.Demuxer))
357message.Headers.Add(PeerDictionaryHeader.CreateMessageIdHeader(messageId));
359message.Headers.Add(MessageHeader.CreateHeader(PeerOperationNames.PeerTo, PeerStrings.Namespace, message.Headers.To));
360message.Headers.Add(PeerDictionaryHeader.CreateViaHeader(via));
361message.Headers.Add(PeerDictionaryHeader.CreateFloodRole());
454int i = msg.Headers.FindHeader(SecurityJan2004Strings.Security, SecurityJan2004Strings.Namespace);
457msg.Headers.AddUnderstood(i);
461DeliverMessageToClientChannels(registrant, clientBuffer, via, message.Headers.To, contentType, messageSize, -1, null);
881throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.PeerMessageMustHaveVia, message.Headers.Action)));
920throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.PeerMessageMustHaveVia, message.Headers.Action)));
1439Fx.Assert(message.Headers.To == to, "To Header is inconsistent in Send() case!");
1478localCopy.Headers.To = to;
1482int i = localCopy.Headers.FindHeader(SecurityJan2004Strings.Security, SecurityJan2004Strings.Namespace);
1485localCopy.Headers.AddUnderstood(i);
1503localCopy.Headers.ReplaceAt(index, hopHeader);
System\ServiceModel\Channels\ServiceChannel.cs (12)
621MessageHeaders headers = rpc.Request.Headers;
994if ((operation.ReplyAction != MessageHeaders.WildcardAction) && !rpc.Reply.IsFault && rpc.Reply.Headers.Action != null)
996if (String.CompareOrdinal(operation.ReplyAction, rpc.Reply.Headers.Action) != 0)
1000rpc.Reply.Headers.Action,
1009string action = rpc.Reply.Headers.Action;
1253if (!context.OutgoingMessageVersion.IsMatch(message.Headers.MessageVersion))
1256SR.GetString(SR.SFxVersionMismatchInOperationContextAndMessage2, context.OutgoingMessageVersion, message.Headers.MessageVersion)
1262message.Headers.CopyHeadersFrom(context.OutgoingMessageHeaders);
1281this.Call(message.Headers.Action, true, operation, new object[] { message }, EmptyArray<object>.Instance, timeout);
1292return this.BeginCall(message.Headers.Action, true, operation, new object[] { message }, timeout, callback, state);
1308return (Message)this.Call(message.Headers.Action, false, operation, new object[] { message }, EmptyArray<object>.Instance, timeout);
1319return this.BeginCall(message.Headers.Action, false, operation, new object[] { message }, timeout, callback, state);
System\ServiceModel\Dispatcher\XmlSerializerOperationFormatter.cs (4)
101message.Headers.Add(new XmlElementMessageHeader(this, message.Version, element.LocalName, element.NamespaceURI,
113message.Headers.Add(new XmlElementMessageHeader(this, message.Version, element.LocalName, element.NamespaceURI,
125message.Headers.Add(new XmlElementMessageHeader(this, message.Version, element.LocalName, element.NamespaceURI,
156MessageHeaders headers = message.Headers;
System\ServiceModel\Security\NegotiationTokenAuthenticator.cs (12)
570if (message.Headers.Action == this.RequestSecurityTokenAction.Value)
580else if (message.Headers.Action == this.RequestSecurityTokenResponseAction.Value)
592throw TraceUtility.ThrowHelperError(new SecurityNegotiationException(SR.GetString(SR.InvalidActionForNegotiationMessage, message.Headers.Action)), message);
598if (request.Headers.MessageId != null)
732string action = request.Headers.Action;
748to = request.Headers.To;
824this.suppressAuditFailure, request, request.Headers.To, request.Headers.Action,
845this.suppressAuditFailure, request, request.Headers.To, request.Headers.Action,
946faultReply.Headers.RelatesTo = request.Headers.MessageId;
System\ServiceModel\Security\SecurityProtocol.cs (7)
586IList<SupportingTokenProviderSpecification> supportingTokenProviders = this.GetSupportingTokenProviders(message.Headers.Action);
634IList<SupportingTokenAuthenticatorSpecification> authenticators = factory.GetSupportingTokenAuthenticators(message.Headers.Action,
812this.factory.SuppressAuditFailure, verifiedMessage, verifiedMessage.Headers.To, verifiedMessage.Headers.Action,
841this.factory.SuppressAuditFailure, message, message.Headers.To, message.Headers.Action, primaryIdentity, exception);
961this.supportingTokenProviders = this.binding.GetSupportingTokenProviders(message.Headers.Action);
System\ServiceModel\Security\SecuritySessionSecurityTokenAuthenticator.cs (10)
476faultReply.Headers.RelatesTo = request.Headers.MessageId;
677throw TraceUtility.ThrowHelperWarning(new InvalidOperationException(SR.GetString(SR.SecurityContextMissing, request.Headers.Action)), request);
806this.NotifyOperationCompletion(SecuritySessionOperation.Renew, newToken, (SecurityContextSecurityToken)sessionToken.SecurityToken, request.Headers.ReplyTo);
950this.NotifyOperationCompletion(SecuritySessionOperation.Issue, issuedToken, null, request.Headers.ReplyTo);
996if (request.Headers.MessageId != null)
1018if (request.Headers.Action == this.IssueAction.Value)
1023else if (request.Headers.Action == this.RenewAction.Value)
1030throw TraceUtility.ThrowHelperWarning(new SecurityNegotiationException(SR.GetString(SR.InvalidActionForNegotiationMessage, request.Headers.Action)), request);
1344if (message.Headers.Action == this.actions[i])