Skip to content

Commit

Permalink
Rename DefaultCompressionOptions
Browse files Browse the repository at this point in the history
  • Loading branch information
slang25 committed Jul 8, 2024
1 parent ce4b6d4 commit b3e5222
Show file tree
Hide file tree
Showing 9 changed files with 19 additions and 19 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ public static StaticPublicationConfiguration Build<T>(
{
MessageResponseLogger = bus.Config.MessageResponseLogger,
CompressionRegistry = bus.CompressionRegistry,
CompressionOptions = writeConfiguration.CompressionOptions ?? bus.Config.CompressionOptions
CompressionOptions = writeConfiguration.CompressionOptions ?? bus.Config.DefaultCompressionOptions
};

var snsTopic = new SnsTopicByName(
Expand Down
2 changes: 1 addition & 1 deletion src/JustSaying/Fluent/QueueAddressPublicationBuilder`1.cs
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public void Configure(JustSayingBus bus, IAwsClientFactoryProxy proxy, ILoggerFa
{
MessageResponseLogger = config.MessageResponseLogger,
CompressionRegistry = bus.CompressionRegistry,
CompressionOptions = _compressionOptions ?? bus.Config.CompressionOptions
CompressionOptions = _compressionOptions ?? bus.Config.DefaultCompressionOptions
};
CompressionEncodingValidator.ValidateEncoding(bus.CompressionRegistry, eventPublisher.CompressionOptions);

Expand Down
2 changes: 1 addition & 1 deletion src/JustSaying/Fluent/TopicAddressPublicationBuilder`1.cs
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ public void Configure(JustSayingBus bus, IAwsClientFactoryProxy proxy, ILoggerFa
{
MessageResponseLogger = config.MessageResponseLogger,
CompressionRegistry = bus.CompressionRegistry,
CompressionOptions = _compressionOptions ?? bus.Config.CompressionOptions
CompressionOptions = _compressionOptions ?? bus.Config.DefaultCompressionOptions
};
CompressionEncodingValidator.ValidateEncoding(bus.CompressionRegistry, eventPublisher.CompressionOptions);

Expand Down
2 changes: 1 addition & 1 deletion src/JustSaying/Fluent/TopicPublicationBuilder`1.cs
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ void IPublicationBuilder<T>.Configure(

var writeConfiguration = new SnsWriteConfiguration();
ConfigureWrites?.Invoke(writeConfiguration);
writeConfiguration.CompressionOptions ??= bus.Config.CompressionOptions;
writeConfiguration.CompressionOptions ??= bus.Config.DefaultCompressionOptions;
CompressionEncodingValidator.ValidateEncoding(bus.CompressionRegistry, writeConfiguration.CompressionOptions);

var client = proxy.GetAwsClientFactory().GetSnsClient(RegionEndpoint.GetBySystemName(region));
Expand Down
2 changes: 1 addition & 1 deletion src/JustSaying/IMessagingConfig.cs
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,6 @@ public interface IMessagingConfig : IPublishConfiguration
IMessageSubjectProvider MessageSubjectProvider { get; set; }
ITopicNamingConvention TopicNamingConvention { get; set; }
IQueueNamingConvention QueueNamingConvention { get; set; }
PublishCompressionOptions CompressionOptions { get; set; }
PublishCompressionOptions DefaultCompressionOptions { get; set; }
void Validate();
}
4 changes: 2 additions & 2 deletions src/JustSaying/MessagingConfig.cs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ public MessagingConfig()
MessageSubjectProvider = new NonGenericMessageSubjectProvider();
TopicNamingConvention = new DefaultNamingConventions();
QueueNamingConvention = new DefaultNamingConventions();
CompressionOptions = new PublishCompressionOptions();
DefaultCompressionOptions = new PublishCompressionOptions();
}

public int PublishFailureReAttempts { get; set; }
Expand All @@ -27,7 +27,7 @@ public MessagingConfig()
public IMessageSubjectProvider MessageSubjectProvider { get; set; }
public ITopicNamingConvention TopicNamingConvention { get; set; }
public IQueueNamingConvention QueueNamingConvention { get; set; }
public PublishCompressionOptions CompressionOptions { get; set; }
public PublishCompressionOptions DefaultCompressionOptions { get; set; }

public virtual void Validate()
{
Expand Down
8 changes: 4 additions & 4 deletions src/JustSaying/PublicAPI/net461/PublicAPI.Unshipped.txt
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ JustSaying.AwsTools.QueueCreation.SqsBasicConfiguration.CompressionOptions.get -
JustSaying.AwsTools.QueueCreation.SqsBasicConfiguration.CompressionOptions.set -> void
JustSaying.Fluent.QueueAddressPublicationBuilder<T>.WithCompression(JustSaying.AwsTools.MessageHandling.PublishCompressionOptions compressionOptions) -> JustSaying.Fluent.QueueAddressPublicationBuilder<T>
JustSaying.Fluent.TopicAddressPublicationBuilder<T>.WithCompression(JustSaying.AwsTools.MessageHandling.PublishCompressionOptions compressionOptions) -> JustSaying.Fluent.TopicAddressPublicationBuilder<T>
JustSaying.IMessagingConfig.CompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.IMessagingConfig.CompressionOptions.set -> void
JustSaying.IMessagingConfig.DefaultCompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.IMessagingConfig.DefaultCompressionOptions.set -> void
JustSaying.Messaging.Compression.ContentEncodings
JustSaying.Messaging.Compression.GzipMessageBodyCompression
JustSaying.Messaging.Compression.GzipMessageBodyCompression.Compress(string messageBody) -> string
Expand All @@ -37,5 +37,5 @@ JustSaying.Messaging.Compression.IMessageCompressionRegistry.GetCompression(stri
JustSaying.Messaging.Compression.MessageCompressionRegistry
JustSaying.Messaging.Compression.MessageCompressionRegistry.GetCompression(string contentEncoding) -> JustSaying.Messaging.Compression.IMessageBodyCompression
JustSaying.Messaging.Compression.MessageCompressionRegistry.MessageCompressionRegistry(System.Collections.Generic.IList<JustSaying.Messaging.Compression.IMessageBodyCompression> compressions) -> void
JustSaying.MessagingConfig.CompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.MessagingConfig.CompressionOptions.set -> void
JustSaying.MessagingConfig.DefaultCompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.MessagingConfig.DefaultCompressionOptions.set -> void
8 changes: 4 additions & 4 deletions src/JustSaying/PublicAPI/net8.0/PublicAPI.Unshipped.txt
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ JustSaying.AwsTools.QueueCreation.SqsBasicConfiguration.CompressionOptions.get -
JustSaying.AwsTools.QueueCreation.SqsBasicConfiguration.CompressionOptions.set -> void
JustSaying.Fluent.QueueAddressPublicationBuilder<T>.WithCompression(JustSaying.AwsTools.MessageHandling.PublishCompressionOptions compressionOptions) -> JustSaying.Fluent.QueueAddressPublicationBuilder<T>
JustSaying.Fluent.TopicAddressPublicationBuilder<T>.WithCompression(JustSaying.AwsTools.MessageHandling.PublishCompressionOptions compressionOptions) -> JustSaying.Fluent.TopicAddressPublicationBuilder<T>
JustSaying.IMessagingConfig.CompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.IMessagingConfig.CompressionOptions.set -> void
JustSaying.IMessagingConfig.DefaultCompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.IMessagingConfig.DefaultCompressionOptions.set -> void
JustSaying.Messaging.Compression.ContentEncodings
JustSaying.Messaging.Compression.GzipMessageBodyCompression
JustSaying.Messaging.Compression.GzipMessageBodyCompression.Compress(string messageBody) -> string
Expand All @@ -37,5 +37,5 @@ JustSaying.Messaging.Compression.IMessageCompressionRegistry.GetCompression(stri
JustSaying.Messaging.Compression.MessageCompressionRegistry
JustSaying.Messaging.Compression.MessageCompressionRegistry.GetCompression(string contentEncoding) -> JustSaying.Messaging.Compression.IMessageBodyCompression
JustSaying.Messaging.Compression.MessageCompressionRegistry.MessageCompressionRegistry(System.Collections.Generic.IList<JustSaying.Messaging.Compression.IMessageBodyCompression> compressions) -> void
JustSaying.MessagingConfig.CompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.MessagingConfig.CompressionOptions.set -> void
JustSaying.MessagingConfig.DefaultCompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.MessagingConfig.DefaultCompressionOptions.set -> void
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,8 @@ JustSaying.AwsTools.QueueCreation.SqsBasicConfiguration.CompressionOptions.get -
JustSaying.AwsTools.QueueCreation.SqsBasicConfiguration.CompressionOptions.set -> void
JustSaying.Fluent.QueueAddressPublicationBuilder<T>.WithCompression(JustSaying.AwsTools.MessageHandling.PublishCompressionOptions compressionOptions) -> JustSaying.Fluent.QueueAddressPublicationBuilder<T>
JustSaying.Fluent.TopicAddressPublicationBuilder<T>.WithCompression(JustSaying.AwsTools.MessageHandling.PublishCompressionOptions compressionOptions) -> JustSaying.Fluent.TopicAddressPublicationBuilder<T>
JustSaying.IMessagingConfig.CompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.IMessagingConfig.CompressionOptions.set -> void
JustSaying.IMessagingConfig.DefaultCompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.IMessagingConfig.DefaultCompressionOptions.set -> void
JustSaying.Messaging.Compression.ContentEncodings
JustSaying.Messaging.Compression.GzipMessageBodyCompression
JustSaying.Messaging.Compression.GzipMessageBodyCompression.Compress(string messageBody) -> string
Expand All @@ -37,5 +37,5 @@ JustSaying.Messaging.Compression.IMessageCompressionRegistry.GetCompression(stri
JustSaying.Messaging.Compression.MessageCompressionRegistry
JustSaying.Messaging.Compression.MessageCompressionRegistry.GetCompression(string contentEncoding) -> JustSaying.Messaging.Compression.IMessageBodyCompression
JustSaying.Messaging.Compression.MessageCompressionRegistry.MessageCompressionRegistry(System.Collections.Generic.IList<JustSaying.Messaging.Compression.IMessageBodyCompression> compressions) -> void
JustSaying.MessagingConfig.CompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.MessagingConfig.CompressionOptions.set -> void
JustSaying.MessagingConfig.DefaultCompressionOptions.get -> JustSaying.AwsTools.MessageHandling.PublishCompressionOptions
JustSaying.MessagingConfig.DefaultCompressionOptions.set -> void

0 comments on commit b3e5222

Please sign in to comment.