Creates an LBM context.

C# |
public class LBMContext : IDisposable

All Members | Constructors | Methods | |||
Icon | Member | Description |
---|---|---|
![]() | LBMContext()()() |
Instantiate an LBMContext object using default attributes.
|
![]() | LBMContext(LBMContextAttributes) |
Instantiate an LBMContext object using given attributes.
|
![]() | addImmediateMessageReceiver(LBMImmediateMessageCallback) |
Register a callback for handling of non-topic immediate messages
|
![]() | addImmediateMessageReceiver(LBMImmediateMessageCallback, Object) |
Register a callback for handling of non-topic immediate messages
|
![]() | addSourceNotifyCallback(LBMSourceNotification) |
Register a callback interface to be
called when a new source is seen for any topic.
|
![]() | addSourceNotifyCallback(LBMSourceNotification, Object) |
Register a callback interface (and a callback handle argument) to be
called when a new source is seen for any topic.
|
![]() | allocTopic(String) |
Create an LBMTopic object (useable for an LBM source)
for given topic name and attributes.
Topic strings should be limited in length to 246 characters (not including
the final null).
|
![]() | allocTopic(String, LBMSourceAttributes) |
Create an LBMTopic object (useable for an LBM source)
for given topic name and attributes.
Topic strings should be limited in length to 246 characters (not including
the final null).
|
![]() | close()()() |
Close and dispose of this context.
Warning: It is not safe to call this method from a context thread callback. |
![]() | createHotFailoverReceiver(LBMTopic) | Obsolete.
Create an LBM Hot-Failover Receiver object associated with this context
and a given topic.
|
![]() | createHotFailoverReceiver(LBMTopic, LBMEventQueue) | Obsolete.
Create an LBM Hot-Failover Receiver object associated with this context
and a given topic and event queue.
|
![]() | createHotFailoverReceiver(LBMTopic, LBMReceiverCallback, Object) |
Create an LBM Hot-Failover Receiver object associated with this context
and a given topic.
|
![]() | createHotFailoverReceiver(LBMTopic, LBMReceiverCallback, Object, LBMEventQueue) |
Create an LBM Hot-Failover Receiver object associated with this context
and a given topic and event queue.
|
![]() | createHotFailoverSource(LBMTopic) |
Create an LBM Hot-Failover Source object associated with this context and a given topic.
|
![]() | createHotFailoverSource(LBMTopic, LBMSourceEventCallback, Object) |
Create an LBM Hot-Failover Source object associated with this context
and a given topic.
|
![]() | createHotFailoverSource(LBMTopic, LBMEventQueue) |
Create an LBM Hot-Failover Source object associated with this given context
and a given topic and event queue.
|
![]() | createHotFailoverSource(LBMTopic, LBMSourceEventCallback, Object, LBMEventQueue) |
Create an LBM Hot-Failover Source object associated with this context
and a given topic and event queue.
|
![]() | createReceiver(LBMTopic) | Obsolete.
Create an LBM Receiver object associated with this context
and a given topic.
|
![]() | createReceiver(LBMTopic, LBMEventQueue) | Obsolete.
Create an LBM Receiver object associated with this context
and a given topic and event queue.
|
![]() | createReceiver(LBMTopic, LBMReceiverCallback, Object) |
Create an LBM Receiver object associated with this context
and a given topic.
|
![]() | createReceiver(LBMTopic, LBMReceiverCallback, Object, LBMEventQueue) |
Create an LBM Receiver object associated with this context
and a given topic and event queue.
|
![]() | createSource(LBMTopic) |
Create an LBM Source object associated with this context and a given topic.
|
![]() | createSource(LBMTopic, LBMSourceEventCallback, Object) |
Create an LBM Source object associated with this context
and a given topic.
|
![]() | createSource(LBMTopic, LBMEventQueue) |
Create an LBM Source object associated with this given context
and a given topic and event queue.
|
![]() | createSource(LBMTopic, LBMSourceEventCallback, Object, LBMEventQueue) |
Create an LBM Source object associated with this context
and a given topic and event queue.
|
![]() | createTimer(Int64) |
Create an LBM Timer object
|
![]() | createTimer(Int64, LBMEventQueue) |
Creates a timer associated with this context and a specified event queue
that expires with a specified delay.
|
![]() | createTimer(Int64, LBMTimerCallback, Object) |
Creates a timer associated with this context that expires with
specified delay.
|
![]() | createTimer(Int64, LBMTimerCallback, Object, LBMEventQueue) |
Creates a timer associated with this context and a specified event queue
that expires with a specified delay.
|
![]() | Dispose()()() |
Same as close()()() |
![]() | dumpAttributeList()()() |
Returns an array of context attributes in LBConfigOption
|
![]() | enableImmediateMessageReceiver()()() |
Enable LBM to receive non-topic immediate messages.
|
![]() | enableImmediateMessageReceiver(LBMEventQueue) |
Enable LBM to receive non-topic immediate messages (using an event
queue).
|
![]() | Finalize()()() |
LBMContext class finalization
(Overrides Object.Finalize()()().) |
![]() | getAttributeValue(String) |
Returns the value of a context-related attribute for this context.
|
![]() | getImmediateMessageReceiverStatistics(Int32) |
Return the immediate message source statistics for this context.
|
![]() | getImmediateMessageSourceStatistics(Int32) |
Return the immediate message source statistics for this context.
|
![]() | getReceiverStatistics(Int32) |
Return the aggregate set of receiver transport statistics for this context
|
![]() | getSourceStatistics(Int32) |
Return the aggregate set of source transport statistics for this context
|
![]() | getStatistics()()() |
Return the current set of statistics for this context
|
![]() | getUMQInflight(String) | Get the current UMQ inflight value for this context |
![]() | lookupTopic(String) |
Create an LBMTopic object (useable for an LBM receiver) for a given topic name.
Topic strings should be limited in length to 246 characters (not including
the final null).
|
![]() | lookupTopic(String, LBMReceiverAttributes) |
Create an LBMTopic object (useable for an LBM receiver)
for given topic name and attributes.
Topic strings should be limited in length to 246 characters (not including
the final null).
|
![]() | processEvents(Int64) |
Process internal events in the given LBM context object.
|
![]() | removeImmediateMessageReceiver(LBMImmediateMessageCallback) |
Deregister a non-topic, immediate message callback
|
![]() | removeImmediateMessageReceiver(LBMImmediateMessageCallback, Object) |
Deregister a non-topic, immediate message callback
|
![]() | removeSourceNotifyCallback(LBMSourceNotification) |
Deregister a source notification callback
|
![]() | removeSourceNotifyCallback(LBMSourceNotification, Object) |
Deregister a source notification callback
|
![]() | requestTopicResolution(UInt16, UInt32, UInt32) |
Request Topic Advertisements (sources), Topic Queries (receivers),
and/or Wildcard Topic Queries (wildcard receivers) in the configured topic
resolution address domain.
|
![]() | resetImmediateMessageReceiverStatistics()()() |
Reset the immediate message receiver transport statistics for this context.
|
![]() | resetImmediateMessageSourceStatistics()()() |
This will reset the immediate message source transport statistics for this context.
|
![]() | resetReceiverStatistics()()() |
This will reset the transport stats for all receivers in this context.
|
![]() | resetSourceStatistics()()() |
This will reset the transport statistics for all sources in this context.
|
![]() | resetStatistics()()() |
This will reset the statistics for this context at the c layer.
Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function. |
![]() | scheduleTimer(Int64) |
Create an LBM Timer object and retains an internal reference to it.
This prevents the timer from being reclaimed by the garbage collector before it expires.
|
![]() | scheduleTimer(Int64, LBMEventQueue) |
Creates a timer associated with this context and a specified event queue
that expires with a specified delay, and retains an internal reference to it.
This prevents the timer from being reclaimed by the garbage collector before it expires.
|
![]() | scheduleTimer(Int64, LBMTimerCallback, Object) |
Creates a timer associated with this context that expires with
specified delay, and retains an internal reference to it.
This prevents the timer from being reclaimed by the garbage collector before it expires.
|
![]() | scheduleTimer(Int64, LBMTimerCallback, Object, LBMEventQueue) |
Creates a timer associated with this context and a specified event queue
that expires with a specified delay.
This prevents the timer from being reclaimed by the garbage collector before it expires.
|
![]() | send(String, String, array<Byte>[]()[], Int32, Int32) |
Send a unicast immediate message to a specific topic
|
![]() | send(String, String, LBMRequest, LBMEventQueue, Int32) |
Send a unicast immediate request to a specific topic (specifying an
Event Queue for processing of the response(s))
|
![]() | send(String, String, LBMRequest, Int32) |
Send a unicast immediate request to a specific topic
|
![]() | send(String, array<Byte>[]()[], Int32, Int32) |
Send a multicast immediate message to a specific topic
|
![]() | send(String, LBMRequest, LBMEventQueue, Int32) |
Send a multicast immediate request to a specific topic (specifying an
Event Queue for processing of the response(s))
|
![]() | send(String, LBMRequest, Int32) |
Send a multicast immediate request to a specific topic
|
![]() | send(String, String, array<Byte>[]()[], Int32, Int32, LBMSourceSendExInfo) |
Send a multicast immediate message on a specific topic to a queue. (UMQ only)
|
![]() | sendc(array<Char>[]()[], array<Char>[]()[], array<Byte>[]()[], Int32, Int32) |
Send a unicast immediate message to a specific topic
|
![]() | sendc(array<Char>[]()[], array<Byte>[]()[], Int32, Int32) |
Send a multicast immediate message to a specific topic
|
![]() | sendTopicless(String, array<Byte>[]()[], Int32, Int32) |
Send a topicless unicast immediate message
|
![]() | sendTopicless(array<Char>[]()[], array<Byte>[]()[], Int32, Int32) |
Send a topicless unicast immediate message
|
![]() | sendTopicless(array<Byte>[]()[], Int32, Int32) |
Send a topicless multicast immediate message
|
![]() | setAttributeValue(String, String) |
Set the value of a context-related attribute for this context.
|
![]() | setUMQInflight(String, LBMSetInflightCallback, Object) | Set the current UMQ inflight value for this context |
![]() | setUMQMessageStable(String, UMQMessageId) | Mark a specific msg_id as stable, triggering an event if configured to do so, and adjusting the inflight if necessary |
![]() | unblockProcessEvents()()() |
Unblock processEvents call.
|

This creates an instance of the LBM main processing element, an LBM context.
Sources and Receivers are created from an LBM context and work within that
context. For the Embedded operational mode, a thread is spawned to handle
message processing.

Object | |
![]() | LBMContext |