You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/04 09:18:53 UTC
svn commit: r383071 - /incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/
Author: chirino
Date: Sat Mar 4 00:18:50 2006
New Revision: 383071
URL: http://svn.apache.org/viewcvs?rev=383071&view=rev
Log:
Get it to compile after refactor
Modified:
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IBytesMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnection.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnectionFactory.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IDestination.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMapMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageConsumer.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageProducer.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IPrimitiveMap.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IQueue.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ISession.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IStartable.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryQueue.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryTopic.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITextMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITopic.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWireException.cs
incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs Sat Mar 4 00:18:50 2006
@@ -16,10 +16,11 @@
*/
using System;
using System.Collections;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
{
/// <summary>
/// Exception thrown when the broker returns an error
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs Sat Mar 4 00:18:50 2006
@@ -1,10 +1,11 @@
using System;
using System.Collections;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
using System.Threading;
-namespace OpenWire.Client
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
{
/// <summary>
/// Represents a connection with a message broker
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs Sat Mar 4 00:18:50 2006
@@ -16,15 +16,17 @@
*/
using System;
using System.Collections;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client {
- /// <summary>
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
+{
+ /// <summary>
/// Exception thrown when a connection is used that it already closed
/// </summary>
public class ConnectionClosedException : OpenWireException {
public ConnectionClosedException() : base("The connection is already closed!") {
}
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs Sat Mar 4 00:18:50 2006
@@ -16,10 +16,11 @@
*/
using System;
using System.Collections;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
{
/// <summary>
/// Represents a connection with a message broker
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs Sat Mar 4 00:18:50 2006
@@ -16,15 +16,17 @@
*/
using System;
using System.Collections;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client {
- /// <summary>
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
+{
+ /// <summary>
/// Exception thrown when a consumer is used that it already closed
/// </summary>
public class ConsumerClosedException : OpenWireException {
public ConsumerClosedException() : base("The consumer is already closed!") {
}
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs Sat Mar 4 00:18:50 2006
@@ -15,11 +15,13 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client {
- /// <summary>
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
+{
+ /// <summary>
/// Summary description for DestinationFilter.
/// </summary>
public abstract class DestinationFilter {
@@ -27,9 +29,9 @@
public const String ANY_CHILD = "*";
public bool matches(ActiveMQMessage message) {
- return matches(message.Destination);
+ return matches(message.Destination);
}
- public abstract bool matches(ActiveMQDestination destination);
- }
+ public abstract bool matches(ActiveMQDestination destination);
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IBytesMessage.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IBytesMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IBytesMessage.cs Sat Mar 4 00:18:50 2006
@@ -1,34 +1,33 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed 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 OpenWire.Client.Commands;
-
-namespace OpenWire.Client
-{
- /// <summary>
- /// Represents a binary based message
- /// </summary>
- public interface IBytesMessage : IMessage
- {
-
- byte[] Content
- {
- get;
- set;
- }
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ
+{
+ /// <summary>
+ /// Represents a binary based message
+ /// </summary>
+ public interface IBytesMessage : IMessage
+ {
+
+ byte[] Content
+ {
+ get;
+ set;
+ }
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnection.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnection.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnection.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnection.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,8 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client
+namespace ActiveMQ
{
public enum AcknowledgementMode
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnectionFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnectionFactory.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnectionFactory.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IConnectionFactory.cs Sat Mar 4 00:18:50 2006
@@ -15,10 +15,10 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-
-namespace OpenWire.Client {
+namespace ActiveMQ
+{
+
/// <summary>
/// A Factory of IConnection objects
/// </summary>
@@ -33,5 +33,5 @@
/// Creates a new connection with the given user name and password
/// </summary>
IConnection CreateConnection(string userName, string password);
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IDestination.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IDestination.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IDestination.cs Sat Mar 4 00:18:50 2006
@@ -15,12 +15,12 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client {
- /// <summary>
+namespace ActiveMQ
+{
+ /// <summary>
/// Summary description for Destination.
/// </summary>
public interface IDestination {
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMapMessage.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMapMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMapMessage.cs Sat Mar 4 00:18:50 2006
@@ -1,33 +1,32 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed 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 OpenWire.Client.Commands;
-
-namespace OpenWire.Client
-{
- /// <summary>
- /// Represents a Map message which contains key and value pairs which are
- /// of primitive types
- /// </summary>
- public interface IMapMessage : IMessage
- {
- IPrimitiveMap Body {
- get;
- }
- }
-}
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ
+{
+ /// <summary>
+ /// Represents a Map message which contains key and value pairs which are
+ /// of primitive types
+ /// </summary>
+ public interface IMapMessage : IMessage
+ {
+ IPrimitiveMap Body {
+ get;
+ }
+ }
+}
+
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessage.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessage.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,8 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client
+namespace ActiveMQ
{
/// <summary>
/// Represents a message either to be sent to a message broker or received from a message broker
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageConsumer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageConsumer.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageConsumer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageConsumer.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,8 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client
+namespace ActiveMQ
{
public delegate void MessageListener(IMessage message);
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageProducer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageProducer.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageProducer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IMessageProducer.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,9 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client {
+namespace ActiveMQ
+{
/// <summary>
/// An object capable of sending messages to some destination
/// </summary>
@@ -31,37 +31,37 @@
/// <summary>
/// Sends the message to the given destination
/// </summary>
- void Send(IDestination destination, IMessage message);
+ void Send(IDestination destination, IMessage message);
bool Persistent
{
get;
- set;
+ set;
}
long TimeToLive
{
get;
- set;
+ set;
}
int Priority
{
get;
- set;
+ set;
}
bool DisableMessageID
{
get;
- set;
+ set;
}
bool DisableMessageTimestamp
{
get;
- set;
+ set;
}
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IPrimitiveMap.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IPrimitiveMap.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IPrimitiveMap.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IPrimitiveMap.cs Sat Mar 4 00:18:50 2006
@@ -1,86 +1,84 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed 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 OpenWire.Client.Commands;
-
-namespace OpenWire.Client
-{
- /// <summary>
- /// Represents a Map of primitive types where the keys are all string instances
- /// and the values are strings or numbers.
- /// </summary>
- public interface IPrimitiveMap
- {
-
- void Clear();
-
- bool Contains(object key);
-
- void Remove(object key);
-
- int Count
- {
- get;
- }
-
- ICollection Keys
- {
- get;
- }
-
- ICollection Values
- {
- get;
- }
-
- object this[string key]
- {
- get;
- set;
- }
-
- string GetString(string key);
- void SetString(string key, string value);
-
- bool GetBool(string key);
- void SetByte(string key, bool value);
-
- byte GetByte(string key);
- void SetByte(string key, byte value);
-
- char GetChar(string key);
- void SetChar(string key, char value);
-
- short GetShort(string key);
- void SetShort(string key, short value);
-
- int GetInt(string key);
- void SetInt(string key, int value);
-
- long GetLong(string key);
- void SetLong(string key, long value);
-
- float GetFloat(string key);
- void SetFloat(string key, float value);
-
- double GetDouble(string key);
- void SetDouble(string key, double value);
-
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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;
+
+namespace ActiveMQ
+{
+ /// <summary>
+ /// Represents a Map of primitive types where the keys are all string instances
+ /// and the values are strings or numbers.
+ /// </summary>
+ public interface IPrimitiveMap
+ {
+
+ void Clear();
+
+ bool Contains(object key);
+
+ void Remove(object key);
+
+ int Count
+ {
+ get;
+ }
+
+ ICollection Keys
+ {
+ get;
+ }
+
+ ICollection Values
+ {
+ get;
+ }
+
+ object this[string key]
+ {
+ get;
+ set;
+ }
+
+ string GetString(string key);
+ void SetString(string key, string value);
+
+ bool GetBool(string key);
+ void SetByte(string key, bool value);
+
+ byte GetByte(string key);
+ void SetByte(string key, byte value);
+
+ char GetChar(string key);
+ void SetChar(string key, char value);
+
+ short GetShort(string key);
+ void SetShort(string key, short value);
+
+ int GetInt(string key);
+ void SetInt(string key, int value);
+
+ long GetLong(string key);
+ void SetLong(string key, long value);
+
+ float GetFloat(string key);
+ void SetFloat(string key, float value);
+
+ double GetDouble(string key);
+ void SetDouble(string key, double value);
+
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IQueue.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IQueue.cs Sat Mar 4 00:18:50 2006
@@ -15,16 +15,16 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client {
- /// <summary>
+namespace ActiveMQ
+{
+ /// <summary>
/// Summary description for IQueue.
/// </summary>
public interface IQueue : IDestination {
String QueueName {
- get;
- }
- }
+ get;
+ }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ISession.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ISession.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ISession.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ISession.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,8 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client
+namespace ActiveMQ
{
/// <summary>
/// Represents a single unit of work on an IConnection.
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IStartable.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IStartable.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IStartable.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/IStartable.cs Sat Mar 4 00:18:50 2006
@@ -1,23 +1,23 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed 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 OpenWire.Client
-{
- public interface IStartable
- {
- void Start();
- }
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ
+{
+ public interface IStartable
+ {
+ void Start();
+ }
+}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryQueue.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryQueue.cs Sat Mar 4 00:18:50 2006
@@ -15,12 +15,12 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client {
- /// <summary>
+namespace ActiveMQ
+{
+ /// <summary>
/// Summary description for ITemporaryQueue.
/// </summary>
public interface ITemporaryQueue : IDestination {
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryTopic.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryTopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITemporaryTopic.cs Sat Mar 4 00:18:50 2006
@@ -15,12 +15,12 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client {
- /// <summary>
+namespace ActiveMQ
+{
+ /// <summary>
/// Summary description for TemporaryTopic.
/// </summary>
public interface ITemporaryTopic : IDestination {
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITextMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITextMessage.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITextMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITextMessage.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,8 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client
+namespace ActiveMQ
{
/// <summary>
/// Represents a text based message
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITopic.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ITopic.cs Sat Mar 4 00:18:50 2006
@@ -15,16 +15,16 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client {
- /// <summary>
+namespace ActiveMQ
+{
+ /// <summary>
/// Summary description for ITopic.
/// </summary>
public interface ITopic : IDestination {
String TopicName {
- get;
- }
- }
+ get;
+ }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs Sat Mar 4 00:18:50 2006
@@ -17,10 +17,11 @@
using System;
using System.Collections;
using System.Threading;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
{
public enum AckType
{
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs Sat Mar 4 00:18:50 2006
@@ -15,9 +15,11 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-namespace OpenWire.Client
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
{
/// <summary>
/// An object capable of sending messages to some destination
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWireException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWireException.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWireException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWireException.cs Sat Mar 4 00:18:50 2006
@@ -16,15 +16,14 @@
*/
using System;
using System.Collections;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-namespace OpenWire.Client {
- /// <summary>
+namespace ActiveMQ
+{
+ /// <summary>
/// Represents an OpenWire exception
/// </summary>
public class OpenWireException : Exception {
public OpenWireException(string message) : base(message) {
}
- }
+ }
}
Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs?rev=383071&r1=383070&r2=383071&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs Sat Mar 4 00:18:50 2006
@@ -15,11 +15,12 @@
* limitations under the License.
*/
using System;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
using System.Collections;
-namespace OpenWire.Client
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.Commands;
+
+namespace ActiveMQ
{
/// <summary>
/// Default provider of ISession