Class SessionExecutor
- Namespace
- Apache.NMS.ActiveMQ
- Assembly
- Apache.NMS.ActiveMQ.dll
public class SessionExecutor : Task
- Inheritance
-
SessionExecutor
- Implements
-
- Inherited Members
-
Constructors
SessionExecutor(Session, IDictionary)
public SessionExecutor(Session session, IDictionary consumers)
Parameters
session
Session
consumers
IDictionary
Properties
Empty
public bool Empty { get; }
Property Value
- bool
HasUncomsumedMessages
public bool HasUncomsumedMessages { get; }
Property Value
- bool
Running
public bool Running { get; }
Property Value
- bool
UnconsumedMessages
public MessageDispatch[] UnconsumedMessages { get; }
Property Value
- MessageDispatch[]
Methods
Clear()
ClearMessagesInProgress()
public void ClearMessagesInProgress()
Close()
Dispatch(MessageDispatch)
public void Dispatch(MessageDispatch dispatch)
Parameters
dispatch
MessageDispatch
Execute(MessageDispatch)
public void Execute(MessageDispatch dispatch)
Parameters
dispatch
MessageDispatch
ExecuteFirst(MessageDispatch)
public void ExecuteFirst(MessageDispatch dispatch)
Parameters
dispatch
MessageDispatch
~SessionExecutor()
protected ~SessionExecutor()
Iterate()
Returns
- bool
Start()
Stop()
Stop(TimeSpan)
public void Stop(TimeSpan timeout)
Parameters
timeout
TimeSpan
Wakeup()