Class SimplePriorityMessageDispatchChannel
- Namespace
- Apache.NMS.ActiveMQ.Util
- Assembly
- Apache.NMS.ActiveMQ.dll
public class SimplePriorityMessageDispatchChannel : MessageDispatchChannel
- Inheritance
-
SimplePriorityMessageDispatchChannel
- Implements
-
- Inherited Members
-
Constructors
SimplePriorityMessageDispatchChannel()
public SimplePriorityMessageDispatchChannel()
Fields
MAX_PRIORITY
public const int MAX_PRIORITY = 10
Field Value
- int
Properties
Closed
public bool Closed { get; set; }
Property Value
- bool
Count
public long Count { get; }
Property Value
- long
Empty
public bool Empty { get; }
Property Value
- bool
Running
public bool Running { get; set; }
Property Value
- bool
SyncRoot
public object SyncRoot { get; }
Property Value
- object
Methods
Clear()
Close()
Dequeue(TimeSpan)
public MessageDispatch Dequeue(TimeSpan timeout)
Parameters
timeout
TimeSpan
Returns
- MessageDispatch
DequeueNoWait()
public MessageDispatch DequeueNoWait()
Returns
- MessageDispatch
Enqueue(MessageDispatch)
public void Enqueue(MessageDispatch dispatch)
Parameters
dispatch
MessageDispatch
EnqueueFirst(MessageDispatch)
public void EnqueueFirst(MessageDispatch dispatch)
Parameters
dispatch
MessageDispatch
GetList(MessageDispatch)
protected LinkedList<MessageDispatch> GetList(MessageDispatch md)
Parameters
md
MessageDispatch
Returns
- LinkedList<MessageDispatch>
GetPriority(MessageDispatch)
protected int GetPriority(MessageDispatch message)
Parameters
message
MessageDispatch
Returns
- int
Peek()
public MessageDispatch Peek()
Returns
- MessageDispatch
RemoveAll()
public MessageDispatch[] RemoveAll()
Returns
- MessageDispatch[]
Signal()
Start()
Stop()