| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public async Task<string> MESForBasketAsync(string ztype, string zlsn, string zlpn, string zstatus, string zversion, int timeoutMs = 30000) |
|---|
| | | public async Task<string> MESForBasketAsync(string ztype, string zlsn, string zlpn, string zstatus, string zversion, int timeoutMes = 30000) |
|---|
| | | { |
|---|
| | | var guid = Guid.NewGuid().ToString(); |
|---|
| | | var tcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); |
|---|
| | |
|---|
| | | CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Information, $"RabbitMQ 篮具 发送1：{message}"); |
|---|
| | | _sendChannel.BasicPublish("", "auto_line_mac_queue", null, body); |
|---|
| | | |
|---|
| | | var completed = await Task.WhenAny(tcs.Task, Task.Delay(timeoutMs)); |
|---|
| | | var completed = await Task.WhenAny(tcs.Task, Task.Delay(timeoutMes)); |
|---|
| | | _pendingTask1.TryRemove(guid, out _); |
|---|
| | | if (completed == tcs.Task) |
|---|
| | | return await tcs.Task; |
|---|
