Class Dispatcher
Handles the multi-threaded dispatching between the transport and the consumers
Inheritance
System.Object
    Dispatcher
  Inherited Members
      System.Object.Equals(System.Object)
    
    
      System.Object.Equals(System.Object, System.Object)
    
    
      System.Object.GetHashCode()
    
    
      System.Object.GetType()
    
    
      System.Object.MemberwiseClone()
    
    
      System.Object.ReferenceEquals(System.Object, System.Object)
    
    
      System.Object.ToString()
    
  Namespace: ActiveMQ
Assembly: Apache.NMS.ActiveMQ.dll
Syntax
public class DispatcherMethods
| Improve this Doc View SourceDequeue()
Method Dequeue
Declaration
public IMessage Dequeue()Returns
| Type | Description | 
|---|---|
| Apache.NMS.IMessage | 
Dequeue(TimeSpan)
Method Dequeue
Declaration
public IMessage Dequeue(TimeSpan timeout)Parameters
| Type | Name | Description | 
|---|---|---|
| System.TimeSpan | timeout | 
Returns
| Type | Description | 
|---|---|
| Apache.NMS.IMessage | 
DequeueNoWait()
Method DequeueNoWait
Declaration
public IMessage DequeueNoWait()Returns
| Type | Description | 
|---|---|
| Apache.NMS.IMessage | 
Enqueue(ActiveMQMessage)
Method Enqueue
Declaration
public void Enqueue(ActiveMQMessage message)Parameters
| Type | Name | Description | 
|---|---|---|
| ActiveMQMessage | message | 
PulseSemaphore()
Declaration
protected void PulseSemaphore()Redeliver(ActiveMQMessage)
Redeliver the given message, putting it at the head of the queue
Declaration
public void Redeliver(ActiveMQMessage message)Parameters
| Type | Name | Description | 
|---|---|---|
| ActiveMQMessage | message | 
RedeliverRolledBackMessages()
Whem we start a transaction we must redeliver any rolled back messages
Declaration
public void RedeliverRolledBackMessages()SetAsyncDelivery(AutoResetEvent)
Declaration
public void SetAsyncDelivery(AutoResetEvent eventHandle)Parameters
| Type | Name | Description | 
|---|---|---|
| System.Threading.AutoResetEvent | eventHandle |