public virtual IFixSession CreateFixSession()

in FixAntenna/NetCore/FixEngine/FixSessionBuilder.cs [46:128]
74 lines of code
10 McCabe index (conditional complexity)

		public virtual IFixSession CreateFixSession(string sessionPropertiesId, Properties fixJmsProp)
		{
			var details = new SessionParameters();
			var fixVersionPValue = fixJmsProp.GetNotEmptyProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionFixVersionSuffix);
			var fixVersionUtils = new FixVersionUtils(fixVersionPValue);
			var fixtVer = fixVersionUtils.GetFixtVersion();
			if (fixtVer != null)
			{
				details.FixVersion = fixtVer;
				details.AppVersion = fixVersionUtils.GetFixVersion();
			}
			else
			{
				details.FixVersion = fixVersionUtils.GetFixVersion();
			}
			details.Host = fixJmsProp.GetNotEmptyProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionHostSuffix);
			details.Port = fixJmsProp.GetNotEmptyIntegerProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionPortSuffix);
			details.SenderCompId = fixJmsProp.GetNotEmptyProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionSenderCompIdSuffix);
			details.TargetCompId = fixJmsProp.GetNotEmptyProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionTargetCompIdSuffix);
			// sub id
			details.SenderSubId = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionSenderSubIdSuffix);
			details.TargetSubId = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionTargetSubIdSuffix);
			// location id
			details.SenderLocationId = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionSenderLocationIdSuffix);
			details.TargetLocationId = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionTargetLocationIdSuffix);

			// incoming and outgoing sequence number
			var inSeq = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionIncomingSequenceNumberSuffix);
			var outSeq = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionOutgoingSequenceNumberSuffix);
			if (!string.IsNullOrWhiteSpace(inSeq))
			{
				try
				{
					details.IncomingSequenceNumber = int.Parse(inSeq);
				}
				catch (Exception e)
				{
					throw new System.ArgumentException("invalid value: " + inSeq + ", for: " + FixSessionPrefix + "." + sessionPropertiesId + FixSessionIncomingSequenceNumberSuffix, e);
				}
			}
			if (!string.IsNullOrWhiteSpace(outSeq))
			{
				try
				{
					details.OutgoingSequenceNumber = int.Parse(outSeq);
				}
				catch (Exception e)
				{
					throw new System.ArgumentException("invalid value: " + outSeq + ", for: " + FixSessionPrefix + "." + sessionPropertiesId + FixSessionOutgoingSequenceNumberSuffix, e);
				}
			}

			// heartbeat interval
			var interval = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionHeartbeatIntervalSuffix);
			if (!string.IsNullOrWhiteSpace(interval))
			{
				try
				{
					details.HeartbeatInterval = int.Parse(interval);
				}
				catch (Exception e)
				{
					throw new System.ArgumentException("invalid value: " + interval + ", for: " + FixSessionPrefix + "." + sessionPropertiesId + FixSessionHeartbeatIntervalSuffix, e);
				}
			}

			//additional outgoing login fields
			var outgoingFields = fixJmsProp.GetProperty(FixSessionPrefix + "." + sessionPropertiesId + FixSessionOutgoingLoginFieldsSuffix);
			if (!string.IsNullOrWhiteSpace(outgoingFields))
			{
				try
				{
					var outMessage = RawFixUtil.GetFixMessage(outgoingFields.AsByteArray());
					details.OutgoingLoginMessage = outMessage;
				}
				catch (Exception e)
				{
					throw new System.ArgumentException("invalid value: " + outgoingFields + ", for: " + FixSessionPrefix + "." + sessionPropertiesId + FixSessionOutgoingLoginFieldsSuffix, e);
				}
			}

			return details.CreateNewFixSession();
		}