@@ -40,42 +40,42 @@ public partial class MessageSendE2ETests : E2EMsTestBase
4040 private readonly string _modulePrefix = $ "{ nameof ( MessageSendE2ETests ) } _";
4141 private static readonly string s_proxyServerAddress = TestConfiguration . IotHub . ProxyServerAddress ;
4242
43- [ TestMethodWithRetry ( Max = 3 ) ]
43+ [ TestMethodWithRetry ( Max = 3 ) ]
4444 [ Timeout ( TestTimeoutMilliseconds ) ]
4545 public async Task Message_DeviceSendSingleMessage_Amqp ( )
4646 {
4747 await SendSingleMessage ( TestDeviceType . Sasl , Client . TransportType . Amqp_Tcp_Only ) . ConfigureAwait ( false ) ;
4848 }
4949
50- [ TestMethodWithRetry ( Max = 3 ) ]
50+ [ TestMethodWithRetry ( Max = 3 ) ]
5151 [ Timeout ( TestTimeoutMilliseconds ) ]
5252 public async Task Message_DeviceSendSingleMessage_AmqpWs ( )
5353 {
5454 await SendSingleMessage ( TestDeviceType . Sasl , Client . TransportType . Amqp_WebSocket_Only ) . ConfigureAwait ( false ) ;
5555 }
5656
57- [ TestMethodWithRetry ( Max = 3 ) ]
57+ [ TestMethodWithRetry ( Max = 3 ) ]
5858 [ Timeout ( TestTimeoutMilliseconds ) ]
5959 public async Task Message_DeviceSendSingleMessage_Mqtt ( )
6060 {
6161 await SendSingleMessage ( TestDeviceType . Sasl , Client . TransportType . Mqtt_Tcp_Only ) . ConfigureAwait ( false ) ;
6262 }
6363
64- [ TestMethodWithRetry ( Max = 3 ) ]
64+ [ TestMethodWithRetry ( Max = 3 ) ]
6565 [ Timeout ( TestTimeoutMilliseconds ) ]
6666 public async Task Message_DeviceSendSingleMessage_MqttWs ( )
6767 {
6868 await SendSingleMessage ( TestDeviceType . Sasl , Client . TransportType . Mqtt_WebSocket_Only ) . ConfigureAwait ( false ) ;
6969 }
7070
71- [ TestMethodWithRetry ( Max = 3 ) ]
71+ [ TestMethodWithRetry ( Max = 3 ) ]
7272 [ Timeout ( TestTimeoutMilliseconds ) ]
7373 public async Task Message_DeviceSendSingleMessage_Http ( )
7474 {
7575 await SendSingleMessage ( TestDeviceType . Sasl , Client . TransportType . Http1 ) . ConfigureAwait ( false ) ;
7676 }
7777
78- [ TestMethodWithRetry ( Max = 3 ) ]
78+ [ TestMethodWithRetry ( Max = 3 ) ]
7979 [ Timeout ( TestTimeoutMilliseconds ) ]
8080 public async Task Message_DeviceSendSingleMessage_Amqp_WithHeartbeats ( )
8181 {
@@ -87,7 +87,7 @@ public async Task Message_DeviceSendSingleMessage_Amqp_WithHeartbeats()
8787 await SendSingleMessage ( TestDeviceType . Sasl , transportSettings ) . ConfigureAwait ( false ) ;
8888 }
8989
90- [ TestMethodWithRetry ( Max = 3 ) ]
90+ [ TestMethodWithRetry ( Max = 3 ) ]
9191 [ Timeout ( TestTimeoutMilliseconds ) ]
9292 public async Task Message_DeviceSendSingleMessage_AmqpWs_WithHeartbeats ( )
9393 {
@@ -100,10 +100,11 @@ public async Task Message_DeviceSendSingleMessage_AmqpWs_WithHeartbeats()
100100 await SendSingleMessage ( TestDeviceType . Sasl , transportSettings ) . ConfigureAwait ( false ) ;
101101 }
102102
103- [ TestMethodWithRetry ( Max = 3 ) ]
103+ [ TestMethodWithRetry ( Max = 3 ) ]
104104 [ Timeout ( TestTimeoutMilliseconds ) ]
105105 [ TestCategory ( "Proxy" ) ]
106106 [ TestCategory ( "LongRunning" ) ]
107+ [ Ignore ( "Azure DevOps Windows test environment doesn't support proxies currently" ) ]
107108 public async Task Message_DeviceSendSingleMessage_Http_WithProxy ( )
108109 {
109110 var httpTransportSettings = new Http1TransportSettings
@@ -115,9 +116,10 @@ public async Task Message_DeviceSendSingleMessage_Http_WithProxy()
115116 await SendSingleMessage ( TestDeviceType . Sasl , transportSettings ) . ConfigureAwait ( false ) ;
116117 }
117118
118- [ TestMethodWithRetry ( Max = 3 ) ]
119+ [ TestMethodWithRetry ( Max = 3 ) ]
119120 [ Timeout ( TestTimeoutMilliseconds ) ]
120121 [ TestCategory ( "Proxy" ) ]
122+ [ Ignore ( "Azure DevOps Windows test environment doesn't support proxies currently" ) ]
121123 public async Task Message_DeviceSendSingleMessage_Http_WithCustomProxy ( )
122124 {
123125 var httpTransportSettings = new Http1TransportSettings ( ) ;
@@ -129,10 +131,11 @@ public async Task Message_DeviceSendSingleMessage_Http_WithCustomProxy()
129131 Assert . AreNotEqual ( proxy . Counter , 0 ) ;
130132 }
131133
132- [ TestMethodWithRetry ( Max = 3 ) ]
134+ [ TestMethodWithRetry ( Max = 3 ) ]
133135 [ Timeout ( TestTimeoutMilliseconds ) ]
134136 [ TestCategory ( "Proxy" ) ]
135137 [ TestCategory ( "LongRunning" ) ]
138+ [ Ignore ( "Azure DevOps Windows test environment doesn't support proxies currently" ) ]
136139 public async Task Message_DeviceSendSingleMessage_AmqpWs_WithProxy ( )
137140 {
138141 var amqpTransportSettings = new AmqpTransportSettings ( Client . TransportType . Amqp_WebSocket_Only )
@@ -144,9 +147,10 @@ public async Task Message_DeviceSendSingleMessage_AmqpWs_WithProxy()
144147 await SendSingleMessage ( TestDeviceType . Sasl , transportSettings ) . ConfigureAwait ( false ) ;
145148 }
146149
147- [ TestMethodWithRetry ( Max = 3 ) ]
150+ [ TestMethodWithRetry ( Max = 3 ) ]
148151 [ Timeout ( TestTimeoutMilliseconds ) ]
149152 [ TestCategory ( "Proxy" ) ]
153+ [ Ignore ( "Azure DevOps Windows test environment doesn't support proxies currently" ) ]
150154 public async Task Message_DeviceSendSingleMessage_MqttWs_WithProxy ( )
151155 {
152156 var mqttTransportSettings = new MqttTransportSettings ( Client . TransportType . Mqtt_WebSocket_Only )
@@ -158,9 +162,10 @@ public async Task Message_DeviceSendSingleMessage_MqttWs_WithProxy()
158162 await SendSingleMessage ( TestDeviceType . Sasl , transportSettings ) . ConfigureAwait ( false ) ;
159163 }
160164
161- [ TestMethodWithRetry ( Max = 3 ) ]
165+ [ TestMethodWithRetry ( Max = 3 ) ]
162166 [ Timeout ( TestTimeoutMilliseconds ) ]
163167 [ TestCategory ( "Proxy" ) ]
168+ [ Ignore ( "Azure DevOps Windows test environment doesn't support proxies currently" ) ]
164169 public async Task Message_ModuleSendSingleMessage_AmqpWs_WithProxy ( )
165170 {
166171 var amqpTransportSettings = new AmqpTransportSettings ( Client . TransportType . Amqp_WebSocket_Only )
@@ -172,9 +177,10 @@ public async Task Message_ModuleSendSingleMessage_AmqpWs_WithProxy()
172177 await SendSingleMessageModule ( transportSettings ) . ConfigureAwait ( false ) ;
173178 }
174179
175- [ TestMethodWithRetry ( Max = 3 ) ]
180+ [ TestMethodWithRetry ( Max = 3 ) ]
176181 [ Timeout ( TestTimeoutMilliseconds ) ]
177182 [ TestCategory ( "Proxy" ) ]
183+ [ Ignore ( "Azure DevOps Windows test environment doesn't support proxies currently" ) ]
178184 public async Task Message_ModuleSendSingleMessage_MqttWs_WithProxy ( )
179185 {
180186 var mqttTransportSettings = new MqttTransportSettings ( Client . TransportType . Mqtt_WebSocket_Only )
@@ -186,7 +192,7 @@ public async Task Message_ModuleSendSingleMessage_MqttWs_WithProxy()
186192 await SendSingleMessageModule ( transportSettings ) . ConfigureAwait ( false ) ;
187193 }
188194
189- [ TestMethodWithRetry ( Max = 3 ) ]
195+ [ TestMethodWithRetry ( Max = 3 ) ]
190196 [ Timeout ( TestTimeoutMilliseconds ) ]
191197 public async Task Message_ModuleSendsMessageToRouteTwice ( )
192198 {
@@ -213,72 +219,72 @@ public async Task Message_ModuleSendsMessageToRouteTwice()
213219 }
214220 }
215221
216- [ TestMethodWithRetry ( Max = 3 ) ]
222+ [ TestMethodWithRetry ( Max = 3 ) ]
217223 [ Timeout ( TestTimeoutMilliseconds ) ]
218224 public async Task X509_DeviceSendSingleMessage_Amqp ( )
219225 {
220226 await SendSingleMessage ( TestDeviceType . X509 , Client . TransportType . Amqp_Tcp_Only ) . ConfigureAwait ( false ) ;
221227 }
222228
223- [ TestMethodWithRetry ( Max = 3 ) ]
229+ [ TestMethodWithRetry ( Max = 3 ) ]
224230 [ Timeout ( TestTimeoutMilliseconds ) ]
225231 public async Task X509_DeviceSendSingleMessage_AmqpWs ( )
226232 {
227233 await SendSingleMessage ( TestDeviceType . X509 , Client . TransportType . Amqp_WebSocket_Only ) . ConfigureAwait ( false ) ;
228234 }
229235
230- [ TestMethodWithRetry ( Max = 3 ) ]
236+ [ TestMethodWithRetry ( Max = 3 ) ]
231237 [ Timeout ( TestTimeoutMilliseconds ) ]
232238 [ TestCategory ( "LongRunning" ) ]
233239 public async Task X509_DeviceSendSingleMessage_Mqtt ( )
234240 {
235241 await SendSingleMessage ( TestDeviceType . X509 , Client . TransportType . Mqtt_Tcp_Only ) . ConfigureAwait ( false ) ;
236242 }
237243
238- [ TestMethodWithRetry ( Max = 3 ) ]
244+ [ TestMethodWithRetry ( Max = 3 ) ]
239245 [ Timeout ( TestTimeoutMilliseconds ) ]
240246 public async Task X509_DeviceSendSingleMessage_MqttWs ( )
241247 {
242248 await SendSingleMessage ( TestDeviceType . X509 , Client . TransportType . Mqtt_WebSocket_Only ) . ConfigureAwait ( false ) ;
243249 }
244250
245- [ TestMethodWithRetry ( Max = 3 ) ]
251+ [ TestMethodWithRetry ( Max = 3 ) ]
246252 [ Timeout ( TestTimeoutMilliseconds ) ]
247253 public async Task X509_DeviceSendSingleMessage_Http ( )
248254 {
249255 await SendSingleMessage ( TestDeviceType . X509 , Client . TransportType . Http1 ) . ConfigureAwait ( false ) ;
250256 }
251257
252- [ TestMethodWithRetry ( Max = 3 ) ]
258+ [ TestMethodWithRetry ( Max = 3 ) ]
253259 [ Timeout ( TestTimeoutMilliseconds ) ]
254260 public async Task X509_DeviceSendBatchMessages_Amqp ( )
255261 {
256262 await SendBatchMessages ( TestDeviceType . X509 , Client . TransportType . Amqp_Tcp_Only ) . ConfigureAwait ( false ) ;
257263 }
258264
259- [ TestMethodWithRetry ( Max = 3 ) ]
265+ [ TestMethodWithRetry ( Max = 3 ) ]
260266 [ Timeout ( TestTimeoutMilliseconds ) ]
261267 public async Task X509_DeviceSendBatchMessages_AmqpWs ( )
262268 {
263269 await SendBatchMessages ( TestDeviceType . X509 , Client . TransportType . Amqp_WebSocket_Only ) . ConfigureAwait ( false ) ;
264270 }
265271
266- [ TestMethodWithRetry ( Max = 3 ) ]
272+ [ TestMethodWithRetry ( Max = 3 ) ]
267273 [ Timeout ( TestTimeoutMilliseconds ) ]
268274 [ TestCategory ( "LongRunning" ) ]
269275 public async Task X509_DeviceSendBatchMessages_Mqtt ( )
270276 {
271277 await SendBatchMessages ( TestDeviceType . X509 , Client . TransportType . Mqtt_Tcp_Only ) . ConfigureAwait ( false ) ;
272278 }
273279
274- [ TestMethodWithRetry ( Max = 3 ) ]
280+ [ TestMethodWithRetry ( Max = 3 ) ]
275281 [ Timeout ( TestTimeoutMilliseconds ) ]
276282 public async Task X509_DeviceSendBatchMessages_MqttWs ( )
277283 {
278284 await SendBatchMessages ( TestDeviceType . X509 , Client . TransportType . Mqtt_WebSocket_Only ) . ConfigureAwait ( false ) ;
279285 }
280286
281- [ TestMethodWithRetry ( Max = 3 ) ]
287+ [ TestMethodWithRetry ( Max = 3 ) ]
282288 [ Timeout ( TestTimeoutMilliseconds ) ]
283289 public async Task X509_DeviceSendBatchMessages_Http ( )
284290 {
@@ -317,9 +323,6 @@ public async Task Message_ClientThrowsForMqttTopicNameTooLong()
317323 [ DataRow ( TestDeviceType . X509 , Client . TransportType . Mqtt_WebSocket_Only , LargeMessageSizeInBytes ) ]
318324 [ DataRow ( TestDeviceType . X509 , Client . TransportType . Amqp_Tcp_Only , LargeMessageSizeInBytes ) ]
319325 [ DataRow ( TestDeviceType . X509 , Client . TransportType . Amqp_WebSocket_Only , LargeMessageSizeInBytes ) ]
320- //[DataRow(TestDeviceType.X509, Client.TransportType.Http1, LargeMessageSizeInBytes)]
321- // this only work when 8kB and less - Known issue for GWv2 (TODO: reenable when this is fixed)
322-
323326 public async Task Message_DeviceSendSingleLargeMessageAsync ( TestDeviceType testDeviceType , Client . TransportType transportType , int messageSize )
324327 {
325328 await SendSingleMessage ( testDeviceType , transportType , messageSize ) . ConfigureAwait ( false ) ;
@@ -421,7 +424,7 @@ public async Task Message_DeviceSendMessageWayOverAllowedSize_Http()
421424 await SendSingleMessage ( TestDeviceType . Sasl , Client . TransportType . Http1 , OverlyExceedAllowedMessageSizeInBytes ) . ConfigureAwait ( false ) ;
422425 }
423426
424- [ TestMethodWithRetry ( Max = 3 ) ]
427+ [ TestMethodWithRetry ( Max = 3 ) ]
425428 [ Timeout ( TestTimeoutMilliseconds ) ]
426429 public async Task Message_DeviceSendSingleWithCustomHttpClient_Http ( )
427430 {
@@ -534,7 +537,7 @@ public static Client.Message ComposeD2cTestMessage(out string payload, out strin
534537 p1Value = Guid . NewGuid ( ) . ToString ( ) ;
535538 string userId = Guid . NewGuid ( ) . ToString ( ) ;
536539
537- VerboseTestLogger . WriteLine ( $ "{ nameof ( ComposeD2cTestMessage ) } : messageId='{ messageId } ' userId='{ userId } ' payload='{ payload . Substring ( 0 , 32 ) } ' p1Value='{ p1Value } '") ;
540+ VerboseTestLogger . WriteLine ( $ "{ nameof ( ComposeD2cTestMessage ) } : messageId='{ messageId } ' userId='{ userId } ' payload='{ payload . Substring ( 0 , 32 ) } ' p1Value='{ p1Value } '") ;
538541 var message = new Client . Message ( Encoding . UTF8 . GetBytes ( payload ) )
539542 {
540543 MessageId = messageId ,
@@ -552,7 +555,7 @@ public static Client.Message ComposeD2cTestMessageOfSpecifiedSize(int messageSiz
552555 payload = $ "{ Guid . NewGuid ( ) } _{ new string ( '*' , messageSize ) } ";
553556 p1Value = Guid . NewGuid ( ) . ToString ( ) ;
554557
555- VerboseTestLogger . WriteLine ( $ "{ nameof ( ComposeD2cTestMessageOfSpecifiedSize ) } : messageId='{ messageId } ' payload='{ payload . Substring ( 0 , 32 ) } ' p1Value='{ p1Value } '") ;
558+ VerboseTestLogger . WriteLine ( $ "{ nameof ( ComposeD2cTestMessageOfSpecifiedSize ) } : messageId='{ messageId } ' payload='{ payload . Substring ( 0 , 32 ) } ' p1Value='{ p1Value } '") ;
556559 var message = new Client . Message ( Encoding . UTF8 . GetBytes ( payload ) )
557560 {
558561 MessageId = messageId ,
0 commit comments