Get it to compile after refactor

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383071 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-03-04 08:18:50 +00:00
parent 1701ac7fa5
commit fcbb2b22e8
26 changed files with 265 additions and 262 deletions

View File

@ -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

View File

@ -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

View File

@ -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!") {
}
}
}
}

View File

@ -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

View File

@ -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!") {
}
}
}
}

View File

@ -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 @@ namespace OpenWire.Client {
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);
}
}

View File

@ -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;
}
}
}

View File

@ -15,9 +15,8 @@
* limitations under the License.
*/
using System;
using OpenWire.Client.Commands;
namespace OpenWire.Client
namespace ActiveMQ
{
public enum AcknowledgementMode

View File

@ -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 @@ namespace OpenWire.Client {
/// Creates a new connection with the given user name and password
/// </summary>
IConnection CreateConnection(string userName, string password);
}
}
}

View File

@ -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 {
}
}
}

View File

@ -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;
}
}
}

View File

@ -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

View File

@ -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);

View File

@ -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 @@ namespace OpenWire.Client {
/// <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;
}
}
}
}

View File

@ -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);
}
}

View File

@ -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;
}
}
}

View File

@ -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.

View File

@ -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();
}
}

View File

@ -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 {
}
}
}

View File

@ -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 {
}
}
}

View File

@ -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

View File

@ -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;
}
}
}

View File

@ -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
{

View File

@ -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

View File

@ -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) {
}
}
}
}

View File

@ -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