File tree 4 files changed +4
-4
lines changed 4 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ public static void Main(string[] args)
10
10
using ( var connection = factory . CreateConnection ( ) )
11
11
using ( var channel = connection . CreateModel ( ) )
12
12
{
13
- channel . ExchangeDeclare ( exchange : "logs" , type : "fanout" ) ;
13
+ channel . ExchangeDeclare ( exchange : "logs" , type : ExchangeType . Fanout ) ;
14
14
15
15
var message = GetMessage ( args ) ;
16
16
var body = Encoding . UTF8 . GetBytes ( message ) ;
Original file line number Diff line number Diff line change @@ -11,7 +11,7 @@ public static void Main()
11
11
using ( var connection = factory . CreateConnection ( ) )
12
12
using ( var channel = connection . CreateModel ( ) )
13
13
{
14
- channel . ExchangeDeclare ( exchange : "logs" , type : "fanout" ) ;
14
+ channel . ExchangeDeclare ( exchange : "logs" , type : ExchangeType . Fanout ) ;
15
15
16
16
var queueName = channel . QueueDeclare ( ) . QueueName ;
17
17
channel . QueueBind ( queue : queueName , exchange : "logs" , routingKey : "" ) ;
Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ public static void Main(string[] args)
10
10
using ( var connection = factory . CreateConnection ( ) )
11
11
using ( var channel = connection . CreateModel ( ) )
12
12
{
13
- channel . ExchangeDeclare ( exchange : "logs" , type : "fanout" ) ;
13
+ channel . ExchangeDeclare ( exchange : "logs" , type : ExchangeType . Fanout ) ;
14
14
15
15
var message = GetMessage ( args ) ;
16
16
var body = Encoding . UTF8 . GetBytes ( message ) ;
Original file line number Diff line number Diff line change @@ -11,7 +11,7 @@ public static void Main()
11
11
using ( var connection = factory . CreateConnection ( ) )
12
12
using ( var channel = connection . CreateModel ( ) )
13
13
{
14
- channel . ExchangeDeclare ( exchange : "logs" , type : "fanout" ) ;
14
+ channel . ExchangeDeclare ( exchange : "logs" , type : ExchangeType . Fanout ) ;
15
15
16
16
var queueName = channel . QueueDeclare ( ) . QueueName ;
17
17
channel . QueueBind ( queue : queueName , exchange : "logs" , routingKey : "" ) ;
You can’t perform that action at this time.
0 commit comments