IMessageQueueClient.cs

using System;

namespace ServiceStack.Messaging
{
	public interface IMessageQueueClient
		: IMessageProducer
	{
		/// <summary>
		/// Publish the specified message into the durable queue @queueName
		/// </summary>
		/// <param name="queueName"></param>
		/// <param name="messageBytes"></param>
		void Publish(string queueName, byte[] messageBytes);
		
		/// <summary>
		/// Publish the specified message into the transient queue @queueName
		/// </summary>
		/// <param name="queueName"></param>
		/// <param name="messageBytes"></param>
		void Notify(string queueName, byte[] messageBytes);

		/// <summary>
		/// Synchronous blocking get.
		/// </summary>
		/// <param name="queueName"></param>
		/// <param name="timeOut"></param>
		/// <returns></returns>
		byte[] Get(string queueName, TimeSpan? timeOut);
		
		/// <summary>
		/// Non blocking get message
		/// </summary>
		/// <param name="queueName"></param>
		/// <returns></returns>
		byte[] GetAsync(string queueName);

		/// <summary>
		/// Blocking wait for notifications on any of the supplied channels
		/// </summary>
		/// <param name="channelNames"></param>
		/// <returns></returns>
		string WaitForNotifyOnAny(params string[] channelNames);
	}
}