GitHub-Mirror/Tapeti
1
0
Fork 0
mirror of synced 2024-11-22 01:13:49 +00:00
Code Issues Projects Releases Wiki Activity

Fixed NotImplementedException for Tapeti.Cmd Example command

Browse Source
This commit is contained in:
Mark van Renswoude 2021-08-30 14:43:28 +02:00
parent 2eb66c5780
commit aded39981c
1 changed files with 67 additions and 70 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

137
Tapeti.Cmd/Mock/MockBasicProperties.cs
View File

@ -79,91 +79,88 @@ namespace Tapeti.Cmd.Mock
throw new NotImplementedException(); throw new NotImplementedException();
} }
public bool IsAppIdPresent() public bool IsAppIdPresent() => appIdPresent;
{ public bool IsClusterIdPresent() => clusterIdPresent;
throw new NotImplementedException(); public bool IsContentEncodingPresent() => contentEncodingPresent;
} public bool IsContentTypePresent() => contentTypePresent;
public bool IsCorrelationIdPresent() => correlationIdPresent;
public bool IsDeliveryModePresent() => deliveryModePresent;
public bool IsExpirationPresent() => expirationPresent;
public bool IsHeadersPresent() => headersPresent;
public bool IsMessageIdPresent() => messageIdPresent;
public bool IsPriorityPresent() => priorityPresent;
public bool IsReplyToPresent() => replyToPresent;
public bool IsTimestampPresent() => timestampPresent;
public bool IsTypePresent() => typePresent;
public bool IsUserIdPresent() => userIdPresent;
public bool IsClusterIdPresent() private bool appIdPresent;
{ private string appId;
throw new NotImplementedException();
}
public bool IsContentEncodingPresent() private bool clusterIdPresent;
{ private string clusterId;
throw new NotImplementedException();
}
public bool IsContentTypePresent() private bool contentEncodingPresent;
{ private string contentEncoding;
throw new NotImplementedException();
}
public bool IsCorrelationIdPresent() private bool contentTypePresent;
{ private string contentType;
throw new NotImplementedException();
}
public bool IsDeliveryModePresent() private bool correlationIdPresent;
{ private string correlationId;
throw new NotImplementedException();
}
public bool IsExpirationPresent() private bool deliveryModePresent;
{ private byte deliveryMode;
throw new NotImplementedException();
}
public bool IsHeadersPresent() private bool expirationPresent;
{ private string expiration;
throw new NotImplementedException();
}
public bool IsMessageIdPresent() private bool headersPresent;
{ private IDictionary<string, object> headers;
throw new NotImplementedException();
} private bool messageIdPresent;
private string messageId;
public bool IsPriorityPresent() private bool priorityPresent;
{ private byte priority;
throw new NotImplementedException();
}
public bool IsReplyToPresent() private bool replyToPresent;
{ private string replyTo;
throw new NotImplementedException();
}
public bool IsTimestampPresent() private bool timestampPresent;
{ private AmqpTimestamp timestamp;
throw new NotImplementedException();
}
public bool IsTypePresent() private bool typePresent;
{ private string type;
throw new NotImplementedException();
}
public bool IsUserIdPresent() private bool userIdPresent;
{ private string userId;
throw new NotImplementedException();
}
public string AppId { get; set; }
public string ClusterId { get; set; }
public string ContentEncoding { get; set; } public string AppId { get => appId; set => SetValue(out appId, out appIdPresent, value); }
public string ContentType { get; set; } public string ClusterId { get => clusterId; set => SetValue(out clusterId, out clusterIdPresent, value); }
public string CorrelationId { get; set; } public string ContentEncoding { get => contentEncoding; set => SetValue(out contentEncoding, out contentEncodingPresent, value); }
public byte DeliveryMode { get; set; } public string ContentType { get => contentType; set => SetValue(out contentType, out contentTypePresent, value); }
public string Expiration { get; set; } public string CorrelationId { get => correlationId; set => SetValue(out correlationId, out correlationIdPresent, value); }
public IDictionary<string, object> Headers { get; set; } public byte DeliveryMode { get => deliveryMode; set => SetValue(out deliveryMode, out deliveryModePresent, value); }
public string MessageId { get; set; } public string Expiration { get => expiration; set => SetValue(out expiration, out expirationPresent, value); }
public IDictionary<string, object> Headers { get => headers; set => SetValue(out headers, out headersPresent, value); }
public string MessageId { get => messageId; set => SetValue(out messageId, out messageIdPresent, value); }
public bool Persistent { get; set; } public bool Persistent { get; set; }
public byte Priority { get; set; } public byte Priority { get => priority; set => SetValue(out priority, out priorityPresent, value); }
public string ReplyTo { get; set; } public string ReplyTo { get => replyTo; set => SetValue(out replyTo, out replyToPresent, value); }
public PublicationAddress ReplyToAddress { get; set; } public PublicationAddress ReplyToAddress { get; set; }
public AmqpTimestamp Timestamp { get; set; } public AmqpTimestamp Timestamp { get => timestamp; set => SetValue(out timestamp, out timestampPresent, value); }
public string Type { get; set; } public string Type { get => type; set => SetValue(out type, out typePresent, value); }
public string UserId { get; set; } public string UserId { get => userId; set => SetValue(out userId, out userIdPresent, value); }
private static void SetValue<T>(out T field, out bool present, T value)
{
field = value;
present = true;
}
} }
} }