qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ai...@apache.org
Subject svn commit: r886940 [3/14] - in /qpid/trunk/qpid/dotnet/client-010: ./ addins/ addins/ExcelAddIn/ addins/ExcelAddInMessageProcessor/ addins/ExcelAddInProducer/ client/ client/client/ client/transport/ client/transport/codec/ client/transport/exception/...
Date Thu, 03 Dec 2009 22:03:55 GMT
Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Connection.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Connection.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Connection.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Connection.cs Thu Dec  3 22:03:51 2009
@@ -1,172 +1,172 @@
-/*
-*
-* 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.Collections.Generic;
-using Logger = org.apache.qpid.transport.util.Logger;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// Connection
-    /// </summary>
-    public class Connection
-    {
-        private static readonly Logger log = Logger.get(typeof (Connection));
-
-        private readonly Sender<ProtocolEvent> _sender;
-        private readonly ConnectionDelegate _connDdelegate;
-        private  int _channelMax = 1;
-        private int _connectionId;
-        private readonly Receiver<ReceivedPayload<ProtocolEvent>> _receiver;
-
-        private readonly Dictionary<int, Channel> _channels = new Dictionary<int, Channel>();
-
-        public Connection(Receiver<ReceivedPayload<ProtocolEvent>> receiver, Sender<ProtocolEvent> sender, ConnectionDelegate connDdelegate)
-        {
-            _receiver = receiver;
-            _sender = sender;
-            _connDdelegate = connDdelegate;
-        }
-
-        public int ConnectionId
-        {
-            get { return _connectionId; }
-            set { _connectionId = value; }
-        }
-
-        public ConnectionDelegate ConnectionDelegate
-        {
-            get { return _connDdelegate; }
-        }
-
-        public int ChannelMax
-        {
-            get { return _channelMax; }
-            set { _channelMax = value; }
-        }
-
-        public void send(ProtocolEvent pevent)
-        {
-            log.debug("SEND: [{0}] {1}", this, pevent);
-            _sender.send(pevent);
-        }
-
-        public void flush()
-        {
-            log.debug("FLUSH: [{0}]", this);
-            _sender.flush();
-        }
-
-
-        public Channel getChannel()
-        {
-            lock (_channels)
-            {
-                for (int i = 0; i < ChannelMax; i++)
-                {
-                    if (!_channels.ContainsKey(i))
-                    {
-                        return getChannel(i);
-                    }
-                }
-                throw new Exception("no more _channels available");
-            }
-        }
-
-        public Channel getChannel(int number)
-        {
-            lock (_channels)
-            {
-                Channel channel = null;
-                if (_channels.Count > 0)
-                {
-                    if( _channels.ContainsKey(number))
-                        channel = _channels[number];
-                }
-                if (channel == null)
-                {
-                    channel = new Channel(this, number, _connDdelegate.getSessionDelegate());                   
-                    _receiver.Received += channel.On_ReceivedEvent;                   
-                    _channels.Add(number, channel);
-                }
-                return channel;
-            }
-        }
-
-        public void removeChannel(int number)
-        {
-            lock (_channels)
-            {
-                _receiver.Received -= _channels[number].On_ReceivedEvent;
-                _channels.Remove(number);                
-            }
-        }
-
-        public void On_ReceivedEvent(object sender, ReceivedPayload<ProtocolEvent> payload)
-        {
-           log.debug("RECV: [{0}] {1}", this, payload.Payload);
-            if (_channels.ContainsKey(payload.Payload.Channel)) return;
-            Channel channel = getChannel(payload.Payload.Channel);
-            channel.On_ReceivedEvent(sender, payload);
-        }
-
-        public void On_ReceivedException(Object sender, ExceptionArgs arg)
-        {
-            _connDdelegate.exception(arg.Exception);
-        }
-
-        public void On_ReceivedClosed(Object sender, EventArgs arg)
-        {
-            log.debug("Connection closed: {0}", this);
-            lock (_channels)
-            {
-                foreach (Channel ch in _channels.Values)
-                {
-                    ch.closedFromConnection();
-                }
-            }
-            _channels.Clear();
-            _connDdelegate.closed();
-        }
-
-
-        public void closeCode(ConnectionClose close)
-        {
-            lock (_channels)
-            {
-                foreach (Channel ch in _channels.Values)
-                {
-                    ch.closeCode(close);
-                }
-            }
-        }
-
-        public void close()
-        {
-            _sender.close();
-        }
-
-        public String toString()
-        {
-            return String.Format("conn:{0}", this);
-        }
-    }
-}
+/*
+*
+* 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.Collections.Generic;
+using Logger = org.apache.qpid.transport.util.Logger;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// Connection
+    /// </summary>
+    public class Connection
+    {
+        private static readonly Logger log = Logger.get(typeof (Connection));
+
+        private readonly Sender<ProtocolEvent> _sender;
+        private readonly ConnectionDelegate _connDdelegate;
+        private  int _channelMax = 1;
+        private int _connectionId;
+        private readonly Receiver<ReceivedPayload<ProtocolEvent>> _receiver;
+
+        private readonly Dictionary<int, Channel> _channels = new Dictionary<int, Channel>();
+
+        public Connection(Receiver<ReceivedPayload<ProtocolEvent>> receiver, Sender<ProtocolEvent> sender, ConnectionDelegate connDdelegate)
+        {
+            _receiver = receiver;
+            _sender = sender;
+            _connDdelegate = connDdelegate;
+        }
+
+        public int ConnectionId
+        {
+            get { return _connectionId; }
+            set { _connectionId = value; }
+        }
+
+        public ConnectionDelegate ConnectionDelegate
+        {
+            get { return _connDdelegate; }
+        }
+
+        public int ChannelMax
+        {
+            get { return _channelMax; }
+            set { _channelMax = value; }
+        }
+
+        public void send(ProtocolEvent pevent)
+        {
+            log.debug("SEND: [{0}] {1}", this, pevent);
+            _sender.send(pevent);
+        }
+
+        public void flush()
+        {
+            log.debug("FLUSH: [{0}]", this);
+            _sender.flush();
+        }
+
+
+        public Channel getChannel()
+        {
+            lock (_channels)
+            {
+                for (int i = 0; i < ChannelMax; i++)
+                {
+                    if (!_channels.ContainsKey(i))
+                    {
+                        return getChannel(i);
+                    }
+                }
+                throw new Exception("no more _channels available");
+            }
+        }
+
+        public Channel getChannel(int number)
+        {
+            lock (_channels)
+            {
+                Channel channel = null;
+                if (_channels.Count > 0)
+                {
+                    if( _channels.ContainsKey(number))
+                        channel = _channels[number];
+                }
+                if (channel == null)
+                {
+                    channel = new Channel(this, number, _connDdelegate.getSessionDelegate());                   
+                    _receiver.Received += channel.On_ReceivedEvent;                   
+                    _channels.Add(number, channel);
+                }
+                return channel;
+            }
+        }
+
+        public void removeChannel(int number)
+        {
+            lock (_channels)
+            {
+                _receiver.Received -= _channels[number].On_ReceivedEvent;
+                _channels.Remove(number);                
+            }
+        }
+
+        public void On_ReceivedEvent(object sender, ReceivedPayload<ProtocolEvent> payload)
+        {
+           log.debug("RECV: [{0}] {1}", this, payload.Payload);
+            if (_channels.ContainsKey(payload.Payload.Channel)) return;
+            Channel channel = getChannel(payload.Payload.Channel);
+            channel.On_ReceivedEvent(sender, payload);
+        }
+
+        public void On_ReceivedException(Object sender, ExceptionArgs arg)
+        {
+            _connDdelegate.exception(arg.Exception);
+        }
+
+        public void On_ReceivedClosed(Object sender, EventArgs arg)
+        {
+            log.debug("Connection closed: {0}", this);
+            lock (_channels)
+            {
+                foreach (Channel ch in _channels.Values)
+                {
+                    ch.closedFromConnection();
+                }
+            }
+            _channels.Clear();
+            _connDdelegate.closed();
+        }
+
+
+        public void closeCode(ConnectionClose close)
+        {
+            lock (_channels)
+            {
+                foreach (Channel ch in _channels.Values)
+                {
+                    ch.closeCode(close);
+                }
+            }
+        }
+
+        public void close()
+        {
+            _sender.close();
+        }
+
+        public String toString()
+        {
+            return String.Format("conn:{0}", this);
+        }
+    }
+}

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs Thu Dec  3 22:03:51 2009
@@ -1,108 +1,108 @@
-/*
-*
-* 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.Collections.Generic;
-using System.Threading;
-using Logger = org.apache.qpid.transport.util.Logger;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// ConnectionDelegate
-    /// 
-    /// Currently only implemented client specific methods
-    /// </summary>
-    public abstract class ConnectionDelegate : MethodDelegate<Channel>
-    {
-        private static readonly Logger log = Logger.get(typeof(ConnectionDelegate));
-        private String _virtualHost;
-
-        private ManualResetEvent _negotiationComplete;
-
-        public abstract SessionDelegate getSessionDelegate();
-
-        public abstract void exception(Exception t);
-
-        public abstract void closed();
-
-        public void setCondition(ManualResetEvent negotiationComplete)
-        {
-            _negotiationComplete = negotiationComplete;
-        }
-
-        public virtual void init(Channel ch, ProtocolHeader hdr)
-        {
-            ch.Connection.send(new ProtocolHeader((byte)1, hdr.Major, hdr.Minor));
-            List<Object> plain = new List<Object>();
-            plain.Add("PLAIN");
-            List<Object> utf8 = new List<Object>();
-            utf8.Add("utf8");
-            ch.connectionStart(null, plain, utf8);
-        }
-
-        public String VirtualHost
-        {
-            get { return _virtualHost; }
-            set { _virtualHost = value; }
-        }
-
-        // ----------------------------------------------
-        //           Client side
-        //-----------------------------------------------
-        public override void connectionStart(Channel context, ConnectionStart mstruct)
-        {            
-            Dictionary<String, Object> props = new Dictionary<String, Object>();
-            context.connectionStartOk(props, null, null, "utf8");
-        }
-
-        public override void connectionSecure(Channel context, ConnectionSecure mstruct)
-        {      // todo SASL          
-            context.connectionSecureOk(new byte[0]);
-        }
-
-        public override void connectionTune(Channel context, ConnectionTune mstruct)
-        {
-            context.Connection.ChannelMax = mstruct.getChannelMax();
-            context.connectionTuneOk(mstruct.getChannelMax(), mstruct.getMaxFrameSize(), mstruct.getHeartbeatMax());
-            context.connectionOpen(_virtualHost, null, Option.INSIST);
-        }
-
-        public override void connectionOpenOk(Channel context, ConnectionOpenOk mstruct)
-        {
-            List<Object> knownHosts = mstruct.getKnownHosts();
-            if (_negotiationComplete != null)
-            {
-                _negotiationComplete.Set();
-            }
-        }
-
-        public override void connectionRedirect(Channel context, ConnectionRedirect mstruct)
-        {
-            // not going to bother at the moment
-        }
-
-        public override void connectionClose(Channel ch, ConnectionClose close)
-        {
-            ch.Connection.closeCode(close);
-            ch.connectionCloseOk();
-        }
-    }
+/*
+*
+* 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.Collections.Generic;
+using System.Threading;
+using Logger = org.apache.qpid.transport.util.Logger;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// ConnectionDelegate
+    /// 
+    /// Currently only implemented client specific methods
+    /// </summary>
+    public abstract class ConnectionDelegate : MethodDelegate<Channel>
+    {
+        private static readonly Logger log = Logger.get(typeof(ConnectionDelegate));
+        private String _virtualHost;
+
+        private ManualResetEvent _negotiationComplete;
+
+        public abstract SessionDelegate getSessionDelegate();
+
+        public abstract void exception(Exception t);
+
+        public abstract void closed();
+
+        public void setCondition(ManualResetEvent negotiationComplete)
+        {
+            _negotiationComplete = negotiationComplete;
+        }
+
+        public virtual void init(Channel ch, ProtocolHeader hdr)
+        {
+            ch.Connection.send(new ProtocolHeader((byte)1, hdr.Major, hdr.Minor));
+            List<Object> plain = new List<Object>();
+            plain.Add("PLAIN");
+            List<Object> utf8 = new List<Object>();
+            utf8.Add("utf8");
+            ch.connectionStart(null, plain, utf8);
+        }
+
+        public String VirtualHost
+        {
+            get { return _virtualHost; }
+            set { _virtualHost = value; }
+        }
+
+        // ----------------------------------------------
+        //           Client side
+        //-----------------------------------------------
+        public override void connectionStart(Channel context, ConnectionStart mstruct)
+        {            
+            Dictionary<String, Object> props = new Dictionary<String, Object>();
+            context.connectionStartOk(props, null, null, "utf8");
+        }
+
+        public override void connectionSecure(Channel context, ConnectionSecure mstruct)
+        {      // todo SASL          
+            context.connectionSecureOk(new byte[0]);
+        }
+
+        public override void connectionTune(Channel context, ConnectionTune mstruct)
+        {
+            context.Connection.ChannelMax = mstruct.getChannelMax();
+            context.connectionTuneOk(mstruct.getChannelMax(), mstruct.getMaxFrameSize(), mstruct.getHeartbeatMax());
+            context.connectionOpen(_virtualHost, null, Option.INSIST);
+        }
+
+        public override void connectionOpenOk(Channel context, ConnectionOpenOk mstruct)
+        {
+            List<Object> knownHosts = mstruct.getKnownHosts();
+            if (_negotiationComplete != null)
+            {
+                _negotiationComplete.Set();
+            }
+        }
+
+        public override void connectionRedirect(Channel context, ConnectionRedirect mstruct)
+        {
+            // not going to bother at the moment
+        }
+
+        public override void connectionClose(Channel ch, ConnectionClose close)
+        {
+            ch.Connection.closeCode(close);
+            ch.connectionCloseOk();
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Field.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Field.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Field.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Field.cs Thu Dec  3 22:03:51 2009
@@ -1,75 +1,75 @@
-/*
-*
-* 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 Decoder = org.apache.qpid.transport.codec.Decoder;
-using Encoder = org.apache.qpid.transport.codec.Encoder;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// Field
-    /// </summary>
-    public abstract class Field<C, T>
-    {
-        private C container;
-        private T type;
-        private String name;
-        private int index;
-
-        protected Field(C container, T type, String name, int index)
-        {
-            this.container = container;
-            this.type = type;
-            this.name = name;
-            this.index = index;
-        }
-
-        public C Container
-        {
-            get { return container; }
-        }
-
-        public T Type
-        {
-            get { return type; }
-        }
-
-        public String Name
-        {
-            get { return name; }
-        }
-
-        public int Index
-        {
-            get { return index; }
-        }
-
-        public abstract bool has(Object mystruct);
-
-        public abstract void has(Object mystruct, bool value);
-
-        public abstract T get(Object mystruct);
-
-        public abstract void read(Decoder dec, Object mystruct);
-
-        public abstract void write(Encoder enc, Object mystruct);
-    }
+/*
+*
+* 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 Decoder = org.apache.qpid.transport.codec.Decoder;
+using Encoder = org.apache.qpid.transport.codec.Encoder;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// Field
+    /// </summary>
+    public abstract class Field<C, T>
+    {
+        private C container;
+        private T type;
+        private String name;
+        private int index;
+
+        protected Field(C container, T type, String name, int index)
+        {
+            this.container = container;
+            this.type = type;
+            this.name = name;
+            this.index = index;
+        }
+
+        public C Container
+        {
+            get { return container; }
+        }
+
+        public T Type
+        {
+            get { return type; }
+        }
+
+        public String Name
+        {
+            get { return name; }
+        }
+
+        public int Index
+        {
+            get { return index; }
+        }
+
+        public abstract bool has(Object mystruct);
+
+        public abstract void has(Object mystruct, bool value);
+
+        public abstract T get(Object mystruct);
+
+        public abstract void read(Decoder dec, Object mystruct);
+
+        public abstract void write(Encoder enc, Object mystruct);
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Future.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Future.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Future.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Future.cs Thu Dec  3 22:03:51 2009
@@ -1,38 +1,38 @@
-/*
-*
-* 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.
-*
-*/
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// Future
-    /// </summary>
-    public interface Future
-    {
-        Struct Result
-        {
-            get; set;
-        }
-
-        Session Session
-        { set;
-        }
-    }
+/*
+*
+* 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.
+*
+*/
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// Future
+    /// </summary>
+    public interface Future
+    {
+        Struct Result
+        {
+            get; set;
+        }
+
+        Session Session
+        { set;
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Header.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Header.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Header.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Header.cs Thu Dec  3 22:03:51 2009
@@ -1,83 +1,83 @@
-/*
-*
-* 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.Collections.Generic;
-using System.Text;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// Header
-    /// </summary>
-    public class Header
-    {
-        private readonly Struct[] _mystructs;
-
-        public Header(List<Struct> structs)
-            : this(structs.ToArray())
-        {
-        }
-
-        public Header(params Struct[] structs)
-        {
-            _mystructs = structs;
-        }
-
-        public Struct[] Structs
-        {
-            get { return _mystructs; }
-        }
-
-
-        public Struct get(Struct klass)
-        {
-            foreach (Struct st in _mystructs)
-            {
-                if (Equals(st.GetType(), klass.GetType()))
-                {
-                    return st;
-                }
-            }
-            return null;
-        }
-
-        public String toString()
-        {
-            StringBuilder str = new StringBuilder();
-            str.Append(" Header(");
-            bool first = true;
-            foreach (Struct s in _mystructs)
-            {
-                if (first)
-                {
-                    first = false;
-                }
-                else
-                {
-                    str.Append(", ");
-                }
-                str.Append(s);
-            }
-            str.Append(")");
-            return str.ToString();
-        }
-    }
+/*
+*
+* 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.Collections.Generic;
+using System.Text;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// Header
+    /// </summary>
+    public class Header
+    {
+        private readonly Struct[] _mystructs;
+
+        public Header(List<Struct> structs)
+            : this(structs.ToArray())
+        {
+        }
+
+        public Header(params Struct[] structs)
+        {
+            _mystructs = structs;
+        }
+
+        public Struct[] Structs
+        {
+            get { return _mystructs; }
+        }
+
+
+        public Struct get(Struct klass)
+        {
+            foreach (Struct st in _mystructs)
+            {
+                if (Equals(st.GetType(), klass.GetType()))
+                {
+                    return st;
+                }
+            }
+            return null;
+        }
+
+        public String toString()
+        {
+            StringBuilder str = new StringBuilder();
+            str.Append(" Header(");
+            bool first = true;
+            foreach (Struct s in _mystructs)
+            {
+                if (first)
+                {
+                    first = false;
+                }
+                else
+                {
+                    str.Append(", ");
+                }
+                str.Append(s);
+            }
+            str.Append(")");
+            return str.ToString();
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Method.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Method.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Method.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Method.cs Thu Dec  3 22:03:51 2009
@@ -1,150 +1,150 @@
-/*
-*
-* 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.IO;
-using System.Text;
-using Frame = org.apache.qpid.transport.network.Frame;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// Method
-    /// </summary>
-    public abstract class Method : Struct, ProtocolEvent
-    {
-        public new static Method create(int type)
-        {
-            return (Method) StructFactory.createInstruction(type);
-        }
-
-        // XXX: command subclass?
-        private int id;
-        private int channel;
-        private bool idSet;
-        private bool sync;
-        private bool batch;
-
-        public int Id
-        {
-            get { return id; }
-            set
-            {
-                id = value;
-                idSet = true;
-            }
-        }
-
-
-        public bool Sync
-        {
-            get { return sync; }
-            set { sync = value; }
-        }
-
-        public bool Batch
-        {
-            get { return batch; }
-            set { batch = value; }
-        }
-
-        public abstract bool hasPayload();
-
-        public virtual Header Header
-        {
-            get { return null; }
-            set { throw new Exception(); }
-        }
-
-        public virtual MemoryStream Body
-        {
-            get { return null; }
-            set { throw new Exception(); }
-        }
-
-
-        public abstract void dispatch<C>(C context, MethodDelegate<C> mdelegate );
-
-        #region ProtocolEvent
-
-        public int Channel
-        {
-            get { return channel; }
-            set { channel = value; }
-        }
-
-        public abstract byte EncodedTrack { get; set; }
-
-        public void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate)
-        {
-            if (EncodedTrack == Frame.L4)
-            {
-                protocoldelegate.Command(context, this);
-            }
-            else
-            {
-                protocoldelegate.Control(context, this);
-            }
-        }
-
-        #endregion
-
-        public new String toString()
-        {
-            StringBuilder str = new StringBuilder();
-
-            str.Append("ch=");
-            str.Append(channel);
-
-            if (EncodedTrack == Frame.L4 && idSet)
-            {
-                str.Append(" id=");
-                str.Append(id);
-            }
-
-            if (sync || batch)
-            {
-                str.Append(" ");
-                str.Append("[");
-                if (Sync)
-                {
-                    str.Append("S");
-                }
-                if (Batch)
-                {
-                    str.Append("B");
-                }
-                str.Append("]");
-            }
-            str.Append(" ");
-            str.Append(base.toString());
-            if (Header != null)
-            {
-                str.Append(Header.toString());
-            }
-            if (Body != null)
-            {
-                str.Append("\n  body=");
-                str.Append(Body.ToString());
-            }
-            return str.ToString();
-        }
-    }
+/*
+*
+* 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.IO;
+using System.Text;
+using Frame = org.apache.qpid.transport.network.Frame;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// Method
+    /// </summary>
+    public abstract class Method : Struct, ProtocolEvent
+    {
+        public new static Method create(int type)
+        {
+            return (Method) StructFactory.createInstruction(type);
+        }
+
+        // XXX: command subclass?
+        private int id;
+        private int channel;
+        private bool idSet;
+        private bool sync;
+        private bool batch;
+
+        public int Id
+        {
+            get { return id; }
+            set
+            {
+                id = value;
+                idSet = true;
+            }
+        }
+
+
+        public bool Sync
+        {
+            get { return sync; }
+            set { sync = value; }
+        }
+
+        public bool Batch
+        {
+            get { return batch; }
+            set { batch = value; }
+        }
+
+        public abstract bool hasPayload();
+
+        public virtual Header Header
+        {
+            get { return null; }
+            set { throw new Exception(); }
+        }
+
+        public virtual MemoryStream Body
+        {
+            get { return null; }
+            set { throw new Exception(); }
+        }
+
+
+        public abstract void dispatch<C>(C context, MethodDelegate<C> mdelegate );
+
+        #region ProtocolEvent
+
+        public int Channel
+        {
+            get { return channel; }
+            set { channel = value; }
+        }
+
+        public abstract byte EncodedTrack { get; set; }
+
+        public void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate)
+        {
+            if (EncodedTrack == Frame.L4)
+            {
+                protocoldelegate.Command(context, this);
+            }
+            else
+            {
+                protocoldelegate.Control(context, this);
+            }
+        }
+
+        #endregion
+
+        public new String toString()
+        {
+            StringBuilder str = new StringBuilder();
+
+            str.Append("ch=");
+            str.Append(channel);
+
+            if (EncodedTrack == Frame.L4 && idSet)
+            {
+                str.Append(" id=");
+                str.Append(id);
+            }
+
+            if (sync || batch)
+            {
+                str.Append(" ");
+                str.Append("[");
+                if (Sync)
+                {
+                    str.Append("S");
+                }
+                if (Batch)
+                {
+                    str.Append("B");
+                }
+                str.Append("]");
+            }
+            str.Append(" ");
+            str.Append(base.toString());
+            if (Header != null)
+            {
+                str.Append(Header.toString());
+            }
+            if (Body != null)
+            {
+                str.Append("\n  body=");
+                str.Append(Body.ToString());
+            }
+            return str.ToString();
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolDelegate.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolDelegate.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolDelegate.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolDelegate.cs Thu Dec  3 22:03:51 2009
@@ -1,37 +1,37 @@
-/*
-*
-* 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.
-*
-*/
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// ProtocolDelegate
-    /// </summary>
-    public interface ProtocolDelegate<T>
-    {
-        void Init(T context, ProtocolHeader header);
-
-        void Control(T context, Method control);
-
-        void Command(T context, Method command);
-
-        void Error(T context, ProtocolError error);
-    }
+/*
+*
+* 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.
+*
+*/
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// ProtocolDelegate
+    /// </summary>
+    public interface ProtocolDelegate<T>
+    {
+        void Init(T context, ProtocolHeader header);
+
+        void Control(T context, Method control);
+
+        void Command(T context, Method command);
+
+        void Error(T context, ProtocolError error);
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolError.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolError.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolError.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolError.cs Thu Dec  3 22:03:51 2009
@@ -1,86 +1,86 @@
-/*
-*
-* 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 NetworkDelegate = org.apache.qpid.transport.network.NetworkDelegate;
-using NetworkEvent = org.apache.qpid.transport.network.NetworkEvent;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// ProtocolError
-    /// </summary>
-    public sealed class ProtocolError : NetworkEvent, ProtocolEvent
-    {
-        private int channel;
-        private byte track;
-        private String format;
-        private Object[] args;
-
-        public ProtocolError(byte track, String format, params Object[] args)
-        {
-            this.track = track;
-            this.format = format;
-            this.args = args;
-        }
-
-        #region NetworkEvent Methods
-
-        public void ProcessNetworkEvent(NetworkDelegate ndelegate)
-        {
-            ndelegate.Error(this);
-        }
-
-        #endregion
-
-        #region ProtocolEvent Methods
-
-        public int Channel
-        {
-            get { return channel; }
-            set { channel = value; }
-        }
-
-        public byte EncodedTrack
-        {
-            get { return track; }
-            set { throw new NotImplementedException(); }
-        }
-
-        public void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate)
-        {
-            protocoldelegate.Error(context, this);
-        }
-
-        #endregion
-
-        public String Message
-        {
-            get { return String.Format(format, args); }
-        }
-
-
-        public String toString()
-        {
-            return String.Format("protocol error: {0}", Message);
-        }
-
-    }
+/*
+*
+* 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 NetworkDelegate = org.apache.qpid.transport.network.NetworkDelegate;
+using NetworkEvent = org.apache.qpid.transport.network.NetworkEvent;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// ProtocolError
+    /// </summary>
+    public sealed class ProtocolError : NetworkEvent, ProtocolEvent
+    {
+        private int channel;
+        private byte track;
+        private String format;
+        private Object[] args;
+
+        public ProtocolError(byte track, String format, params Object[] args)
+        {
+            this.track = track;
+            this.format = format;
+            this.args = args;
+        }
+
+        #region NetworkEvent Methods
+
+        public void ProcessNetworkEvent(NetworkDelegate ndelegate)
+        {
+            ndelegate.Error(this);
+        }
+
+        #endregion
+
+        #region ProtocolEvent Methods
+
+        public int Channel
+        {
+            get { return channel; }
+            set { channel = value; }
+        }
+
+        public byte EncodedTrack
+        {
+            get { return track; }
+            set { throw new NotImplementedException(); }
+        }
+
+        public void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate)
+        {
+            protocoldelegate.Error(context, this);
+        }
+
+        #endregion
+
+        public String Message
+        {
+            get { return String.Format(format, args); }
+        }
+
+
+        public String toString()
+        {
+            return String.Format("protocol error: {0}", Message);
+        }
+
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolEvent.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolEvent.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolEvent.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolEvent.cs Thu Dec  3 22:03:51 2009
@@ -1,42 +1,42 @@
-/*
-*
-* 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.
-*
-*/
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// ProtocolEvent
-    /// </summary>
-    public interface ProtocolEvent
-    {
-        int Channel
-        {
-            get;
-            set;
-        }
-
-        byte EncodedTrack
-        {
-            set; 
-            get;
-        }
-
-        void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate);  
-    }    
+/*
+*
+* 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.
+*
+*/
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// ProtocolEvent
+    /// </summary>
+    public interface ProtocolEvent
+    {
+        int Channel
+        {
+            get;
+            set;
+        }
+
+        byte EncodedTrack
+        {
+            set; 
+            get;
+        }
+
+        void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate);  
+    }    
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolHeader.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolHeader.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolHeader.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/ProtocolHeader.cs Thu Dec  3 22:03:51 2009
@@ -1,125 +1,125 @@
-/*
-*
-* 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.IO;
-using System.Text;
-using NetworkDelegate = org.apache.qpid.transport.network.NetworkDelegate;
-using NetworkEvent = org.apache.qpid.transport.network.NetworkEvent;
-using Frame = org.apache.qpid.transport.network.Frame;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> ProtocolHeader
-    /// 
-    /// </summary>
-    public sealed class ProtocolHeader : NetworkEvent, ProtocolEvent
-    {
-        private readonly char[] AMQP = new char[] {'A', 'M', 'Q', 'P'};
-        private const byte CLASS = 1;
-
-        private readonly byte instance;
-        private readonly byte major;
-        private readonly byte minor;
-        private int channel;
-
-        public ProtocolHeader(byte instance, byte major, byte minor)
-        {
-            this.instance = instance;
-            this.major = major;
-            this.minor = minor;
-        }
-
-        public ProtocolHeader(int instance, int major, int minor) : this((byte)instance, (byte)major, (byte)minor)
-        {
-        }
-
-        #region NetworkEvent Methods
-
-        public void ProcessNetworkEvent(NetworkDelegate ndelegate)
-        {
-            ndelegate.Init(this);
-        }
-
-        #endregion
-
-        #region ProtocolEvent Methods
-
-        public int Channel
-        {
-            get
-            {
-                return channel;
-            }
-            set
-            {
-                channel = value;
-            }           
-        }
-
-        public byte EncodedTrack
-        {
-            get
-            {
-                return Frame.L1;
-            }
-            set { throw new NotImplementedException(); }
-        }
-
-        public void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate)
-        {
-            protocoldelegate.Init(context, this);
-        }
-
-        #endregion
-
-        public byte Instance
-        {
-            get { return instance; }
-        }
-
-        public byte Major
-        {
-            get { return major; }
-        }
-
-        public byte Minor
-        {
-            get { return minor; }
-        }
-
-        public MemoryStream ToMemoryStream()
-        {
-            MemoryStream buf = new MemoryStream(8);
-            BinaryWriter writer = new BinaryWriter(buf);
-            writer.Write(AMQP);
-            writer.Write(CLASS);
-            writer.Write(instance);
-            writer.Write((sbyte) major);
-            writer.Write((sbyte) minor);
-            return buf;
-        }
-
-        public String toString()
-        {
-            return String.Format("AMQP.{0:d} {1:d}-{2:d}", instance, major, minor);
-        }
-    }
+/*
+*
+* 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.IO;
+using System.Text;
+using NetworkDelegate = org.apache.qpid.transport.network.NetworkDelegate;
+using NetworkEvent = org.apache.qpid.transport.network.NetworkEvent;
+using Frame = org.apache.qpid.transport.network.Frame;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> ProtocolHeader
+    /// 
+    /// </summary>
+    public sealed class ProtocolHeader : NetworkEvent, ProtocolEvent
+    {
+        private readonly char[] AMQP = new char[] {'A', 'M', 'Q', 'P'};
+        private const byte CLASS = 1;
+
+        private readonly byte instance;
+        private readonly byte major;
+        private readonly byte minor;
+        private int channel;
+
+        public ProtocolHeader(byte instance, byte major, byte minor)
+        {
+            this.instance = instance;
+            this.major = major;
+            this.minor = minor;
+        }
+
+        public ProtocolHeader(int instance, int major, int minor) : this((byte)instance, (byte)major, (byte)minor)
+        {
+        }
+
+        #region NetworkEvent Methods
+
+        public void ProcessNetworkEvent(NetworkDelegate ndelegate)
+        {
+            ndelegate.Init(this);
+        }
+
+        #endregion
+
+        #region ProtocolEvent Methods
+
+        public int Channel
+        {
+            get
+            {
+                return channel;
+            }
+            set
+            {
+                channel = value;
+            }           
+        }
+
+        public byte EncodedTrack
+        {
+            get
+            {
+                return Frame.L1;
+            }
+            set { throw new NotImplementedException(); }
+        }
+
+        public void ProcessProtocolEvent<C>(C context, ProtocolDelegate<C> protocoldelegate)
+        {
+            protocoldelegate.Init(context, this);
+        }
+
+        #endregion
+
+        public byte Instance
+        {
+            get { return instance; }
+        }
+
+        public byte Major
+        {
+            get { return major; }
+        }
+
+        public byte Minor
+        {
+            get { return minor; }
+        }
+
+        public MemoryStream ToMemoryStream()
+        {
+            MemoryStream buf = new MemoryStream(8);
+            BinaryWriter writer = new BinaryWriter(buf);
+            writer.Write(AMQP);
+            writer.Write(CLASS);
+            writer.Write(instance);
+            writer.Write((sbyte) major);
+            writer.Write((sbyte) minor);
+            return buf;
+        }
+
+        public String toString()
+        {
+            return String.Format("AMQP.{0:d} {1:d}-{2:d}", instance, major, minor);
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Range.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Range.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Range.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Range.cs Thu Dec  3 22:03:51 2009
@@ -1,117 +1,117 @@
-/*
-*
-* 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.Collections.Generic;
-using org.apache.qpid.transport.util;
-
-namespace org.apache.qpid.transport
-{
-	
-	/// <summary> 
-	/// Range
-	/// </summary>
-
-
-    public sealed class Range
-    {
-        private int _lower;
-        private int _upper;
-
-        public Range(int lower, int upper)
-        {
-            _lower = lower;
-            _upper = upper;
-        }
-
-        public int Lower
-        {
-            get { return _lower; }
-            set { _lower = value; }
-        }
-        public int Upper
-        {
-            get { return _upper; }
-            set { _upper = value; }
-        }
-
-        public bool includes(int value)
-        {
-            return Serial.le(_lower, value) && Serial.le(value, _upper);
-        }
-
-        public bool includes(Range range)
-        {
-            return includes(range._lower) && includes(range._upper);
-        }
-
-        public bool intersects(Range range)
-        {
-            return (includes(range._lower) || includes(range._upper) ||
-                    range.includes(_lower) || range.includes(_upper));
-        }
-
-        public bool touches(Range range)
-        {
-            return (intersects(range) ||
-                    includes(range._upper + 1) || includes(range._lower - 1) ||
-                    range.includes(_upper + 1) || range.includes(_lower - 1));
-        }
-
-        public Range span(Range range)
-        {
-            return new Range(Serial.min(_lower, range._lower), Serial.max(_upper, range._upper));
-        }
-
-        public List<Range> subtract(Range range)
-        {
-            List<Range> result = new List<Range>();
-
-            if (includes(range._lower) && Serial.le(_lower, range._lower - 1))
-            {
-                result.Add(new Range(_lower, range._lower - 1));
-            }
-
-            if (includes(range._upper) && Serial.le(range._upper + 1, _upper))
-            {
-                result.Add(new Range(range._upper + 1, _upper));
-            }
-
-            if (result.Count == 0 && !range.includes(this))
-            {
-                result.Add(this);
-            }
-
-            return result;
-        }
-
-        public Range intersect(Range range)
-        {
-            int l = Serial.max(_lower, range._lower);
-            int r = Serial.min(_upper, range._upper);
-            return Serial.gt(l, r) ? null : new Range(l, r);
-        }
-
-        public String toString()
-        {
-            return "[" + _lower + ", " + _upper + "]";
-        }
-    }
+/*
+*
+* 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.Collections.Generic;
+using org.apache.qpid.transport.util;
+
+namespace org.apache.qpid.transport
+{
+	
+	/// <summary> 
+	/// Range
+	/// </summary>
+
+
+    public sealed class Range
+    {
+        private int _lower;
+        private int _upper;
+
+        public Range(int lower, int upper)
+        {
+            _lower = lower;
+            _upper = upper;
+        }
+
+        public int Lower
+        {
+            get { return _lower; }
+            set { _lower = value; }
+        }
+        public int Upper
+        {
+            get { return _upper; }
+            set { _upper = value; }
+        }
+
+        public bool includes(int value)
+        {
+            return Serial.le(_lower, value) && Serial.le(value, _upper);
+        }
+
+        public bool includes(Range range)
+        {
+            return includes(range._lower) && includes(range._upper);
+        }
+
+        public bool intersects(Range range)
+        {
+            return (includes(range._lower) || includes(range._upper) ||
+                    range.includes(_lower) || range.includes(_upper));
+        }
+
+        public bool touches(Range range)
+        {
+            return (intersects(range) ||
+                    includes(range._upper + 1) || includes(range._lower - 1) ||
+                    range.includes(_upper + 1) || range.includes(_lower - 1));
+        }
+
+        public Range span(Range range)
+        {
+            return new Range(Serial.min(_lower, range._lower), Serial.max(_upper, range._upper));
+        }
+
+        public List<Range> subtract(Range range)
+        {
+            List<Range> result = new List<Range>();
+
+            if (includes(range._lower) && Serial.le(_lower, range._lower - 1))
+            {
+                result.Add(new Range(_lower, range._lower - 1));
+            }
+
+            if (includes(range._upper) && Serial.le(range._upper + 1, _upper))
+            {
+                result.Add(new Range(range._upper + 1, _upper));
+            }
+
+            if (result.Count == 0 && !range.includes(this))
+            {
+                result.Add(this);
+            }
+
+            return result;
+        }
+
+        public Range intersect(Range range)
+        {
+            int l = Serial.max(_lower, range._lower);
+            int r = Serial.min(_upper, range._upper);
+            return Serial.gt(l, r) ? null : new Range(l, r);
+        }
+
+        public String toString()
+        {
+            return "[" + _lower + ", " + _upper + "]";
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/RangeSet.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/RangeSet.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/RangeSet.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/RangeSet.cs Thu Dec  3 22:03:51 2009
@@ -1,150 +1,150 @@
-/*
-*
-* 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.Collections;
-using System.Collections.Generic;
-using System.Text;
-using org.apache.qpid.transport.util;
-
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// RangeSet
-    /// </summary>
-    public sealed class RangeSet : IEnumerable<Range>
-    {
-        private readonly List<Range> _ranges = new List<Range>();
-
-        IEnumerator IEnumerable.GetEnumerator()
-        {
-            return GetEnumerator();
-        }
-
-        public IEnumerator<Range> GetEnumerator()
-        {
-            return _ranges.GetEnumerator();
-        }
-
-
-        public int size()
-        {
-            return _ranges.Count;
-        }
-
-
-        public Range getFirst()
-        {
-            return _ranges[0];
-        }
-
-        public bool includes(Range range)
-        {
-            foreach (Range r in this)
-            {
-                if (r.includes(range))
-                {
-                    return true;
-                }
-            }
-
-            return false;
-        }
-
-        public bool includes(int n)
-        {
-            foreach (Range r in this)
-            {
-                if (r.includes(n))
-                {
-                    return true;
-                }
-            }
-
-            return false;
-        }
-
-        public void add(Range range)
-        {
-            for (int i = 0; i < _ranges.Count; i++)
-            {
-                Range r = _ranges[i];
-                if (range.touches(r))
-                {
-                    _ranges.Remove(r);
-                    range = range.span(r);
-                }
-                else if (Serial.lt(range.Upper, r.Lower))
-                {
-                    _ranges.Insert(i - 1 , range);
-                    return;
-                }
-            }
-            _ranges.Add(range);
-        }
-
-        public void add(int lower, int upper)
-        {
-            add(new Range(lower, upper));
-        }
-
-        public void add(int value)
-        {
-            add(value, value);
-        }
-
-        public void clear()
-        {
-            _ranges.Clear();
-        }
-
-        public RangeSet copy()
-        {
-            RangeSet copy = new RangeSet();
-            foreach (Range r in _ranges)
-            {
-                copy._ranges.Add(r);
-            }
-            return copy;
-        }
-
-        public String toString()
-        {
-            StringBuilder str = new StringBuilder();
-            str.Append("{");
-            bool first = true;
-            foreach (Range range in _ranges)
-            {
-                if (first)
-                {
-                    first = false;
-                }
-                else
-                {
-                    str.Append(", ");
-                }
-                str.Append(range);
-            }
-            str.Append("}");
-            return str.ToString();
-        }
-    }
+/*
+*
+* 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.Collections;
+using System.Collections.Generic;
+using System.Text;
+using org.apache.qpid.transport.util;
+
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// RangeSet
+    /// </summary>
+    public sealed class RangeSet : IEnumerable<Range>
+    {
+        private readonly List<Range> _ranges = new List<Range>();
+
+        IEnumerator IEnumerable.GetEnumerator()
+        {
+            return GetEnumerator();
+        }
+
+        public IEnumerator<Range> GetEnumerator()
+        {
+            return _ranges.GetEnumerator();
+        }
+
+
+        public int size()
+        {
+            return _ranges.Count;
+        }
+
+
+        public Range getFirst()
+        {
+            return _ranges[0];
+        }
+
+        public bool includes(Range range)
+        {
+            foreach (Range r in this)
+            {
+                if (r.includes(range))
+                {
+                    return true;
+                }
+            }
+
+            return false;
+        }
+
+        public bool includes(int n)
+        {
+            foreach (Range r in this)
+            {
+                if (r.includes(n))
+                {
+                    return true;
+                }
+            }
+
+            return false;
+        }
+
+        public void add(Range range)
+        {
+            for (int i = 0; i < _ranges.Count; i++)
+            {
+                Range r = _ranges[i];
+                if (range.touches(r))
+                {
+                    _ranges.Remove(r);
+                    range = range.span(r);
+                }
+                else if (Serial.lt(range.Upper, r.Lower))
+                {
+                    _ranges.Insert(i - 1 , range);
+                    return;
+                }
+            }
+            _ranges.Add(range);
+        }
+
+        public void add(int lower, int upper)
+        {
+            add(new Range(lower, upper));
+        }
+
+        public void add(int value)
+        {
+            add(value, value);
+        }
+
+        public void clear()
+        {
+            _ranges.Clear();
+        }
+
+        public RangeSet copy()
+        {
+            RangeSet copy = new RangeSet();
+            foreach (Range r in _ranges)
+            {
+                copy._ranges.Add(r);
+            }
+            return copy;
+        }
+
+        public String toString()
+        {
+            StringBuilder str = new StringBuilder();
+            str.Append("{");
+            bool first = true;
+            foreach (Range range in _ranges)
+            {
+                if (first)
+                {
+                    first = false;
+                }
+                else
+                {
+                    str.Append(", ");
+                }
+                str.Append(range);
+            }
+            str.Append("}");
+            return str.ToString();
+        }
+    }
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/ReceivedPayload.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/ReceivedPayload.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/ReceivedPayload.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/ReceivedPayload.cs Thu Dec  3 22:03:51 2009
@@ -1,43 +1,43 @@
-/*
-*
-* 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;
-
-namespace org.apache.qpid.transport
-{
-    public class ReceivedPayload<T> : EventArgs
-    {
-        public ReceivedPayload()
-        {
-        }  
-
-        public ReceivedPayload(T payload)
-        {
-            m_payload = payload;
-        }  
-        private T m_payload;
-
-        public T Payload
-        {
-            get { return m_payload; }
-            set { m_payload = value; }
-        }
-    }
-}
+/*
+*
+* 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;
+
+namespace org.apache.qpid.transport
+{
+    public class ReceivedPayload<T> : EventArgs
+    {
+        public ReceivedPayload()
+        {
+        }  
+
+        public ReceivedPayload(T payload)
+        {
+            m_payload = payload;
+        }  
+        private T m_payload;
+
+        public T Payload
+        {
+            get { return m_payload; }
+            set { m_payload = value; }
+        }
+    }
+}

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Receiver.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Receiver.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Receiver.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Receiver.cs Thu Dec  3 22:03:51 2009
@@ -1,38 +1,38 @@
-/*
-*
-* 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;
-
-namespace org.apache.qpid.transport
-{		
-	/// <summary> 
-    /// a receiver will raise an event when:
-    /// - data is received 
-    /// - an exception is thrown 
-    /// - it is closed 
-	/// </summary>
-	public interface Receiver <T> where T : EventArgs
-	{
-        event EventHandler<T> Received;
-        event EventHandler<ExceptionArgs> Exception;		
-	    event EventHandler Closed;		
-	}
+/*
+*
+* 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;
+
+namespace org.apache.qpid.transport
+{		
+	/// <summary> 
+    /// a receiver will raise an event when:
+    /// - data is received 
+    /// - an exception is thrown 
+    /// - it is closed 
+	/// </summary>
+	public interface Receiver <T> where T : EventArgs
+	{
+        event EventHandler<T> Received;
+        event EventHandler<ExceptionArgs> Exception;		
+	    event EventHandler Closed;		
+	}
 }
\ No newline at end of file

Modified: qpid/trunk/qpid/dotnet/client-010/client/transport/Sender.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/client/transport/Sender.cs?rev=886940&r1=886939&r2=886940&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/client/transport/Sender.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/client/transport/Sender.cs Thu Dec  3 22:03:51 2009
@@ -1,32 +1,32 @@
-/*
-*
-* 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.
-*
-*/
-namespace org.apache.qpid.transport
-{
-    /// <summary> 
-    /// Sender
-    /// </summary>
-    public interface Sender<T>
-    {
-        void send(T msg);
-        void flush();
-        void 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.
+*
+*/
+namespace org.apache.qpid.transport
+{
+    /// <summary> 
+    /// Sender
+    /// </summary>
+    public interface Sender<T>
+    {
+        void send(T msg);
+        void flush();
+        void close();
+    }
 }
\ No newline at end of file



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message