LBM Hot-Failover Receiver class. More...

Inheritance diagram for com.latencybusters.lbm.LBMHotFailoverReceiver:

Classes
struct	lbmtmgr_hf_rcv_t

Public Member Functions
	LBMHotFailoverReceiver (LBMContext lbmctx, LBMTopic lbmtopic, LBMReceiverCallback cb, object cbArg)
	Instantiate an LBM Hot-Failover Receiver object associated with a given context and topic, with an initial receiver callback and callback object set. More...

	LBMHotFailoverReceiver (LBMContext lbmctx, LBMTopic lbmtopic, LBMReceiverCallback cb, object cbArg, LBMEventQueue lbmevq)
	Instantiate an LBM Hot-Failover Receiver object associated with a given context, topic, and event queue, with an initial receiver callback and callback object set. More...

override void	subscribeChannel (long channelNumber, LBMReceiverCallback cb, Object cbArg)
	Channel functionality is not currently supported by hot failover receivers. Calling this method will result in an exception. More...

override void	unsubscribeChannel (long channelNumber)
	Channel functionality is not currently supported by hot failover receivers. Calling this method will result in an exception. More...

void	close ()
	Close and dispose of this receiver. More...

int	receiverCount ()
	Returns the number of receiver callbacks registered to this receiver. More...

void	addReceiver (LBMReceiverCallback cb)
	Register a receiver callback. More...

void	addReceiver (LBMReceiverCallback cb, object cbArg)
	Register a receiver callback. More...

void	removeReceiver (LBMReceiverCallback cb)
	Deregister a receiver callback. More...

void	removeReceiver (LBMReceiverCallback cb, object cbArg)
	Deregister a receiver callback (and callback token) More...

unsafe List< LBMConfigOption >	dumpAttributeList ()
	Dump source configuration options. More...

string	getAttributeValue (string attributeName)
	Returns the value of a receiver-related attribute for this receiver. More...

void	setAttributeValue (string attributeName, string attributeValue)
	Set the value of a receiver-related attribute for this receiver. More...

LBMReceiverStatistics	getStatistics (string source)
	Return the current set of receiver transport statistics for a particular source. More...

LBMReceiverStatistics	getStatistics (int maxStats)
	Return the current set of receiver transport statistics for all sources. More...

void	resetStatistics (string source)
	Reset the current set of receiver transport statistics for a particular source. More...

void	resetStatistics ()
	Reset the receiver transport statistics for all sources. More...

void	umederegister ()
	Deregister from all stores. More...

void	deregister ()
	Deregister from all queues. More...

void	deregister (String queue)
	Deregister from a single queue, specified by name. More...

void	indexStopAssignment (String queue)
	Stops this receiver's eligibility for new index assignments from a queue. More...

void	indexStartAssignment (String queue)
	Starts this receiver's eligibility for new index assignments from a queue. More...

void	indexRelease (String queue, UMQIndexInfo index)
	Instruct the given UMQ queue(s) to release the given UMQ index that is assigned to the given receiver. More...

void	Dispose ()
	Same as close. More...

Detailed Description

LBM Hot-Failover Receiver class.

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

Constructor & Destructor Documentation

com.latencybusters.lbm.LBMHotFailoverReceiver.LBMHotFailoverReceiver	(	LBMContext	lbmctx,
		LBMTopic	lbmtopic,
		LBMReceiverCallback	cb,
		object	cbArg
	)

Instantiate an LBM Hot-Failover Receiver object associated with a given context and topic, with an initial receiver callback and callback object set.

Warning: It is not safe to call this constructor from a context thread callback.

Parameters

lbmctx	Context with which to associate the receiver
lbmtopic	LBMTopic used to initialize the receiver
cb	Callback implementing the LBMReceiverCallback delegate interface
cbArg	Callback object passed as token to callback interface

com.latencybusters.lbm.LBMHotFailoverReceiver.LBMHotFailoverReceiver	(	LBMContext	lbmctx,
		LBMTopic	lbmtopic,
		LBMReceiverCallback	cb,
		object	cbArg,
		LBMEventQueue	lbmevq
	)

Instantiate an LBM Hot-Failover Receiver object associated with a given context, topic, and event queue, with an initial receiver callback and callback object set.

Warning: It is not safe to call this constructor from a context thread callback.

Parameters

lbmctx	Context with which to associate the receiver
lbmtopic	LBMTopic used to initialize the receiver
cb	Callback implementing the LBMReceiverCallback delegate interface
cbArg	Callback object passed as token to callback interface
lbmevq	Event queue with which to associate the receiver (all receiver events will be posted to this event queue)

Exceptions

com.latencybusters.lbm.LBMEInvalException	Topic is not a receiver topic
com.latencybusters.lbm.LBMException	Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

References com.latencybusters.lbm.LBM.EINVAL, com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

Member Function Documentation

void com.latencybusters.lbm.LBMReceiver.addReceiver ( LBMReceiverCallback cb )

inherited

Register a receiver callback.

If the single receiver callback mode is enabled, this API has no effect and will log a warning if invoked.

See also: LBMReceiverCallback; removeReceiver

Parameters

cb	Callback implementing the LBMReceiverCallback delegate interface

void com.latencybusters.lbm.LBMReceiver.addReceiver	(	LBMReceiverCallback	cb,
		object	cbArg
	)

inherited

Register a receiver callback.

If the single receiver callback mode is enabled, this API has no effect and will log a warning if invoked.

See also: LBMReceiverCallback; removeReceiver

Parameters

cb	Callback implementing the LBMReceiverCallback delegate interface
cbArg	Callback token object

References com.latencybusters.lbm.LBM.LOG_WARNING.

void com.latencybusters.lbm.LBMReceiver.close ( )

inherited

Close and dispose of this receiver.

Warning: It is not safe to call this method from a context thread callback.

void com.latencybusters.lbm.LBMReceiver.deregister ( )

inherited

Deregister from all queues.

Exceptions

com.latencybusters.lbm.LBMException An error occurred while attempting to deregister

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

void com.latencybusters.lbm.LBMReceiver.deregister ( String queue )

inherited

Deregister from a single queue, specified by name.

Parameters

queue The queue to deregister from

Exceptions

com.latencybusters.lbm.LBMException An error occurred while attempting to deregister

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

void com.latencybusters.lbm.LBMReceiver.Dispose ( )

inherited

Same as close.

See also: close

Exceptions

com.latencybusters.lbm.LBMException Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

unsafe List<LBMConfigOption> com.latencybusters.lbm.LBMReceiver.dumpAttributeList ( )

inherited

Dump source configuration options.

Exceptions

com.latencybusters.lbm.LBMException Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

Returns: An array of LBMConfigOptions

References com.latencybusters.lbm.LBM.errorMessage(), com.latencybusters.lbm.LBM.errorNumber(), com.latencybusters.lbm.LBMConfigOption.OptionName, com.latencybusters.lbm.LBMConfigOption.Type, and com.latencybusters.lbm.LBMConfigOption.Value.

string com.latencybusters.lbm.LBMReceiver.getAttributeValue ( string attributeName )

inherited

Returns the value of a receiver-related attribute for this receiver.

Parameters

attributeName Name of the attribute to retrieve

Exceptions

com.latencybusters.lbm.LBMException Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

Returns: Value corresponding to the specified attribute name

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

LBMReceiverStatistics com.latencybusters.lbm.LBMReceiver.getStatistics ( string source )

inherited

Return the current set of receiver transport statistics for a particular source.

Parameters

source Source string (as returned by LBMMesage source()) that specifies the set of statistics to return

Returns: LBMReceiverStatistics object containing the statistics corresponding to the specified source

References com.latencybusters.lbm.LBMReceiverStatistics.refresh(), and com.latencybusters.lbm.LBMObjectRecyclerBase.retrieveReceiverStatistics().

LBMReceiverStatistics com.latencybusters.lbm.LBMReceiver.getStatistics ( int maxStats )

inherited

Return the current set of receiver transport statistics for all sources.

Parameters

maxStats Maximum number of sources

Returns: LBMReceiverStatistics object containing the statistics corresponding to the specified number of sources

References com.latencybusters.lbm.LBMReceiverStatistics.refresh(), and com.latencybusters.lbm.LBMObjectRecyclerBase.retrieveReceiverStatistics().

void com.latencybusters.lbm.LBMReceiver.indexRelease	(	String	queue,
		UMQIndexInfo	index
	)

inherited

Instruct the given UMQ queue(s) to release the given UMQ index that is assigned to the given receiver.

Parameters

queue	Name of the queue at which to release the index, or null for all queues.
index	The index to release, or null for all indices.

References com.latencybusters.lbm.LBM.errorMessage(), com.latencybusters.lbm.LBM.errorNumber(), com.latencybusters.lbm.UMQIndexInfo.flags(), com.latencybusters.lbm.UMQIndexInfo.index(), com.latencybusters.lbm.UMQIndexInfo.indexLength(), com.latencybusters.lbm.UMQIndexInfo.numericIndex(), and com.latencybusters.lbm.LBM.UMQ_INDEX_FLAG_NUMERIC.

void com.latencybusters.lbm.LBMReceiver.indexStartAssignment ( String queue )

inherited

Starts this receiver's eligibility for new index assignments from a queue.

Parameters

queue The name of the queue to start new index assignment from, or null for all queues.

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

void com.latencybusters.lbm.LBMReceiver.indexStopAssignment ( String queue )

inherited

Stops this receiver's eligibility for new index assignments from a queue.

Parameters

queue The name of the queue to stop new index assignment from, or null for all queues.

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

int com.latencybusters.lbm.LBMReceiver.receiverCount ( )

inherited

Returns the number of receiver callbacks registered to this receiver.

Returns: The number of receiver callbacks registered to this receiver.

void com.latencybusters.lbm.LBMReceiver.removeReceiver ( LBMReceiverCallback cb )

inherited

Deregister a receiver callback.

If the single receiver callback mode is enabled, this API has no effect and will log a warning if invoked.

See also: LBMReceiverCallback; addReceiver

Parameters

cb	Previously registered callback implementing the LBMReceiverCallback delegate interface

void com.latencybusters.lbm.LBMReceiver.removeReceiver	(	LBMReceiverCallback	cb,
		object	cbArg
	)

inherited

Deregister a receiver callback (and callback token)

If the single receiver callback mode is enabled, this API has no effect and will log a warning if invoked.

See also: LBMReceiverCallback; addReceiver

Parameters

cb	Previously registered callback implementing the LBMReceiverCallback delegate interface
cbArg	Callback token for previously registered callback

References com.latencybusters.lbm.LBMMessage.Dispose(), com.latencybusters.lbm.LBMReceiverCallback(), com.latencybusters.lbm.LBM.LOG_WARNING, and com.latencybusters.lbm.LBMObjectRecyclerBase.retrieveMessage().

void com.latencybusters.lbm.LBMReceiver.resetStatistics ( string source )

inherited

Reset the current set of receiver transport statistics for a particular source.

Parameters

source The string version of the source to reset statistics for.

Exceptions

com.latencybusters.lbm.LBMException Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

void com.latencybusters.lbm.LBMReceiver.resetStatistics ( )

inherited

Reset the receiver transport statistics for all sources.

Exceptions

com.latencybusters.lbm.LBMException Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

void com.latencybusters.lbm.LBMReceiver.setAttributeValue	(	string	attributeName,
		string	attributeValue
	)

inherited

Set the value of a receiver-related attribute for this receiver.

Parameters

attributeName	Name of the attribute to set
attributeValue	New attribute value

Exceptions

com.latencybusters.lbm.LBMException Invalid argument or unexpected operational behavior has been encountered by unmanaged LBM C layer function.

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

override void com.latencybusters.lbm.LBMHotFailoverReceiver.subscribeChannel	(	long	channelNumber,
		LBMReceiverCallback	cb,
		Object	cbArg
	)

virtual

Channel functionality is not currently supported by hot failover receivers. Calling this method will result in an exception.

Exceptions

com.latencybusters.lbm.LBMException Thrown if this method is called on a Hot Failover receiver.

Reimplemented from com.latencybusters.lbm.LBMReceiver.

References com.latencybusters.lbm.LBM.EINVAL.

void com.latencybusters.lbm.LBMReceiver.umederegister ( )

inherited

Deregister from all stores.

Exceptions

com.latencybusters.lbm.LBMException An error occurred while attempting to deregister

References com.latencybusters.lbm.LBM.errorMessage(), and com.latencybusters.lbm.LBM.errorNumber().

override void com.latencybusters.lbm.LBMHotFailoverReceiver.unsubscribeChannel ( long channelNumber )

virtual

Channel functionality is not currently supported by hot failover receivers. Calling this method will result in an exception.

Exceptions

com.latencybusters.lbm.LBMException Thrown if this method is called on a Hot Failover receiver.

Reimplemented from com.latencybusters.lbm.LBMReceiver.

References com.latencybusters.lbm.LBM.EINVAL.

The documentation for this class was generated from the following file:

LBMHotFailoverReceiver.cs

Classes

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation