summaryrefslogtreecommitdiff
path: root/dotnet/client-010/addins/ExcelAddInProducer/Program.cs
diff options
context:
space:
mode:
Diffstat (limited to 'dotnet/client-010/addins/ExcelAddInProducer/Program.cs')
-rw-r--r--dotnet/client-010/addins/ExcelAddInProducer/Program.cs110
1 files changed, 55 insertions, 55 deletions
diff --git a/dotnet/client-010/addins/ExcelAddInProducer/Program.cs b/dotnet/client-010/addins/ExcelAddInProducer/Program.cs
index 9c9edcb249..0c97d6809b 100644
--- a/dotnet/client-010/addins/ExcelAddInProducer/Program.cs
+++ b/dotnet/client-010/addins/ExcelAddInProducer/Program.cs
@@ -1,55 +1,55 @@
-/*
-*
-* Licensed to the Apache Software Foundation (ASF) under one
-* or more contributor license agreements. See the NOTICE file
-* distributed with this work for additional information
-* regarding copyright ownership. The ASF licenses this file
-* to you under the Apache License, Version 2.0 (the
-* "License"); you may not use this file except in compliance
-* with the License. You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing,
-* software distributed under the License is distributed on an
-* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-* KIND, either express or implied. See the License for the
-* specific language governing permissions and limitations
-* under the License.
-*
-*/
-using System;
-using System.Text;
-using System.Threading;
-using org.apache.qpid.client;
-
-namespace ExcelAddInProducer
-{
- class Program
- {
- static void Main(string[] args)
- {
- Client client = new Client();
- Console.WriteLine("Client created");
- client.connect("192.168.1.14", 5672, "test", "guest", "guest");
- Console.WriteLine("Connection established");
-
- ClientSession ssn = client.createSession(50000);
- Console.WriteLine("Session created");
- ssn.queueDeclare("queue1", null, null);
- ssn.exchangeBind("queue1", "amq.direct", "queue1", null);
- IMessage message = new Message();
- message.ApplicationHeaders.Add("price", 0);
- for (int i = 0; i < 100; i++)
- {
- message.clearData();
- message.appendData( Encoding.UTF8.GetBytes("test: " + i));
- message.ApplicationHeaders["price"] = i;
- ssn.messageTransfer("amq.direct", "queue1", message);
- Thread.Sleep(1000);
- }
-
- client.close();
- }
- }
-}
+/*
+*
+* Licensed to the Apache Software Foundation (ASF) under one
+* or more contributor license agreements. See the NOTICE file
+* distributed with this work for additional information
+* regarding copyright ownership. The ASF licenses this file
+* to you under the Apache License, Version 2.0 (the
+* "License"); you may not use this file except in compliance
+* with the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing,
+* software distributed under the License is distributed on an
+* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+* KIND, either express or implied. See the License for the
+* specific language governing permissions and limitations
+* under the License.
+*
+*/
+using System;
+using System.Text;
+using System.Threading;
+using org.apache.qpid.client;
+
+namespace ExcelAddInProducer
+{
+ class Program
+ {
+ static void Main(string[] args)
+ {
+ Client client = new Client();
+ Console.WriteLine("Client created");
+ client.connect("192.168.1.14", 5672, "test", "guest", "guest");
+ Console.WriteLine("Connection established");
+
+ ClientSession ssn = client.createSession(50000);
+ Console.WriteLine("Session created");
+ ssn.queueDeclare("queue1", null, null);
+ ssn.exchangeBind("queue1", "amq.direct", "queue1", null);
+ IMessage message = new Message();
+ message.ApplicationHeaders.Add("price", 0);
+ for (int i = 0; i < 100; i++)
+ {
+ message.clearData();
+ message.appendData( Encoding.UTF8.GetBytes("test: " + i));
+ message.ApplicationHeaders["price"] = i;
+ ssn.messageTransfer("amq.direct", "queue1", message);
+ Thread.Sleep(1000);
+ }
+
+ client.close();
+ }
+ }
+}