Skip to content

Commit 206a712

Browse files
committed
fix #223
1 parent c5030e7 commit 206a712

File tree

3 files changed

+4
-2
lines changed

3 files changed

+4
-2
lines changed

Source/FikaAmazonAPI/Parameter/Notification/ParameterMessageReceiver.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,9 @@ public class ParameterMessageReceiver
77
public string awsAccessKeyId { get; set; }
88
public string awsSecretAccessKey { get; set; }
99
public string SQS_URL { get; set; }
10+
public int? WaitTimeSeconds { get; set; }
1011
public RegionEndpoint RegionEndpoint { get; set; }
11-
public ParameterMessageReceiver(string awsAccessKeyId, string awsSecretAccessKey,string SQS_URL, RegionEndpoint RegionEndpoint)
12+
public ParameterMessageReceiver(string awsAccessKeyId, string awsSecretAccessKey, string SQS_URL, RegionEndpoint RegionEndpoint)
1213
{
1314
this.awsAccessKeyId = awsAccessKeyId;
1415
this.awsSecretAccessKey = awsSecretAccessKey;

Source/FikaAmazonAPI/Services/NotificationService.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,8 @@ public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiv
127127
{
128128
ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(SQS_URL);
129129
receiveMessageRequest.MaxNumberOfMessages = 10;
130+
if (param.WaitTimeSeconds.HasValue)
131+
receiveMessageRequest.WaitTimeSeconds = param.WaitTimeSeconds.Value;
130132

131133
while (true)
132134
{

Source/FikaAmazonAPI/Services/RequestService.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,6 @@ protected void AddLimitHeader(int limit)
254254
}
255255
protected void AddJsonBody(object jsonData)
256256
{
257-
//Request.JsonSerializer = new JsonNetSerializer();
258257
var json = JsonConvert.SerializeObject(jsonData);
259258
Request.AddJsonBody(json);
260259
}

0 commit comments

Comments
 (0)