src/main/csharp/Destination.cs

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

using System;
using System.Text;
using ZeroMQ;

namespace Apache.NMS.ZMQ
{
	/// <summary>
	/// Summary description for Destination.
	/// </summary>
	public abstract class Destination : IDestination
	{
		protected Session session;
		/// <summary>
		/// Socket object
		/// </summary>
		protected ZmqSocket producerEndpoint = null;
		protected ZmqSocket consumerEndpoint = null;
		protected string destinationName;

		/// <summary>
		/// Construct the Destination with a defined physical name.
		/// </summary>
		/// <param name="name"></param>
		protected Destination(Session session, string destName)
		{
			this.session = session;
			this.destinationName = destName;
		}

		~Destination()
		{
			// TODO: Implement IDisposable pattern
			if(null != this.producerEndpoint)
			{
				this.session.Connection.ReleaseProducer(this.producerEndpoint);
				this.producerEndpoint = null;
			}

			if(null != this.consumerEndpoint)
			{
				this.session.Connection.ReleaseConsumer(this.consumerEndpoint);
				this.consumerEndpoint = null;
			}
		}

		public string Name
		{
			get { return this.destinationName; }
		}

		public bool IsTopic
		{
			get
			{
				return DestinationType == DestinationType.Topic
					|| DestinationType == DestinationType.TemporaryTopic;
			}
		}

		public bool IsQueue
		{
			get
			{
				return DestinationType == DestinationType.Queue
					|| DestinationType == DestinationType.TemporaryQueue;
			}
		}

		public bool IsTemporary
		{
			get
			{
				return DestinationType == DestinationType.TemporaryQueue
					|| DestinationType == DestinationType.TemporaryTopic;
			}
		}

		/// <summary>
		/// </summary>
		/// <returns>string representation of this instance</returns>
		public override string ToString()
		{
			return MakeUriString(this.destinationName);
		}

		private string MakeUriString(string destName)
		{
			switch(DestinationType)
			{
			case DestinationType.Topic:
				return "topic://" + destName;

			case DestinationType.TemporaryTopic:
				return "temp-topic://" + destName;

			case DestinationType.TemporaryQueue:
				return "temp-queue://" + destName;

			default:
				return "queue://" + destName;
			}
		}

		/// <summary>
		/// hashCode for this instance
		/// </summary>
		/// <returns></returns>
		public override int GetHashCode()
		{
			int answer = 37;

			answer = this.Name.GetHashCode();

			if(IsTopic)
			{
				answer ^= 0xfabfab;
			}

			return answer;
		}

		/// <summary>
		/// if the object passed in is equivalent, return true
		/// </summary>
		/// <param name="obj">the object to compare</param>
		/// <returns>true if this instance and obj are equivalent</returns>
		public override bool Equals(Object obj)
		{
			bool result = (this == obj);

			if(!result && obj != null && obj is Destination)
			{
				Destination other = (Destination) obj;
				result = (this.DestinationType == other.DestinationType
							&& this.Name.Equals(other.Name));
			}

			return result;
		}

		public abstract DestinationType DestinationType
		{
			get;
		}

		internal int Send(byte[] buffer, TimeSpan timeout)
		{
			if(null == this.producerEndpoint)
			{
				this.producerEndpoint = this.session.Connection.GetProducer();
			}

			return this.producerEndpoint.Send(buffer, buffer.Length, SocketFlags.None, timeout);
		}

		internal string Receive(Encoding encoding, TimeSpan timeout)
		{
			if(null == this.consumerEndpoint)
			{
				this.consumerEndpoint = this.session.Connection.GetConsumer(encoding, this.destinationName);
			}

			return consumerEndpoint.Receive(encoding, timeout);
		}

		internal Frame ReceiveFrame()
		{
			// TODO: Implement
			return null;
		}

		internal ZmqMessage ReceiveMessage()
		{
			// TODO: Implement
			return null;
		}
	}
}