Публикация тем задерживается. Первоначально публикация тем в OPENDDS занимает 5 секунд. ⇐ C++
-
Гость
Публикация тем задерживается. Первоначально публикация тем в OPENDDS занимает 5 секунд.
При создании службы в opendds наблюдается задержка. Первоначально публикуются данные. т. е. если предусмотрена задержка, ServiceObj легко публикует данные, а подписчик подписывается на них, но если задержки нет, мы не можем публиковать данные.
Пожалуйста, предложите, что можно сделать.
**Код издателя**
`private static readonly IOpenDDSharpService _publisherObj = OpenDDSharpServiceFactory.Instance.CreateService(); _publisherObj.Publish (новый LogMessageStruct() { Тип = LogMessageType.LoggingRequest, Буфер = JsonSerializer.SerializeToUtf8Bytes("SampleData") }); ` Код подписчика
частный статический только для чтения IOpenDDSharpService _subscriberObj = OpenDDSharpServiceFactory.Instance.CreateService(); _subscriberObj .Subscribe(пункт => UpdateItem(пункт)); Private static void UpdateItem (элемент LogMessageStruct) { var s = JsonSerializer.Deserialize(item.Buffer.ToString()); } Код задержки
DateTime _desired = DateTime.Now.AddSeconds(5); в то время как (DateTime.Now
При создании службы в opendds наблюдается задержка. Первоначально публикуются данные. т. е. если предусмотрена задержка, ServiceObj легко публикует данные, а подписчик подписывается на них, но если задержки нет, мы не можем публиковать данные.
Пожалуйста, предложите, что можно сделать.
**Код издателя**
`private static readonly IOpenDDSharpService _publisherObj = OpenDDSharpServiceFactory.Instance.CreateService(); _publisherObj.Publish (новый LogMessageStruct() { Тип = LogMessageType.LoggingRequest, Буфер = JsonSerializer.SerializeToUtf8Bytes("SampleData") }); ` Код подписчика
частный статический только для чтения IOpenDDSharpService _subscriberObj = OpenDDSharpServiceFactory.Instance.CreateService(); _subscriberObj .Subscribe(пункт => UpdateItem(пункт)); Private static void UpdateItem (элемент LogMessageStruct) { var s = JsonSerializer.Deserialize(item.Buffer.ToString()); } Код задержки
DateTime _desired = DateTime.Now.AddSeconds(5); в то время как (DateTime.Now
