Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Exchange and Queue name length validation #649

Closed
wants to merge 6 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ public QueueCreator(ConnectionFactory connectionFactory, IRoutingTopology routin
public Task CreateQueueIfNecessary(QueueBindings queueBindings, string identity)
{
using (var connection = connectionFactory.CreateAdministrationConnection())
using (var channel = connection.CreateModel())
using (var channel = new ModelWithValidation(connection.CreateModel()))
{
DelayInfrastructure.Build(channel);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ public QueuePurger(ConnectionFactory connectionFactory)
public void Purge(string queue)
{
using (var connection = connectionFactory.CreateAdministrationConnection())
using (var channel = connection.CreateModel())
using (var channel = new ModelWithValidation(connection.CreateModel()))
{
channel.QueuePurge(queue);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ public SubscriptionManager(ConnectionFactory connectionFactory, IRoutingTopology
public Task Subscribe(Type eventType, ContextBag context)
{
using (var connection = connectionFactory.CreateAdministrationConnection())
using (var channel = connection.CreateModel())
using (var channel = new ModelWithValidation(connection.CreateModel()))
{
routingTopology.SetupSubscription(channel, eventType, localQueue);
}
Expand All @@ -31,7 +31,7 @@ public Task Subscribe(Type eventType, ContextBag context)
public Task Unsubscribe(Type eventType, ContextBag context)
{
using (var connection = connectionFactory.CreateAdministrationConnection())
using (var channel = connection.CreateModel())
using (var channel = new ModelWithValidation(connection.CreateModel()))
{
routingTopology.TeardownSubscription(channel, eventType, localQueue);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ sealed class ConfirmsAwareChannel : IDisposable
{
public ConfirmsAwareChannel(IConnection connection, IRoutingTopology routingTopology, bool usePublisherConfirms)
{
channel = connection.CreateModel();
channel = new ModelWithValidation(connection.CreateModel());
channel.BasicReturn += Channel_BasicReturn;

this.routingTopology = routingTopology;
Expand Down
Loading