LBM Hot-Failover Source class.

C# |
public class LBMHotFailoverSource : LBMSource

All Members | Constructors | Methods | |||
Icon | Member | Description |
---|---|---|
![]() | LBMHotFailoverSource(LBMContext, LBMTopic) |
Instantiate an LBM Hot-Failover Source object associated with a given context
and topic.
|
![]() | LBMHotFailoverSource(LBMContext, LBMTopic, LBMSourceEventCallback, Object) |
Instantiate an LBM Hot-Failover Source object associated with a given context
and topic and initialize source event callback.
|
![]() | LBMHotFailoverSource(LBMContext, LBMTopic, LBMEventQueue) |
Instantiate an LBM Hot-Failover Source object associated with a given context,
topic, and event queue.
|
![]() | LBMHotFailoverSource(LBMContext, LBMTopic, LBMSourceEventCallback, Object, LBMEventQueue) |
Instantiate an LBM Hot-Failover Source object associated with a given context,
topic, and event queue and initialize source event callback.
|
![]() | addSourceCallback(LBMSourceEventCallback) |
Register a source event callback
(Inherited from LBMSource.) |
![]() | addSourceCallback(LBMSourceEventCallback, Object) |
Register a source event callback (and callback token)
(Inherited from LBMSource.) |
![]() | buffAcquire(IntPtr%, UInt32, Int32) |
Acquire a pointer to a buffer of the specified length, to be filled in and sent later.
Warning: this API is NOT thread safe between sources on the same transport session.
For thread safety, use the send(array<Byte>[]()[], Int32, Int32) api.
(Inherited from LBMSource.) |
![]() | buffsCancel()()() |
Cancels all outstanding (not yet completed) buffers previously acquired using buffAcquire(IntPtr%, UInt32, Int32)
or buffsCompleteAndAcquire(IntPtr%, UInt32, Int32). All such acquired but not completed buffers for this source (only)
will no longer be received by any receives.
(Inherited from LBMSource.) |
![]() | buffsComplete()()() |
Sends all buffers on a transport session that had ben previously acquired.
Warning: this API is NOT thread safe between sources on the same transport session.
(Inherited from LBMSource.) |
![]() | buffsCompleteAndAcquire(IntPtr%, UInt32, Int32) |
First sends all buffers on a transport session that had ben previously acquired, and
then acquires a pointer to a buffer of the specified length, to be filled in and sent later.
Warning: this API is NOT thread safe between sources on the same transport session.
(Inherited from LBMSource.) |
![]() | close()()() |
Close and dispose of this source
(Inherited from LBMSource.) |
![]() | createChannel(Int64) |
Create a channel object to send messages with the given channel number.
(Inherited from LBMSource.) |
![]() | deleteChannel(LBMSourceChannelInfo) |
Deletea channel object
(Inherited from LBMSource.) |
![]() | Dispose()()() |
Same as close()()() (Inherited from LBMSource.) |
![]() | dumpAttributeList()()() |
Dump source configuration options
(Inherited from LBMSource.) |
![]() | Finalize()()() |
LBMSource finalization
(Inherited from LBMSource.) |
![]() | flush()()() |
Send messages from both the explicit and implicit batches ASAP.
(Inherited from LBMSource.) |
![]() | getAttributeValue(String) |
Returns the value of a source-related attribute for this source
(Inherited from LBMSource.) |
![]() | getInflight(Int32) | Get the current inflight value for this source (Inherited from LBMSource.) |
![]() | getInflight(Int32, Int32%, UInt64%) |
Get the current inflight values for message and bytes.
(Inherited from LBMSource.) |
![]() | getStatistics()()() |
Return the current set of source transport statistics for this source
(Inherited from LBMSource.) |
![]() | isClosed()()() |
Check if a source has been closed
(Inherited from LBMSource.) |
![]() | removeSourceCallback(LBMSourceEventCallback) |
Deregister a source event callback
(Inherited from LBMSource.) |
![]() | removeSourceCallback(LBMSourceEventCallback, Object) |
Deregister a source event callback
(Inherited from LBMSource.) |
![]() | resetStatistics()()() |
This will reset the transport statistics for this source.
(Inherited from LBMSource.) |
![]() | send(array<Byte>[]()[], Int32, Int64, Int32) |
Send a message to the topic associated with the LBM source
|
![]() | send(array<Byte>[]()[], Int32, Int64, Int32, LBMSourceSendExInfo) |
Send a message to the topic associated with the LBM source
|
![]() | send(array<Byte>[]()[], Int32, Int32) |
Send a message to the topic associated with the LBM source
(Inherited from LBMSource.) |
![]() | send(array<Byte>[]()[], Int32, Int32, Object) |
Send a message to the topic associated with the LBM source
(Inherited from LBMSource.) |
![]() | send(array<Byte>[]()[], Int32, Int32, LBMSourceSendExInfo) |
Send a message to the topic associated with the LBM source
(Inherited from LBMSource.) |
![]() | send(LBMRequest, Int32) |
Send a request message to the topic associated with the LBM source
(Inherited from LBMSource.) |
![]() | send(LBMRequest, LBMEventQueue, Int32) |
Send a request message to the topic associated with the LBM source
using a designated event queue for responses
(Inherited from LBMSource.) |
![]() | send(LBMRequest, Int32, LBMSourceSendExInfo) |
Send a request message to the topic associated with the LBM source
using an designated event queue for responses
(Inherited from LBMSource.) |
![]() | send(LBMRequest, LBMEventQueue, Int32, LBMSourceSendExInfo) |
Send a request message to the topic associated with the LBM source
using an designated event queue for responses
(Inherited from LBMSource.) |
![]() | sendReceiverReset(Int32, LBMSourceSendExInfo) |
Send a message that instructs hot-failover receivers to reset their state. In, and only in, the case that hf receivers
cannot be manually restarted, this function can be used to allow delivering of previously sent sequence numbers. The
hot-failover receiver will deliver a message of type LBM.MSG_HF_RESET and will include the new expected sequence number.
The sequence number contained with the reset will be used as the next expected sequence number to be sent.
NOTE: The best way to reset a hot-failover receiver's state is to restart the receiver itself. This function should be used
only when that is impossible.
|
![]() | setAttributeValue(String, String) |
Set the value of a source-related attribute for this source
(Inherited from LBMSource.) |
![]() | setInflight(Int32, LBMSetInflightCallback, Object) | Set the current inflight value for this source (Inherited from LBMSource.) |
![]() | setInflight(Int32, Int32%, UInt64%, LBMSetInflightCallbackEx, Object) |
Set the current inflight messages and bytes for this source. Note that increasing one value while decreasing the other is not allowed.
If you need to do this, call setInflight twice using 0 as the value for the one you are not changing.
(Inherited from LBMSource.) |
![]() | setUMEMessageStable(Int64) | Mark a specific sqn as stable, triggering an event if configured to do so, and adjusting the inflight if necessary (Inherited from LBMSource.) |
![]() | umederegister()()() |
Deregister the UME Source
(Inherited from LBMSource.) |

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