LBM Receiver class.

C# |
public class LBMReceiver : IDisposable

All Members | Constructors | Methods | |||
Icon | Member | Description |
---|---|---|
![]() | LBMReceiver(LBMContext, LBMTopic) |
Instantiate an LBM Receiver object associated with a given context and topic.
|
![]() | LBMReceiver(LBMContext, LBMTopic, LBMEventQueue) |
Instantiate an LBM Receiver object associated with a given context,
topic, and event queue
|
![]() | LBMReceiver(LBMContext, LBMTopic, LBMReceiverCallback, Object) |
Instantiate an LBM Receiver object associated with a given context
and topic, with an initial receiver callback and callback object set.
|
![]() | LBMReceiver(LBMContext, LBMTopic, LBMReceiverCallback, Object, LBMEventQueue) |
Instantiate an LBM Receiver object associated with a given context,
topic, and event queue, with an initial receiver callback and callback object set.
|
![]() | addReceiver(LBMReceiverCallback) |
Register a receiver callback
|
![]() | addReceiver(LBMReceiverCallback, Object) |
Register a receiver callback
|
![]() | close()()() |
Close and dispose of this receiver
|
![]() | deregister()()() | Deregister from all queues. |
![]() | deregister(String) | Deregister from a single queue, specified by name. |
![]() | Dispose()()() |
Same as close()()() |
![]() | dumpAttributeList()()() |
Dump source configuration options
|
![]() | Finalize()()() |
LBMReceiver finalization
(Overrides Object.Finalize()()().) |
![]() | getAttributeValue(String) |
Returns the value of a receiver-related attribute for this receiver
|
![]() | getStatistics(String) |
Return the current set of receiver transport statistics for a particular source
|
![]() | getStatistics(Int32) |
Return the current set of receiver transport statistics for all sources
|
![]() | indexRelease(String, UMQIndexInfo) | Instruct the given UMQ queue(s) to release the given UMQ index that is assigned to the given receiver. |
![]() | indexStartAssignment(String) | Starts this receiver's eligibility for new index assignments from a queue. |
![]() | indexStopAssignment(String) | Stops this receiver's eligibility for new index assignments from a queue. |
![]() | receiverCount()()() |
Returns the number of receiver callbacks registered to this receiver
|
![]() | removeReceiver(LBMReceiverCallback) |
Deregister a receiver callback
|
![]() | removeReceiver(LBMReceiverCallback, Object) |
Deregister a receiver callback (and callback token)
|
![]() | resetStatistics(String) |
Reset the current set of receiver transport statistics for a particular source.
|
![]() | resetStatistics()()() |
Reset the receiver transport statistics for all sources.
|
![]() | setAttributeValue(String, String) |
Set the value of a receiver-related attribute for this receiver
|
![]() | subscribeChannel(Int64, LBMReceiverCallback, Object) |
Subscribe to the given channel, with an optional callback and token object.
The specified callback will be called to deliver messages sent with the
specified channel number. If null is specified for the callback, messages
sent with the specified channel number will be delivered to the receiver's
normal callback.
Only one callback may be registered for a given channel. If this method is called
twice with the same channel number, an error will result.
|
![]() | umederegister()()() | Deregister from all stores. |
![]() | unsubscribeChannel(Int64) | Discontinue an existing channel subscription. |

Warning: It is not safe to instantiate this class from a context thread callback.

Object | ||
![]() | LBMReceiver | |
![]() | LBMHotFailoverReceiver |