|
@@ -119,8 +119,8 @@ SELECT |
|
|
{ |
|
|
{ |
|
|
Id = reader.GetInt64(index++), |
|
|
Id = reader.GetInt64(index++), |
|
|
Version = reader.GetString(index++), |
|
|
Version = reader.GetString(index++), |
|
|
Group = queryDto.MessageType == MessageType.Subscribe ? reader.GetString(index++) : default, |
|
|
|
|
|
Name = reader.GetString(index++), |
|
|
Name = reader.GetString(index++), |
|
|
|
|
|
Group = queryDto.MessageType == MessageType.Subscribe ? reader.GetString(index++) : default, |
|
|
Content = reader.GetString(index++), |
|
|
Content = reader.GetString(index++), |
|
|
Retries = reader.GetInt32(index++), |
|
|
Retries = reader.GetInt32(index++), |
|
|
Added = reader.GetDateTime(index++), |
|
|
Added = reader.GetDateTime(index++), |
|
@@ -271,4 +271,4 @@ select [Key], [Count] from aggr with (nolock) where [Key] >= @minKey and [Key] < |
|
|
return await Task.FromResult(mediumMessage); |
|
|
return await Task.FromResult(mediumMessage); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
} |