Comments (4)
No. 1-4
ben
ben
        private void HandleSingleTempestEvent(Amazon.SQS.Model.Message message)
        {
            TempestStoryEvent tempestStoryEvent = JsonConvert
                .DeserializeObject<TempestStoryEvent>(message.Body);
            log.Debug("Received sqs message: " + message.Body);
            SystemLog.Info("received sqs", "receive-sqs", null, "tempestevent", message.Body);
            //TODO: handle unpublish messages when we support Tempest Read API
            if (tempestStoryEvent.Action == TempestStoryAction.Publish) {
                // just checking it can generate the Uri ok.  This validates the Path, and
                // tries to form a Uri from it, so if we get past this, we're in pretty good
                // shape.
                var unused = tempestStoryEvent.ApiUrl;
                Bake(tempestStoryEvent);
            }
            log.Debug("deleting message");
            SystemLog.Info("deleting sqs message", "delete-sqs", null, "tempestevent", message.Body);
            amazonSqsClient.DeleteMessage(QueueUrl, message.ReceiptHandle);
        }
Brian
Brian

Editor

Brian
Brian

Editor

@Brian hello

Brian
Brian

Editor

reply