|
@@ -73,7 +73,7 @@ namespace TEAMModelFunction
|
|
{
|
|
{
|
|
case "pending":
|
|
case "pending":
|
|
var message = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
var message = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
- message.Properties.Add("name", "Exam");
|
|
|
|
|
|
+ message.ApplicationProperties.Add("name", "Exam");
|
|
if (records.Count > 0)
|
|
if (records.Count > 0)
|
|
{
|
|
{
|
|
await _serviceBus.GetServiceBusClient().cancelMessage("active-task", records[0].sequenceNumber);
|
|
await _serviceBus.GetServiceBusClient().cancelMessage("active-task", records[0].sequenceNumber);
|
|
@@ -140,7 +140,7 @@ namespace TEAMModelFunction
|
|
}
|
|
}
|
|
}
|
|
}
|
|
var messageEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
var messageEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
- messageEnd.Properties.Add("name", "Exam");
|
|
|
|
|
|
+ messageEnd.ApplicationProperties.Add("name", "Exam");
|
|
if (records.Count > 0)
|
|
if (records.Count > 0)
|
|
{
|
|
{
|
|
long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
@@ -237,7 +237,7 @@ namespace TEAMModelFunction
|
|
{
|
|
{
|
|
case "pending":
|
|
case "pending":
|
|
var messageVote = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
var messageVote = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
- messageVote.Properties.Add("name", "Vote");
|
|
|
|
|
|
+ messageVote.ApplicationProperties.Add("name", "Vote");
|
|
if (voteRecords.Count > 0)
|
|
if (voteRecords.Count > 0)
|
|
{
|
|
{
|
|
long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVote, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
long start = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVote, DateTimeOffset.FromUnixTimeMilliseconds(stime));
|
|
@@ -262,7 +262,7 @@ namespace TEAMModelFunction
|
|
break;
|
|
break;
|
|
case "going":
|
|
case "going":
|
|
var messageVoteEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
var messageVoteEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
- messageVoteEnd.Properties.Add("name", "Vote");
|
|
|
|
|
|
+ messageVoteEnd.ApplicationProperties.Add("name", "Vote");
|
|
if (voteRecords.Count > 0)
|
|
if (voteRecords.Count > 0)
|
|
{
|
|
{
|
|
long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageVoteEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
@@ -297,7 +297,7 @@ namespace TEAMModelFunction
|
|
{
|
|
{
|
|
case "pending":
|
|
case "pending":
|
|
var messageSurvey = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
var messageSurvey = new ServiceBusMessage(new { id = input.Id, progress = "going", code = code }.ToJsonString());
|
|
- messageSurvey.Properties.Add("name", "Survey");
|
|
|
|
|
|
+ messageSurvey.ApplicationProperties.Add("name", "Survey");
|
|
if (changeRecords.Count > 0)
|
|
if (changeRecords.Count > 0)
|
|
{
|
|
{
|
|
await _serviceBus.GetServiceBusClient().cancelMessage("active-task", changeRecords[0].sequenceNumber);
|
|
await _serviceBus.GetServiceBusClient().cancelMessage("active-task", changeRecords[0].sequenceNumber);
|
|
@@ -322,7 +322,7 @@ namespace TEAMModelFunction
|
|
break;
|
|
break;
|
|
case "going":
|
|
case "going":
|
|
var messageSurveyEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
var messageSurveyEnd = new ServiceBusMessage(new { id = input.Id, progress = "finish", code = code }.ToJsonString());
|
|
- messageSurveyEnd.Properties.Add("name", "Survey");
|
|
|
|
|
|
+ messageSurveyEnd.ApplicationProperties.Add("name", "Survey");
|
|
if (changeRecords.Count > 0)
|
|
if (changeRecords.Count > 0)
|
|
{
|
|
{
|
|
long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|
|
long end = await _serviceBus.GetServiceBusClient().SendScheduleMessageAsync("active-task", messageSurveyEnd, DateTimeOffset.FromUnixTimeMilliseconds(etime));
|