ensuring backwards compatibility

Author: thefringeninja

src/EventStore.Client.Common/protos/persistentsubscriptions.proto

@@ -98,16 +98,22 @@ message CreateReq {
 		bool resolve_links = 1;
 		uint64 revision = 2;
 		bool extra_statistics = 3;
-		int64 message_timeout = 4;
 		int32 max_retry_count = 5;
-		int64 checkpoint_after = 6;
 		int32 min_checkpoint_count = 7;
 		int32 max_checkpoint_count = 8;
 		int32 max_subscriber_count = 9;
 		int32 live_buffer_size = 10;
 		int32 read_batch_size = 11;
 		int32 history_buffer_size = 12;
 		ConsumerStrategy named_consumer_strategy = 13;
+		oneof message_timeout {
+			int64 message_timeout_ticks = 4;
+			int32 message_timeout_ms = 14;
+		}
+		oneof checkpoint_after {
+			int64 checkpoint_after_ticks = 6;
+			int32 checkpoint_after_ms = 15;
+		}
 	}
 
 	enum ConsumerStrategy {
@@ -133,16 +139,22 @@ message UpdateReq {
 		bool resolve_links = 1;
 		uint64 revision = 2;
 		bool extra_statistics = 3;
-		int64 message_timeout = 4;
 		int32 max_retry_count = 5;
-		int64 checkpoint_after = 6;
 		int32 min_checkpoint_count = 7;
 		int32 max_checkpoint_count = 8;
 		int32 max_subscriber_count = 9;
 		int32 live_buffer_size = 10;
 		int32 read_batch_size = 11;
 		int32 history_buffer_size = 12;
 		ConsumerStrategy named_consumer_strategy = 13;
+		oneof message_timeout {
+			int64 message_timeout_ticks = 4;
+			int32 message_timeout_ms = 14;
+		}
+		oneof checkpoint_after {
+			int64 checkpoint_after_ticks = 6;
+			int32 checkpoint_after_ms = 15;
+		}
 	}
 
 	enum ConsumerStrategy {

src/EventStore.Client.PersistentSubscriptions/EventStorePersistentSubscriptionsClient.Create.cs

@@ -45,9 +45,9 @@ await _client.CreateAsync(new CreateReq {
 					GroupName = groupName,
 					Settings = new CreateReq.Types.Settings {
 						Revision = settings.StartFrom,
-						CheckpointAfter = (int)settings.CheckPointAfter.TotalMilliseconds,
+						CheckpointAfterMs = (int)settings.CheckPointAfter.TotalMilliseconds,
 						ExtraStatistics = settings.ExtraStatistics,
-						MessageTimeout = (int)settings.MessageTimeout.TotalMilliseconds,
+						MessageTimeoutMs = (int)settings.MessageTimeout.TotalMilliseconds,
 						ResolveLinks = settings.ResolveLinkTos,
 						HistoryBufferSize = settings.HistoryBufferSize,
 						LiveBufferSize = settings.LiveBufferSize,

src/EventStore.Client.PersistentSubscriptions/EventStorePersistentSubscriptionsClient.Update.cs

@@ -45,9 +45,9 @@ await _client.UpdateAsync(new UpdateReq {
 					GroupName = groupName,
 					Settings = new UpdateReq.Types.Settings {
 						Revision = settings.StartFrom,
-						CheckpointAfter = (int)settings.CheckPointAfter.TotalMilliseconds,
+						CheckpointAfterMs = (int)settings.CheckPointAfter.TotalMilliseconds,
 						ExtraStatistics = settings.ExtraStatistics,
-						MessageTimeout = (int)settings.MessageTimeout.TotalMilliseconds,
+						MessageTimeoutMs = (int)settings.MessageTimeout.TotalMilliseconds,
 						ResolveLinks = settings.ResolveLinkTos,
 						HistoryBufferSize = settings.HistoryBufferSize,
 						LiveBufferSize = settings.LiveBufferSize,