using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.Serialization;
namespace IServiceOriented.ServiceBus
{
/// <summary>
/// Represents a listener endpoint.
/// </summary>
[DataContract]
public sealed class ListenerEndpoint : Endpoint
{
public ListenerEndpoint(string name, string configurationName, string address, Type contractType, Listener listener)
: this(Guid.NewGuid(), name, configurationName, address, contractType, listener, false, null)
{
}
public ListenerEndpoint(Guid id, string name, string configurationName, string address, Type contractType, Listener listener) : this(id, name, configurationName, address, contractType, listener, false, null)
{
}
public ListenerEndpoint(Guid id, string name, string configurationName, string address, Type contractType, Listener listener, bool transient, DateTime? expiration)
: base(id, name, configurationName, address, contractType, transient, expiration)
{
Listener = listener;
}
public ListenerEndpoint(string name, string configurationName, string address, string contractTypeName, Listener listener)
: this(Guid.NewGuid(), name, configurationName, address, contractTypeName, listener, false, null)
{
}
public ListenerEndpoint(Guid id, string name, string configurationName, string address, string contractTypeName, Listener listener)
: this(id, name, configurationName, address, contractTypeName, listener, false, null)
{
}
public ListenerEndpoint(Guid id, string name, string configurationName, string address, string contractTypeName, Listener listener, bool transient, DateTime? expiration)
: base(id, name, configurationName, address, contractTypeName, transient, expiration)
{
Listener = listener;
}
Listener _listener;
/// <summary>
/// The listener used by this endpoint
/// </summary>
/// <remarks>
/// Listeners cannot be shared by multiple endpoints.
/// </remarks>
[DataMember]
public Listener Listener
{
get
{
return _listener;
}
private set
{
if (value != null && value.Endpoint != null)
{
throw new InvalidOperationException("Endpoint is attached to another listener");
}
if (_listener != null)
{
_listener.Endpoint = null;
}
_listener = value;
if(value != null) value.Endpoint = this;
}
}
}
}
