diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpContent.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpContent.cs
index 97089cda3ea2..97097c93b0ef 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpContent.cs
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpContent.cs
@@ -17,12 +17,12 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.IO;
-using System.Net.Http;
 using System.Threading.Tasks;
 using Windows.Foundation;
 using Windows.Storage.Streams;
 
 using NetHttpContent = System.Net.Http.HttpContent;
+using NetHttpRequestMessage = System.Net.Http.HttpRequestMessage;
 using NetHttpResponseMessage = System.Net.Http.HttpResponseMessage;
 
 namespace Microsoft.WindowsAzure.ServiceLayer.Http
@@ -181,7 +181,7 @@ public IAsyncAction CopyToBufferAsync()
         /// Submits content data into the given request.
         /// </summary>
         /// <param name="request">Target request.</param>
-        internal void SubmitTo(HttpRequestMessage request)
+        internal void SubmitTo(NetHttpRequestMessage request)
         {
             NetHttpContent content = new System.Net.Http.StreamContent(
                 _rawContent.ReadAsStreamAsync().Result);
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpMethod.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpMethod.cs
new file mode 100644
index 000000000000..4e5322fe7134
--- /dev/null
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpMethod.cs
@@ -0,0 +1,34 @@
+//
+// Copyright 2012 Microsoft Corporation
+// 
+// Licensed under the Apache License, Version 2.0 (the "License");
+//  you may not use this file except in compliance with the License.
+//  You may obtain a copy of the License at
+//    http://www.apache.org/licenses/LICENSE-2.0
+// 
+//  Unless required by applicable law or agreed to in writing, software
+//  distributed under the License is distributed on an "AS IS" BASIS,
+//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  See the License for the specific language governing permissions and
+//  limitations under the License.
+//
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Microsoft.WindowsAzure.ServiceLayer.Http
+{
+    /// <summary>
+    /// Lists HTTP methods used by pipeline implementation.
+    /// </summary>
+    internal static class HttpMethod
+    {
+        internal const string Post              = "POST";
+        internal const string Get               = "GET";
+        internal const string Put               = "PUT";
+        internal const string Delete            = "DELETE";
+    }
+}
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpRequest.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpRequest.cs
new file mode 100644
index 000000000000..3800f55931c0
--- /dev/null
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Http/HttpRequest.cs
@@ -0,0 +1,100 @@
+//
+// Copyright 2012 Microsoft Corporation
+// 
+// Licensed under the Apache License, Version 2.0 (the "License");
+//  you may not use this file except in compliance with the License.
+//  You may obtain a copy of the License at
+//    http://www.apache.org/licenses/LICENSE-2.0
+// 
+//  Unless required by applicable law or agreed to in writing, software
+//  distributed under the License is distributed on an "AS IS" BASIS,
+//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  See the License for the specific language governing permissions and
+//  limitations under the License.
+//
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Http;
+using System.Text;
+using System.Threading.Tasks;
+using NetHttpMethod = System.Net.Http.HttpMethod;
+using NetHttpRequestMessage = System.Net.Http.HttpRequestMessage;
+
+namespace Microsoft.WindowsAzure.ServiceLayer.Http
+{
+    /// <summary>
+    /// Represents an HTTP request.
+    /// </summary>
+    public sealed class HttpRequest
+    {
+        private NetHttpMethod _method;                      // HTTP method verb (get/put/post, etc.)
+
+        /// <summary>
+        /// Gets the URI used for the HTTP request.
+        /// </summary>
+        public Uri Uri { get; private set; }
+
+        /// <summary>
+        /// Gets the HTTP method used for HTTP request.
+        /// </summary>
+        public string Method
+        {
+            get { return _method.ToString(); }
+        }
+
+        /// <summary>
+        /// Gets the headers.
+        /// </summary>
+        public IDictionary<string, string> Headers { get; private set; }
+
+        /// <summary>
+        /// Gets the content of the request.
+        /// </summary>
+        public HttpContent Content { get; set; }
+
+        /// <summary>
+        /// Initializes the request.
+        /// </summary>
+        /// <param name="method">The request's HTTP method.</param>
+        /// <param name="uri">The request's URI.</param>
+        public HttpRequest(string method, Uri uri)
+        {
+            if (uri == null)
+            {
+                throw new ArgumentNullException("uri");
+            }
+            if (method == null)
+            {
+                throw new ArgumentNullException("method");
+            }
+
+            Uri = uri;
+            _method = new NetHttpMethod(method);
+            Headers = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
+        }
+
+        /// <summary>
+        /// Creates a .Net request and populates it with all data.
+        /// </summary>
+        /// <returns>.Net request.</returns>
+        internal NetHttpRequestMessage CreateNetRequest()
+        {
+            NetHttpRequestMessage request = new NetHttpRequestMessage(_method, Uri);
+
+            // Populate headers.
+            foreach (KeyValuePair<string, string> headerItem in Headers)
+            {
+                request.Headers.Add(headerItem.Key, headerItem.Value);
+            }
+
+            // Populate content.
+            if (Content != null)
+            {
+                Content.SubmitTo(request);
+            }
+            return request;
+        }
+    }
+}
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Microsoft.WindowsAzure.ServiceLayer.csproj b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Microsoft.WindowsAzure.ServiceLayer.csproj
index 880172b39917..2a897c911219 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Microsoft.WindowsAzure.ServiceLayer.csproj
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/Microsoft.WindowsAzure.ServiceLayer.csproj
@@ -106,6 +106,8 @@
   </PropertyGroup>
   <ItemGroup>
     <Compile Include="Http\HttpContent.cs" />
+    <Compile Include="Http\HttpMethod.cs" />
+    <Compile Include="Http\HttpRequest.cs" />
     <Compile Include="Http\IHttpContent.cs" />
     <Compile Include="Http\MemoryContent.cs" />
     <Compile Include="Http\StreamContent.cs" />
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokerProperties.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokerProperties.cs
index 71113da6c2ca..a6e11197ffe8 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokerProperties.cs
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokerProperties.cs
@@ -16,10 +16,10 @@
 using System;
 using System.Globalization;
 using System.IO;
-using System.Net.Http;
 using System.Runtime.Serialization;
 using System.Runtime.Serialization.Json;
 using System.Text;
+using Microsoft.WindowsAzure.ServiceLayer.Http;
 
 namespace Microsoft.WindowsAzure.ServiceLayer.ServiceBus
 {
@@ -266,7 +266,7 @@ private static string DateTimeToUtcString(DateTimeOffset? source)
         /// Submits content of the class to the given HTTP request.
         /// </summary>
         /// <param name="request">Target request.</param>
-        internal void SubmitTo(HttpRequestMessage request)
+        internal void SubmitTo(HttpRequest request)
         {
             DataContractJsonSerializer serializer = new DataContractJsonSerializer(typeof(BrokerProperties));
             using (MemoryStream stream = new MemoryStream())
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageInfo.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageInfo.cs
index f9c6b6586d85..61764514361f 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageInfo.cs
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageInfo.cs
@@ -25,7 +25,6 @@
 using Windows.Foundation;
 using Windows.Storage.Streams;
 
-using NetHttpContent = System.Net.Http.HttpContent;
 using NetHttpResponseMessage = System.Net.Http.HttpResponseMessage;
 
 namespace Microsoft.WindowsAzure.ServiceLayer.ServiceBus
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageSettings.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageSettings.cs
index b9f719741331..0b38a7e54979 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageSettings.cs
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/BrokeredMessageSettings.cs
@@ -23,9 +23,6 @@
 using Windows.Foundation.Metadata;
 using Windows.Storage.Streams;
 
-using NetHttpContent = System.Net.Http.HttpContent;
-using NetHttpRequestMessage = System.Net.Http.HttpRequestMessage;
-
 namespace Microsoft.WindowsAzure.ServiceLayer.ServiceBus
 {
     /// <summary>
@@ -206,16 +203,15 @@ public static BrokeredMessageSettings CreateFromStream(IInputStream stream)
             return new BrokeredMessageSettings(content);
         }
 
-
         /// <summary>
         /// Submits content to the given request.
         /// </summary>
         /// <param name="request">Target request.</param>
-        internal void SubmitTo(NetHttpRequestMessage request)
+        internal void SubmitTo(HttpRequest request)
         {
             _brokerProperties.SubmitTo(request);
             _customProperties.SubmitTo(request);
-            Content.SubmitTo(request);
+            request.Content = Content;
         }
     }
 }
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/CustomPropertiesDictionary.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/CustomPropertiesDictionary.cs
index 3faf69ecdae6..a8c32f1b7571 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/CustomPropertiesDictionary.cs
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/CustomPropertiesDictionary.cs
@@ -18,11 +18,13 @@
 using System.Globalization;
 using System.Diagnostics;
 using System.Linq;
-using System.Net.Http;
 using System.Text;
 using System.Threading.Tasks;
+using Microsoft.WindowsAzure.ServiceLayer.Http;
 using Windows.Data.Json;
 
+using NetHttpResponseMessage = System.Net.Http.HttpResponseMessage;
+
 namespace Microsoft.WindowsAzure.ServiceLayer.ServiceBus
 {
     /// <summary>
@@ -42,7 +44,7 @@ internal CustomPropertiesDictionary()
         /// Initializes a dictionary with properties from the response.
         /// </summary>
         /// <param name="response">Response.</param>
-        internal CustomPropertiesDictionary(HttpResponseMessage response)
+        internal CustomPropertiesDictionary(NetHttpResponseMessage response)
             : this()
         {
             foreach (KeyValuePair<string, IEnumerable<string>> item in response.Headers)
@@ -66,7 +68,7 @@ internal CustomPropertiesDictionary(HttpResponseMessage response)
         /// Submits stored properties to the request.
         /// </summary>
         /// <param name="request">HTTP request.</param>
-        internal void SubmitTo(HttpRequestMessage request)
+        internal void SubmitTo(HttpRequest request)
         {
             foreach (KeyValuePair<string, object> item in this)
             {
@@ -107,7 +109,6 @@ private static object DecodeValue(JsonValue value)
                 return dateTime.ToUniversalTime();
             }
             return stringValue;
-
         }
 
         /// <summary>
diff --git a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/ServiceBusRestProxy.cs b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/ServiceBusRestProxy.cs
index a4e7caa6661f..4a9921dc6f82 100644
--- a/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/ServiceBusRestProxy.cs
+++ b/microsoft-azure-servicelayer/Microsoft.WindowsAzure.ServiceLayer/ServiceBus/ServiceBusRestProxy.cs
@@ -17,14 +17,19 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Net;
-using System.Net.Http;
 using System.Text;
 using System.Threading.Tasks;
-
+using Microsoft.WindowsAzure.ServiceLayer.Http;
 using Windows.Data.Xml.Dom;
 using Windows.Foundation;
 using Windows.Web.Syndication;
 
+using NetHttpClient = System.Net.Http.HttpClient;
+using NetHttpMessageHandler = System.Net.Http.HttpMessageHandler;
+using NetHttpMethod = System.Net.Http.HttpMethod;
+using NetHttpResponseMessage = System.Net.Http.HttpResponseMessage;
+using NetHttpRequestMessage = System.Net.Http.HttpRequestMessage;
+
 namespace Microsoft.WindowsAzure.ServiceLayer.ServiceBus
 {
     /// <summary>
@@ -51,7 +56,7 @@ internal class ServiceBusRestProxy: IServiceBusService
         /// <summary>
         /// Gets HTTP client used for communicating with the service.
         /// </summary>
-        private HttpClient Channel { get; set; }
+        private NetHttpClient Channel { get; set; }
 
 
         /// <summary>
@@ -64,8 +69,8 @@ internal ServiceBusRestProxy(ServiceConfiguration serviceOptions)
 
             ServiceConfig = serviceOptions;
 
-            HttpMessageHandler chain = new WrapAuthenticationHandler(serviceOptions);
-            Channel = new HttpClient(chain);
+            NetHttpMessageHandler chain = new WrapAuthenticationHandler(serviceOptions);
+            Channel = new NetHttpClient(chain);
         }
 
         /// <summary>
@@ -599,7 +604,7 @@ IAsyncAction IServiceBusService.SendMessageAsync(string destination, BrokeredMes
             }
 
             Uri uri = ServiceConfig.GetDestinationUri(destination);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Post, uri);
             message.SubmitTo(request);
 
             return SendAsync(request).AsAsyncAction();
@@ -619,7 +624,7 @@ IAsyncOperation<BrokeredMessageInfo> IServiceBusService.PeekQueueMessageAsync(st
             }
 
             Uri uri = ServiceConfig.GetUnlockedMessageUri(queueName, lockInterval);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Post, uri);
             return SendAsync(request, CheckNoContent)
                 .ContinueWith((t) => BrokeredMessageInfo.CreateFromPeekResponse(t.Result), TaskContinuationOptions.OnlyOnRanToCompletion)
                 .AsAsyncOperation();
@@ -639,7 +644,7 @@ IAsyncOperation<BrokeredMessageInfo> IServiceBusService.GetQueueMessageAsync(str
             }
 
             Uri uri = ServiceConfig.GetUnlockedMessageUri(queueName, lockInterval);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Delete, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Delete, uri);
             return SendAsync(request, CheckNoContent)
                 .ContinueWith((t) => new BrokeredMessageInfo(t.Result), TaskContinuationOptions.OnlyOnRanToCompletion)
                 .AsAsyncOperation();
@@ -664,7 +669,7 @@ IAsyncAction IServiceBusService.UnlockQueueMessageAsync(string queueName, long s
             }
 
             Uri uri = ServiceConfig.GetLockedMessageUri(queueName, sequenceNumber, lockToken);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Put, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Put, uri);
             return SendAsync(request)
                 .AsAsyncAction();
         }
@@ -688,7 +693,7 @@ IAsyncAction IServiceBusService.DeleteQueueMessageAsync(string queueName, long s
             }
 
             Uri uri = ServiceConfig.GetLockedMessageUri(queueName, sequenceNumber, lockToken);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Delete, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Delete, uri);
             return SendAsync(request)
                 .AsAsyncAction();
         }
@@ -714,7 +719,7 @@ IAsyncOperation<BrokeredMessageInfo> IServiceBusService.PeekSubscriptionMessageA
             }
 
             Uri uri = ServiceConfig.GetUnlockedSubscriptionMessageUri(topicName, subscriptionName, lockInterval);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Post, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Post, uri);
             return SendAsync(request, CheckNoContent)
                 .ContinueWith(t => new BrokeredMessageInfo(t.Result), TaskContinuationOptions.OnlyOnRanToCompletion)
                 .AsAsyncOperation();
@@ -740,7 +745,7 @@ IAsyncOperation<BrokeredMessageInfo> IServiceBusService.GetSubscriptionMessageAs
             }
 
             Uri uri = ServiceConfig.GetUnlockedSubscriptionMessageUri(topicName, subscriptionName, lockInterval);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Delete, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Delete, uri);
             return SendAsync(request, CheckNoContent)
                 .ContinueWith(t => new BrokeredMessageInfo(t.Result), TaskContinuationOptions.OnlyOnRanToCompletion)
                 .AsAsyncOperation();
@@ -771,7 +776,7 @@ IAsyncAction IServiceBusService.UnlockSubscriptionMessageAsync(string topicName,
             }
 
             Uri uri = ServiceConfig.GetLockedSubscriptionMessageUri(topicName, subscriptionName, sequenceNumber, lockToken);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Put, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Put, uri);
             return SendAsync(request)
                 .AsAsyncAction();
         }
@@ -800,7 +805,7 @@ IAsyncAction IServiceBusService.DeleteSubscriptionMessageAsync(string topicName,
             }
 
             Uri uri = ServiceConfig.GetLockedSubscriptionMessageUri(topicName, subscriptionName, sequenceNumber, lockToken);
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Delete, uri);
+            HttpRequest request = new HttpRequest(HttpMethod.Delete, uri);
             return SendAsync(request)
                 .AsAsyncAction();
         }
@@ -815,7 +820,7 @@ IAsyncAction IServiceBusService.DeleteSubscriptionMessageAsync(string topicName,
         /// <returns>A collection of items.</returns>
         private IAsyncOperation<IEnumerable<TInfo>> GetItemsAsync<TInfo>(Uri containerUri, Action<SyndicationItem, TInfo> initAction, params Type[] extraTypes)
         {
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, containerUri);
+            HttpRequest request = new HttpRequest(HttpMethod.Get, containerUri);
 
             return SendAsync(request, CheckNoContent)
                 .ContinueWith<IEnumerable<TInfo>>(r => GetItems<TInfo>(r.Result, initAction, extraTypes), TaskContinuationOptions.OnlyOnRanToCompletion)
@@ -852,7 +857,7 @@ private IAsyncOperation<IEnumerable<TInfo>> GetItemsAsync<TInfo>(
         /// <param name="initAction">Initialization action.</param>
         /// <param name="extraTypes">Extra types for deserialization.</param>
         /// <returns>Collection of deserialized items.</returns>
-        private IEnumerable<TInfo> GetItems<TInfo>(HttpResponseMessage response, Action<SyndicationItem, TInfo> initAction, params Type[] extraTypes)
+        private IEnumerable<TInfo> GetItems<TInfo>(NetHttpResponseMessage response, Action<SyndicationItem, TInfo> initAction, params Type[] extraTypes)
         {
             Debug.Assert(response.IsSuccessStatusCode);
             SyndicationFeed feed = new SyndicationFeed();
@@ -871,7 +876,7 @@ private IEnumerable<TInfo> GetItems<TInfo>(HttpResponseMessage response, Action<
         /// <returns>Item data</returns>
         private IAsyncOperation<TInfo> GetItemAsync<TInfo>(Uri itemUri, Action<SyndicationItem, TInfo> initAction, params Type[] extraTypes)
         {
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, itemUri);
+            HttpRequest request = new HttpRequest(HttpMethod.Get, itemUri);
 
             return SendAsync(request, CheckNoContent)
                 .ContinueWith<TInfo>(tr => GetItem<TInfo>(tr.Result, initAction, extraTypes), TaskContinuationOptions.OnlyOnRanToCompletion)
@@ -887,7 +892,7 @@ private IAsyncOperation<TInfo> GetItemAsync<TInfo>(Uri itemUri, Action<Syndicati
         /// <param name="initAction">Initialization action for deserialized items.</param>
         /// <param name="extraTypes">Extra types for deserialization.</param>
         /// <returns>Deserialized object.</returns>
-        private TInfo GetItem<TInfo>(HttpResponseMessage response, Action<SyndicationItem, TInfo> initAction, params Type[] extraTypes)
+        private TInfo GetItem<TInfo>(NetHttpResponseMessage response, Action<SyndicationItem, TInfo> initAction, params Type[] extraTypes)
         {
             Debug.Assert(response.IsSuccessStatusCode);
             XmlDocument doc = new XmlDocument();
@@ -906,7 +911,7 @@ private TInfo GetItem<TInfo>(HttpResponseMessage response, Action<SyndicationIte
         /// <returns>Deletion result.</returns>
         private IAsyncAction DeleteItemAsync(Uri itemUri)
         {
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Delete, itemUri);
+            HttpRequest request = new HttpRequest(HttpMethod.Delete, itemUri);
 
             return SendAsync(request)
                 .AsAsyncAction();
@@ -926,11 +931,11 @@ private IAsyncOperation<TInfo> CreateItemAsync<TInfo, TSettings>(
             TSettings itemSettings, 
             Action<SyndicationItem, TInfo> initAction) where TSettings: class
         {
-            HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Put, itemUri);
+            HttpRequest request = new HttpRequest(HttpMethod.Put, itemUri);
 
             return Task.Factory
                 .StartNew(() => SetBody(request, itemSettings, ExtraRuleTypes))
-                .ContinueWith<HttpResponseMessage>(tr => SendAsync(request).Result, TaskContinuationOptions.OnlyOnRanToCompletion)
+                .ContinueWith<NetHttpResponseMessage>(tr => SendAsync(request).Result, TaskContinuationOptions.OnlyOnRanToCompletion)
                 .ContinueWith<TInfo>(tr => GetItem<TInfo>(tr.Result, initAction, ExtraRuleTypes), TaskContinuationOptions.OnlyOnRanToCompletion)
                 .AsAsyncOperation<TInfo>();
         }
@@ -941,11 +946,11 @@ private IAsyncOperation<TInfo> CreateItemAsync<TInfo, TSettings>(
         /// <param name="request">Target request.</param>
         /// <param name="bodyObject">Object to serialize.</param>
         /// <param name="supportedTypes">Supported types.</param>
-        private void SetBody(HttpRequestMessage request, object bodyObject, params Type[] supportedTypes)
+        private void SetBody(HttpRequest request, object bodyObject, params Type[] supportedTypes)
         {
             string content = SerializationHelper.Serialize(bodyObject, supportedTypes);
-            request.Content = new StringContent(content, Encoding.UTF8, Constants.BodyContentType);
-            request.Content.Headers.ContentType.Parameters.Add(new System.Net.Http.Headers.NameValueHeaderValue("type", "entry"));
+            request.Content = HttpContent.CreateFromText(content, Constants.BodyContentType);
+            request.Headers.Add("type", "entry");
         }
 
         /// <summary>
@@ -994,7 +999,7 @@ private static void InitRule(SyndicationItem feedItem, RuleInfo ruleInfo)
         /// <param name="response">Source HTTP response.</param>
         /// <param name="validators">Additional validators.</param>
         /// <returns>Processed HTTP response.</returns>
-        private HttpResponseMessage CheckResponse(HttpResponseMessage response, IEnumerable<Func<HttpResponseMessage, HttpResponseMessage>> validators)
+        private NetHttpResponseMessage CheckResponse(NetHttpResponseMessage response, IEnumerable<Func<NetHttpResponseMessage, NetHttpResponseMessage>> validators)
         {
             if (!response.IsSuccessStatusCode)
             {
@@ -1002,7 +1007,7 @@ private HttpResponseMessage CheckResponse(HttpResponseMessage response, IEnumera
             }
 
             // Pass the response through all validators.
-            foreach (Func<HttpResponseMessage, HttpResponseMessage> validator in validators)
+            foreach (Func<NetHttpResponseMessage, NetHttpResponseMessage> validator in validators)
             {
                 response = validator(response);
             }
@@ -1014,10 +1019,11 @@ private HttpResponseMessage CheckResponse(HttpResponseMessage response, IEnumera
         /// </summary>
         /// <param name="request">Request to send.</param>
         /// <returns>HTTP response.</returns>
-        private Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, params Func<HttpResponseMessage, HttpResponseMessage>[] validators)
+        private Task<NetHttpResponseMessage> SendAsync(HttpRequest request, params Func<NetHttpResponseMessage, NetHttpResponseMessage>[] validators)
         {
-            return Channel.SendAsync(request)
-                .ContinueWith<HttpResponseMessage>((task) => CheckResponse(task.Result, validators), TaskContinuationOptions.OnlyOnRanToCompletion);
+            NetHttpRequestMessage netRequest = request.CreateNetRequest();
+            return Channel.SendAsync(netRequest)
+                .ContinueWith<NetHttpResponseMessage>((task) => CheckResponse(task.Result, validators), TaskContinuationOptions.OnlyOnRanToCompletion);
         }
 
         /// <summary>
@@ -1025,7 +1031,7 @@ private Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, params F
         /// </summary>
         /// <param name="response">Source response.</param>
         /// <returns>Processed HTTP response.</returns>
-        private HttpResponseMessage CheckNoContent(HttpResponseMessage response)
+        private NetHttpResponseMessage CheckNoContent(NetHttpResponseMessage response)
         {
             if (response.StatusCode == System.Net.HttpStatusCode.NoContent || response.StatusCode == HttpStatusCode.ResetContent)
             {