using System;
using System.Threading;
{
class Retransmit
{
public static void Main()
{
ConfigurationHelper.Initialize();
SampleRetransmitClient retransmitClient = new SampleRetransmitClient("RETRANSMIT-PUSH-CLIENT");
retransmitClient.Start();
RetransmitStore retransmitStore = ConfigurationHelper.CreateRetransmitStore(retransmitClient);
RetransmitRequestMessage requestMessage = new RetransmitRequestMessage();
RequestHeaderMessage requestHeaderBuilder = new RequestHeaderMessage();
requestHeaderBuilder.appId = "DMC";
requestHeaderBuilder.sourceTarget = SourceTargetType.SOURCE_TARGET_DMC;
requestHeaderBuilder.user = ConfigurationHelper.Configuration.UserId;
requestHeaderBuilder.password = ConfigurationHelper.Configuration.Password;
requestMessage.maxBytesPerSecond = 0;
requestMessage.requestID = 3;
RetransmitRequestEntryMessage entry = new RetransmitRequestEntryMessage();
DateTime start = DateTime.Now.AddHours(-4);
DateTime end = DateTime.Now;
long startUtc = new DateTimeOffset(start).ToUniversalTime().ToUnixTimeMilliseconds();
long endUtc = new DateTimeOffset(end).ToUniversalTime().ToUnixTimeMilliseconds();
entry.UTCStart = startUtc;
entry.UTCEnd = endUtc;
Console.WriteLine("Start: " + start.ToLongTimeString());
Console.WriteLine("End : " + end.ToLongTimeString());
entry.Symbols.Add("846900.ETR");
entry.Symbols.Add("555750.ETR");
entry.Exchanges.Add("EUWAX");
entry.Exchanges.Add("FFMST");
entry.Exchanges.Add("FXVWD");
requestMessage.requestEntryList.Add(entry);
requestMessage.header = requestHeaderBuilder;
retransmitStore.RequestRetransmit(requestMessage);
try
{
Thread.Sleep(30 * 1000);
}
catch (Exception) { }
retransmitStore.Stop();
retransmitClient.Stop();
}
}
}