File tree Expand file tree Collapse file tree 1 file changed +14
-17
lines changed Expand file tree Collapse file tree 1 file changed +14
-17
lines changed Original file line number Diff line number Diff line change 3
3
using Azure . Storage . Queues . Models ;
4
4
using NServiceBus . Pipeline ;
5
5
6
- namespace ASQN_13
6
+ public class AccessToNativeMessage
7
7
{
8
- public class AccessToNativeMessage
9
- {
10
- #region access-native-incoming-message
8
+ #region access-native-incoming-message
11
9
12
- class DoNotAttemptMessageProcessingIfMessageIsNotLocked : Behavior < ITransportReceiveContext >
10
+ class DoNotAttemptMessageProcessingIfMessageIsNotLocked : Behavior < ITransportReceiveContext >
11
+ {
12
+ public override Task Invoke ( ITransportReceiveContext context , Func < Task > next )
13
13
{
14
- public override Task Invoke ( ITransportReceiveContext context , Func < Task > next )
15
- {
16
- var NextVisibleOnUtc = context . Extensions . Get < QueueMessage > ( ) . NextVisibleOn ;
17
-
18
- if ( NextVisibleOnUtc <= DateTime . UtcNow )
19
- {
20
- return next ( ) ;
21
- }
14
+ var NextVisibleOnUtc = context . Extensions . Get < QueueMessage > ( ) . NextVisibleOn ;
22
15
23
- throw new Exception ( $ "Message lock lost for MessageId { context . Message . MessageId } and it cannot be processed.") ;
16
+ if ( NextVisibleOnUtc <= DateTime . UtcNow )
17
+ {
18
+ return next ( ) ;
24
19
}
25
- }
26
20
27
- #endregion
21
+ throw new Exception ( $ "Message lock lost for MessageId { context . Message . MessageId } and it cannot be processed.") ;
22
+ }
28
23
}
29
- }
24
+
25
+ #endregion
26
+ }
You can’t perform that action at this time.
0 commit comments