OSMQ
v2.0.1
A B C D E F G H I J K L M N O P Q R S T U V W Z _

A

ACCEPT_LISTENER_PRIORITY - Static variable in interface osmq.broker.config.BrokerConsts
 
ADDED - Static variable in class osmq.tables.KeyedRowList
 
ADDED - Static variable in class osmq.util.KeyedOrderedList
 
ADD_STRING - Static variable in class osmq.clients.TopicChangeRequestor
 
ALARM_THRESHOLD_SECONDS - Static variable in class osmq.mcns.MCNS
 
ALIVE_ALARM_THRESHOLD - Static variable in interface osmq.pulsar.Threshold
 
ALL_OPTION - Static variable in class osmq.broker.handlers.ChangeHandler
 
ANY_CHAR - Static variable in class osmq.uicontrols.Formatter
 
AVG_RATE - Static variable in class osmq.broker.StatsContainer
 
AbstractThreadable - class osmq.util.AbstractThreadable.
Base class for objects that need a seperate thread to iteratively perform a task.
AbstractThreadable() - Constructor for class osmq.util.AbstractThreadable
 
Accumulator - class osmq.util.Accumulator.
Encapsulate a long integer value, and provides thread-save methods to increment, decrement and reference the value.
Accumulator() - Constructor for class osmq.util.Accumulator
 
Accumulator(long) - Constructor for class osmq.util.Accumulator
 
AnsweredYes(Frame, String, String) - Static method in class osmq.util.ShutdownManager
 
abs() - Method in class osmq.datatypes.FixedDecimal
 
abs(FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
activePublisherCount - Variable in class osmq.broker.StatsContainer
 
activeSubscriberCount - Variable in class osmq.broker.StatsContainer
 
add(double) - Method in class osmq.datatypes.Decimal
 
add(Decimal) - Method in class osmq.datatypes.Decimal
 
add(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
add(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
add(int) - Method in class osmq.util.Stats
 
add(String) - Method in class osmq.util.TopicSet
 
add(String, MessageListener) - Method in class osmq.util.TopicsListeners
 
addATopic(String) - Method in class osmq.broker.subqueues.SubscriberQueue
 
addColumnAttrib(ColumnAttrib) - Method in class osmq.tables.TableAttrib
 
addDurationListener(DurationListener) - Method in class osmq.util.DurationTimer
 
addEntry(String) - Method in class osmq.util.IntMap
 
addExceptionListener(ExceptionListener) - Method in class osmq.broker.handlers.ServerSocketProcessor
 
addExceptionListener(ExceptionListener) - Method in class osmq.net.ServerSocketProcessor
 
addExceptionListener(ExceptionListener) - Method in class osmq.util.ExceptionEventBean
 
addListener(StateEventListener) - Method in class osmq.pulsar.HeartbeatListener
 
addMessageBuilder(MessageBuilder) - Method in class osmq.clients.BatchPublisher
Adds a message builder that will create messages that will be written by the message publisher.
addMouseListenerToHeaderInTable(JTable) - Method in class osmq.tables.SortingTableModel
 
addRow(KeyedDataRow) - Method in class osmq.tables.KeyedRowTableModel
 
addRow(KeyedDataRow) - Method in class osmq.uicontrols.KeyedTable
 
addRow(KeyedDataRow) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
addRowListener(RowListener) - Method in class osmq.tables.KeyedRowTableModel
 
addRowListener(RowListener) - Method in interface osmq.tables.RowListenerList
 
addRowListener(RowListener) - Method in class osmq.uicontrols.KeyedTable
 
addRowListener(RowListener) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
addStateEventListener(StateEventListener) - Method in class osmq.broker.RemoteLogger
 
addStateEventListener(StateEventListener) - Method in class osmq.net.DiscoveryServer
 
addStateEventListener(StateEventListener) - Method in class osmq.util.StateEventBean
 
addStatusUpdateListener(TickEventListener) - Method in class osmq.broker.StatsEngine
 
addSubscription(MQue, String) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
addSubscription(String, String) - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
Add a topic subscription for a named subscriber (subscriber's clientID).
addSubscription(String) - Method in class osmq.clients.TopicChangeRequestor
 
addTickEventListener(TickEventListener) - Method in class osmq.util.TickEventBean
 
addTopic(String) - Method in interface osmq.clients.Subscriber
Registers a topic for this subscriber.
addTopic(String) - Method in class osmq.clients.SubscriberBean
Registers a topic for this subscriber.
addTopic(String, MessageListener) - Method in class osmq.clients.TopicSubscriberBean
Adds a topical listener -- one that subscribes to a named topic.
added() - Method in class osmq.tables.KeyedRowList
 
added() - Method in class osmq.util.KeyedOrderedList
 
alert(Message) - Method in class osmq.util.TopicSet
 
alignCenter() - Method in class osmq.uicontrols.BaseSyncField
 
alignLeft() - Method in class osmq.uicontrols.BaseSyncField
 
alignRight() - Method in class osmq.uicontrols.BaseSyncField
 
appendByte(byte) - Method in class osmq.util.DynByteArray
 
audit - Static variable in class osmq.logs.Logs
 
authenticate() - Method in class osmq.clients.ClientStream
 
availmemory - Variable in class osmq.broker.StatsContainer
 
avgMps - Variable in class osmq.broker.StatsContainer
 

B

BATCH_CONTROL - Static variable in interface osmq.messages.MessageType
 
BINARY - Static variable in interface osmq.messages.MessageFormat
 
BINARY_SOCKET_STREAMS - Static variable in interface osmq.broker.config.BrokerConsts
 
BROKER_NAME - Static variable in class osmq.broker.StatsContainer
 
BYTES_PUBLISHED - Static variable in class osmq.broker.StatsContainer
 
BaseSyncField - class osmq.uicontrols.BaseSyncField.
 
BaseSyncField() - Constructor for class osmq.uicontrols.BaseSyncField
 
BatchPublisher - class osmq.clients.BatchPublisher.
 
BatchPublisher() - Constructor for class osmq.clients.BatchPublisher
 
BatchPublisher(String) - Constructor for class osmq.clients.BatchPublisher
 
BinaryMessageBean - class osmq.messages.BinaryMessageBean.
Deprecated.  
BinaryMessageBean() - Constructor for class osmq.messages.BinaryMessageBean
Deprecated.  
Broker - class osmq.broker.Broker.
 
Broker() - Constructor for class osmq.broker.Broker
 
BrokerConsts - interface osmq.broker.config.BrokerConsts.
 
BrokerEngine - class osmq.broker.BrokerEngine.
 
BrokerException - exception osmq.clients.BrokerException.
 
BrokerException() - Constructor for class osmq.clients.BrokerException
 
BrokerException(String) - Constructor for class osmq.clients.BrokerException
 
BrokerFaultMonitor - class osmq.broker.BrokerFaultMonitor.
 
BrokerFaultMonitor(BrokerEngine) - Constructor for class osmq.broker.BrokerFaultMonitor
 
BufferedInputFile - class osmq.io.BufferedInputFile.
 
BufferedInputFile(String) - Constructor for class osmq.io.BufferedInputFile
 
BufferedInputFile(File) - Constructor for class osmq.io.BufferedInputFile
 
BufferedInputFileReader - class osmq.io.BufferedInputFileReader.
 
BufferedInputFileReader(String) - Constructor for class osmq.io.BufferedInputFileReader
 
ByteArray - interface osmq.util.ByteArray.
 
ByteArrayImpl - class osmq.util.ByteArrayImpl.
 
ByteArrayImpl() - Constructor for class osmq.util.ByteArrayImpl
 
ByteArrayImpl(byte[]) - Constructor for class osmq.util.ByteArrayImpl
 
ByteString - class osmq.util.ByteString.
An object with methods similar to String but handling byte-size character arrays.
ByteString() - Constructor for class osmq.util.ByteString
 
ByteString(String) - Constructor for class osmq.util.ByteString
 
ByteString(byte[]) - Constructor for class osmq.util.ByteString
 
ByteString(byte[], int, int) - Constructor for class osmq.util.ByteString
 
begin() - Method in class osmq.util.TickEventBean
 
brokername - Variable in class osmq.broker.StatsContainer
 
buf - Static variable in class osmq.mcns.MCResponder
 
buffer - Static variable in class osmq.pulsar.DatasetPulsarListener
 
buffer - Static variable in class osmq.pulsar.HeartbeatListener
 
buffer_size - Static variable in class osmq.pulsar.DatasetPulsarListener
 
buffer_size - Static variable in class osmq.pulsar.HeartbeatListener
 
byteAt(int) - Method in class osmq.util.ByteString
 
bytesPublished - Variable in class osmq.broker.StatsContainer
 

C

CHAR - Static variable in interface osmq.datatypes.DataType
 
CLIENT_SOCKET_TIMEOUT - Static variable in class osmq.mcns.MCNS
 
CLOSE_EVENT - Static variable in class osmq.util.StateEvent
 
COMMAND_FLAG - Static variable in interface osmq.util.NetConsts
 
CONFIG_NAME - Static variable in class osmq.broker.Broker
 
CONFIG_NAME - Static variable in interface osmq.broker.config.BrokerConsts
 
CONTENT_FORMAT - Static variable in interface osmq.messages.MessageAttributes
 
CORRELATION_ID - Static variable in interface osmq.messages.MessageAttributes
 
CSVParser - class osmq.util.CSVParser.
Takes a comma delimited string and returns the elements as an enumeration ( nextElement() and hasMoreElements() )
CSVParser() - Constructor for class osmq.util.CSVParser
 
CSVParser(String) - Constructor for class osmq.util.CSVParser
 
CURRENCY - Static variable in interface osmq.datatypes.DataType
 
CURRENCY_MASK - Static variable in class osmq.uicontrols.Formatter
 
ChangeHandler - class osmq.broker.handlers.ChangeHandler.
An aggregate of the MRouter class that listens on a multicast channgel for remote commands such as kill a subscriber or shut down the message broker
ChangeHandler() - Constructor for class osmq.broker.handlers.ChangeHandler
 
ChangeRequestor - class osmq.broker.ChangeRequestor.
A client component that submits one or more change requests to the router/server.
ChangeRequestor() - Constructor for class osmq.broker.ChangeRequestor
 
ClientAdapter - interface osmq.clients.ClientAdapter.
A client-side integration broker adapter, and the base interface from which the Publisher and Subscriber interfaces are derived.
ClientIdentifier - class osmq.clients.ClientIdentifier.
 
ClientIdentifier() - Constructor for class osmq.clients.ClientIdentifier
 
ClientStream - class osmq.clients.ClientStream.
A ClientStream identifies itself and its role to the remote service when it connects.
CloneableArrayList - class osmq.util.CloneableArrayList.
 
CloneableArrayList() - Constructor for class osmq.util.CloneableArrayList
 
ColumnAttrib - class osmq.tables.ColumnAttrib.
 
ColumnAttrib() - Constructor for class osmq.tables.ColumnAttrib
 
ColumnAttrib(String) - Constructor for class osmq.tables.ColumnAttrib
 
ColumnAttrib(String, int) - Constructor for class osmq.tables.ColumnAttrib
 
ColumnAttrib(String, int, int) - Constructor for class osmq.tables.ColumnAttrib
 
ColumnAttrib(String, int, int, boolean) - Constructor for class osmq.tables.ColumnAttrib
 
CoreRecord - class osmq.records.CoreRecord.
An implementation of a multi-object container that uses an array to store its values.
CoreRecord() - Constructor for class osmq.records.CoreRecord
 
Currency - class osmq.datatypes.Currency.
An immutable data type representing Rate.
Currency() - Constructor for class osmq.datatypes.Currency
 
Currency(Decimal) - Constructor for class osmq.datatypes.Currency
 
Currency(double) - Constructor for class osmq.datatypes.Currency
 
Currency(int) - Constructor for class osmq.datatypes.Currency
 
Currency(String) - Constructor for class osmq.datatypes.Currency
 
CurrencyRenderer - class osmq.tables.CurrencyRenderer.
 
CurrencyRenderer() - Constructor for class osmq.tables.CurrencyRenderer
 
ceil() - Method in class osmq.datatypes.FixedDecimal
 
ceil(FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
charAt(int) - Method in class osmq.util.ByteString
 
checkModel() - Method in class osmq.tables.SortingTableModel
 
classToType(Class) - Static method in class osmq.tables.ColumnAttrib
 
clear(int) - Method in interface osmq.messages.DataSetMessage
Clears the value at the designated position, setting it to null (or zero if numeric)
clear(int) - Method in class osmq.messages.DataSetMessageBean
Clears the value at the designated position, setting it to null (or zero if numeric)
clear() - Method in class osmq.mque.MQue
Clears the queue of all elements.
clear(int) - Method in interface osmq.records.DataRecord
Clears the value at the designated position, setting it to null (or zero if numeric)
clear(int) - Method in class osmq.records.DataRecordBean
Clears the value of the designated position to null (or zero if numeric)
clear(int) - Method in class osmq.records.DataRecordWrapper
Clears the value at the designated position, setting it to null (or zero if numeric)
clear() - Method in class osmq.tables.KeyedRowList
 
clear() - Method in class osmq.util.KeyedOrderedList
Removes all table entries and resets counters to zero.
clearAddress() - Method in class osmq.net.RemoteService
 
clearAddress() - Method in class osmq.net.RemoteServiceWrapper
 
clearAll() - Method in class osmq.messages.MessageHeader
 
clearAll() - Method in interface osmq.records.DataRecord
Clears all the elements, setting them to null (or zero if numeric)
clearAll() - Method in class osmq.records.DataRecordBean
Clear all the elements in the DataRecord object to null (or zero if numeric)
clearAll() - Method in class osmq.records.DataRecordWrapper
Clears all the elements in the DataRecord object, setting them to null (or zero if numeric)
clearAll() - Method in class osmq.util.DataLock
 
clearBody() - Method in interface osmq.messages.DataSetMessage
Clear all the body elements in the DataSetMessage object to null (or zero if numeric)
clearBody() - Method in class osmq.messages.DataSetMessageBean
Clear all the body elements in the DataSetMessage object to null (or zero if numeric)
clearContentSize() - Method in class osmq.util.DynByteArray
 
clearHandler() - Method in class osmq.broker.handlers.PubStatus
 
clearHeader() - Method in interface osmq.messages.DataSetMessage
Clear all the header elements in the DataSetMessage object to null (or zero if numeric)
clearHeader() - Method in class osmq.messages.DataSetMessageBean
Clear all the header elements in the DataSetMessage object to null (or zero if numeric)
clearHighestSize() - Method in class osmq.mque.MQue
Clears the highest count.
clockvalue - Variable in class osmq.broker.StatsContainer
 
clone() - Method in interface osmq.messages.DataSetMessage
 
clone() - Method in class osmq.messages.DataSetMessageBean
 
clone() - Method in interface osmq.messages.MessageAttributes
 
clone() - Method in class osmq.messages.MessageBean
 
clone() - Method in class osmq.messages.MessageHeader
 
clone() - Method in class osmq.records.CoreRecord
 
clone() - Method in interface osmq.records.DataRecord
 
clone() - Method in class osmq.records.DataRecordBean
 
clone() - Method in class osmq.records.DataRecordWrapper
 
clone() - Method in class osmq.tables.ColumnAttrib
 
clone() - Method in class osmq.tables.TableAttrib
 
clone() - Method in class osmq.util.CSVParser
 
clone() - Method in class osmq.util.CloneableArrayList
 
clone() - Method in class osmq.util.DelimitedArrayParser
 
clone() - Method in class osmq.util.DelimitedStringParser
 
clone() - Method in class osmq.util.KeyedOrderedList
 
close() - Method in class osmq.broker.RemoteLogger
 
close() - Method in class osmq.broker.SlaveRouterProcessor
Disconnect the connection to the Message Broker and closes the Queue.
close() - Method in class osmq.broker.subqueues.TopicSubscriptions
 
close() - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
close() - Method in interface osmq.clients.ClientAdapter
Closes the message queues and halts message processing.
close() - Method in interface osmq.clients.Publisher
Closes the message queues and halts message processing.
close() - Method in class osmq.clients.PublisherBean
Closes the publisher's connection to the message broker.
close() - Method in interface osmq.clients.Subscriber
Closes the message queues and halts message flow to the subscriber.
close() - Method in class osmq.clients.SubscriberBean
 
close() - Method in class osmq.clients.ThreadedPublisherBean
 
close() - Method in class osmq.clients.TopicSubscriberBean
 
close() - Method in interface osmq.io.ReaderStream
 
close() - Method in interface osmq.io.WriterStream
 
close() - Method in interface osmq.logs.Log
 
close() - Method in class osmq.mcns.MulticastListener
 
close() - Method in class osmq.mque.MQue
Halts all writes, resulting in a QueueException being thrown on any subsequent calls to the Queue object's write methods.
close() - Method in class osmq.mque.PersistentMQue
 
close() - Method in class osmq.net.SocketStreamFilter
 
close() - Method in class osmq.util.AbstractThreadable
 
close() - Method in class osmq.util.InputSimDevice
 
close() - Method in interface osmq.util.Readable
 
close() - Method in class osmq.util.ThreadBean
 
close() - Method in class osmq.util.ThreadedReader
 
closeConnection() - Method in class osmq.broker.SlaveRouterProcessor
Closes the connection to the Message Broker.
closeLogs() - Static method in class osmq.logs.Logs
 
columnCount() - Method in class osmq.tables.TableAttrib
 
commit() - Method in interface osmq.clients.Publisher
Transmits all messages that were published since the last call to commit() or rollback().
compare(int, int) - Method in class osmq.tables.SortingTableModel
 
compareRowsByColumn(int, int, int) - Method in class osmq.tables.SortingTableModel
 
compareTo(ByteString) - Method in class osmq.util.ByteString
 
compareTo(Object) - Method in class osmq.util.ByteString
 
concat(ByteString) - Method in class osmq.util.ByteString
 
contains(Object) - Method in class osmq.tables.KeyedRowList
 
contains(Object) - Method in class osmq.util.KeyedOrderedList
Identifies whether there is a KeyedData item in the set with a matching key value
createAServer(ExceptionListener) - Static method in class osmq.net.DiscoveryServer
 
createAndStart(Object, String, int, boolean, int) - Static method in class osmq.net.DiscoveryServer
 
createAndStart(Object, RemoteService, int) - Static method in class osmq.net.DiscoveryServer
 
createDataSetMessage(String) - Static method in class osmq.messages.MessageFactory
 
createImmutableMessage(String) - Static method in class osmq.messages.MessageFactory
 
createImmutableMessage(byte[]) - Static method in class osmq.messages.MessageFactory
 
createListener() - Static method in class osmq.mcns.MulticastListener
 
createMessage(byte[]) - Static method in class osmq.messages.MessageFactory
Creates an DataSetMessageBean or BinaryMessageBean, depending on the value of the message format found in the byte array.
createMessage(int) - Static method in class osmq.messages.MessageFactory
 
createNotificationMessage(int, String) - Static method in class osmq.messages.MessageFactory
 
createQueue(String) - Method in class osmq.broker.subqueues.SubscriberQueues
Unconditionally creates a name Queue associated with the value key.
createStream(RemoteService, ExceptionListener, String, ClientIdentifier) - Static method in class osmq.clients.ClientStream
 

D

DATASET - Static variable in interface osmq.messages.MessageFormat
 
DATA_KEY - Static variable in interface osmq.messages.MessageAttributes
 
DECIMAL - Static variable in interface osmq.datatypes.DataType
 
DECIMAL - Static variable in class osmq.util.FixedLengthRecord
 
DEFAULT_BROKER_PORT - Static variable in interface osmq.util.NetConsts
 
DEFAULT_BROKER_SERVICE_NAME - Static variable in interface osmq.broker.config.BrokerConsts
 
DEFAULT_DELIMITER - Static variable in interface osmq.records.DataRecord
 
DEFAULT_STREAM_MODE_BINARY - Static variable in class osmq.net.RemoteService
 
DELIMITER_STRING - Static variable in class osmq.records.CoreRecord
 
DENIAL - Static variable in interface osmq.messages.MessageType
 
DGSocket - class osmq.mcns.DGSocket.
A descendant class of DatagramSocket that ensures the socket is closed when the class instance is deallocated.
DGSocket(int) - Constructor for class osmq.mcns.DGSocket
 
DGSocket() - Constructor for class osmq.mcns.DGSocket
 
DIGIT_CHAR - Static variable in class osmq.uicontrols.Formatter
 
DISCOVERY - Static variable in class osmq.util.Trace
 
DISCOVERY_CHANNEL - Static variable in class osmq.mcns.MCNS
 
DISCOVERY_SERV_ACTIVE - Static variable in class osmq.util.StateEvent
 
DOUBLE - Static variable in interface osmq.datatypes.DataType
 
DROP_STRING - Static variable in class osmq.clients.TopicChangeRequestor
 
DataLock - class osmq.util.DataLock.
 
DataLock() - Constructor for class osmq.util.DataLock
 
DataRecord - interface osmq.records.DataRecord.
A multi-element container that sets and returns its elements as either Strings or scalar data types.
DataRecordBean - class osmq.records.DataRecordBean.
Default implementation of a DataRecord.
DataRecordBean() - Constructor for class osmq.records.DataRecordBean
 
DataRecordBean(Object[]) - Constructor for class osmq.records.DataRecordBean
 
DataRecordBean(int) - Constructor for class osmq.records.DataRecordBean
 
DataRecordBean(CoreRecord) - Constructor for class osmq.records.DataRecordBean
 
DataRecordBean(String) - Constructor for class osmq.records.DataRecordBean
 
DataRecordBean(byte[]) - Constructor for class osmq.records.DataRecordBean
 
DataRecordException - exception osmq.records.DataRecordException.
 
DataRecordException() - Constructor for class osmq.records.DataRecordException
 
DataRecordException(String) - Constructor for class osmq.records.DataRecordException
 
DataRecordGenerator - interface osmq.records.DataRecordGenerator.
 
DataRecordListener - interface osmq.records.DataRecordListener.
 
DataRecordLoader - interface osmq.records.DataRecordLoader.
 
DataRecordWrapper - class osmq.records.DataRecordWrapper.
 
DataRecordWrapper(DataRecord) - Constructor for class osmq.records.DataRecordWrapper
 
DataSetMessage - interface osmq.messages.DataSetMessage.
An entity relational message (DataSetMessage) contains entity data values, and supports mapping those data values to/from Java data types, and routing them as a unit to remote processes.
DataSetMessageBean - class osmq.messages.DataSetMessageBean.
An entity relational message (DataSetMessage) contains entity data values, and supports mapping those data values to/from Java data types, and routing them as a unit to remote processes.
DataSetMessageBean(MessageHeader, DataRecord) - Constructor for class osmq.messages.DataSetMessageBean
 
DataSetMessageBean(MessageHeader, byte[]) - Constructor for class osmq.messages.DataSetMessageBean
 
DataSetMessageBean() - Constructor for class osmq.messages.DataSetMessageBean
 
DataSetMessageBean(int) - Constructor for class osmq.messages.DataSetMessageBean
 
DataType - interface osmq.datatypes.DataType.
 
DatasetPulsarListener - class osmq.pulsar.DatasetPulsarListener.
Aggregate class used by a service's client to identify if and when a service fails.
DatasetPulsarListener() - Constructor for class osmq.pulsar.DatasetPulsarListener
 
DateConverter - class osmq.util.DateConverter.
 
DateConverter() - Constructor for class osmq.util.DateConverter
 
DateConverter(String) - Method in class osmq.util.DateConverter
 
DateFormatter - class osmq.util.DateFormatter.
 
DateFormatter() - Constructor for class osmq.util.DateFormatter
 
DateStamp - class osmq.util.DateStamp.
 
DateStamp() - Constructor for class osmq.util.DateStamp
 
Decimal - class osmq.datatypes.Decimal.
An immutable data type representing Rate.
Decimal() - Constructor for class osmq.datatypes.Decimal
 
Decimal(Decimal) - Constructor for class osmq.datatypes.Decimal
 
Decimal(double) - Constructor for class osmq.datatypes.Decimal
 
Decimal(int) - Constructor for class osmq.datatypes.Decimal
 
Decimal(String) - Constructor for class osmq.datatypes.Decimal
 
DecimalConverter - class osmq.util.DecimalConverter.
 
DecimalConverter() - Constructor for class osmq.util.DecimalConverter
 
DecimalConverter(double) - Constructor for class osmq.util.DecimalConverter
 
DecimalConverter(double, int) - Constructor for class osmq.util.DecimalConverter
 
DelimitedArrayParser - class osmq.util.DelimitedArrayParser.
Takes a delimited string and returns the elements as an enumeration ( nextElement() and hasMoreElements() )
DelimitedArrayParser() - Constructor for class osmq.util.DelimitedArrayParser
 
DelimitedArrayParser(byte[]) - Constructor for class osmq.util.DelimitedArrayParser
 
DelimitedStringParser - class osmq.util.DelimitedStringParser.
Takes a delimited string and returns the elements as an enumeration ( nextElement() and hasMoreElements() )
DelimitedStringParser() - Constructor for class osmq.util.DelimitedStringParser
 
DelimitedStringParser(String) - Constructor for class osmq.util.DelimitedStringParser
 
DiscoveryClient - class osmq.net.DiscoveryClient.
Sends a "where is" request to a multicast group/port, and waits for a service to respond with its host/port.
DiscoveryServer - class osmq.net.DiscoveryServer.
An aggregate class of ServerSocket.class.
DiscoverySocket - class osmq.net.DiscoverySocket.
A DiscoverySocket is a standard socket implementation that can use dynamic discovery to determine the host address and port.
DiscoverySocket(String) - Constructor for class osmq.net.DiscoverySocket
Attempts to attach to the remote service.
DiscoverySocket(String, int) - Constructor for class osmq.net.DiscoverySocket
 
DistributionMode - interface osmq.util.DistributionMode.
Base class for objects that need a seperate thread to iteratively perform a task.
Duration - class osmq.util.Duration.
 
Duration() - Constructor for class osmq.util.Duration
 
Duration(int) - Constructor for class osmq.util.Duration
 
Duration(String, String, String) - Constructor for class osmq.util.Duration
 
Duration(int, int, int) - Constructor for class osmq.util.Duration
 
DurationClock - class osmq.util.DurationClock.
The clock must be started by calling reset();
DurationClock() - Constructor for class osmq.util.DurationClock
 
DurationListener - interface osmq.util.DurationListener.
 
DurationTimer - class osmq.util.DurationTimer.
Periodically notifies a listener regarding the time duration.
DurationTimer(DurationClock) - Constructor for class osmq.util.DurationTimer
 
DurationTimer() - Constructor for class osmq.util.DurationTimer
 
DurationUtil - class osmq.util.DurationUtil.
 
DurationUtil() - Constructor for class osmq.util.DurationUtil
 
DynByteArray - class osmq.util.DynByteArray.
A dynamically resizeable byte array onto which bytes may be appended one at a time.
DynByteArray() - Constructor for class osmq.util.DynByteArray
 
DynByteArray(int) - Constructor for class osmq.util.DynByteArray
 
DynamicPulsar - class osmq.pulsar.DynamicPulsar.
MCNS (multicast Name Service) MulticastPulsar uses an ip multicast channel to repeatedly broadcast a service name, ip adddress and port at a fixed time frequency.
DynamicPulsar(StringGenerator) - Constructor for class osmq.pulsar.DynamicPulsar
 
DynamicPulsar(DataRecordGenerator) - Constructor for class osmq.pulsar.DynamicPulsar
 
decrement() - Method in class osmq.util.Accumulator
 
decrementBy(int) - Method in class osmq.util.Accumulator
 
delete(String) - Method in class osmq.util.TopicSet
 
delete(String) - Method in class osmq.util.TopicsListeners
 
deliveredCount - Variable in class osmq.broker.StatsContainer
 
details - Variable in class osmq.mque.QueueStats
 
didOpen() - Method in class osmq.clients.TopicChangeRequestor
 
distributeAMessage(String, byte[]) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
distributeAMessage(byte[], String, String) - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
div(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
div(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
dividedBy(int) - Method in class osmq.datatypes.Decimal
 
dividedBy(int) - Method in class osmq.datatypes.Price
 
doubleValue() - Method in class osmq.datatypes.Decimal
 
doubleValue() - Method in class osmq.datatypes.FixedDecimal
 
doubleValue() - Method in class osmq.datatypes.Price
 
dropAllEntries() - Method in class osmq.uicontrols.ScrollingKeyedTable
 
dropColumnAttrib(int) - Method in class osmq.tables.TableAttrib
 
dropRow(int) - Method in class osmq.tables.KeyedRowTableModel
 
dropRow(int) - Method in class osmq.uicontrols.KeyedTable
 
dropRow(int) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
dropSubscription(String, String) - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
Remove a topic subscription for a named subscriber (subscriber's clientID)
dropSubscriptionsFor(String) - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
dropTopicsFor(String) - Method in class osmq.broker.BrokerEngine
 

E

E - Static variable in class osmq.datatypes.FixedDecimal
 
ELEMENT_COUNT - Static variable in class osmq.broker.StatsContainer
 
ERROR_DISOVERY_SERVER_NOT_RESPONDING - Static variable in class osmq.mcns.MCNS
 
ERROR_NO_SERVICE_ENTRY - Static variable in class osmq.mcns.MCNS
 
ERROR_SERVICE_NOT_ALIVE - Static variable in class osmq.mcns.MCNS
 
EXTENDED_DOTTED_IP_GROUP - Static variable in class osmq.mcns.NetworkScope
 
EXTENDED_TTL - Static variable in class osmq.mcns.NetworkScope
 
EbcdicTranslator - class osmq.util.EbcdicTranslator.
CSTranslator (Character Set Translator) translates ASCII to EBCDIC and EBCDIC to ASCII.
EbcdicTranslator() - Constructor for class osmq.util.EbcdicTranslator
 
EventCounter - interface osmq.util.EventCounter.
 
EventCounterImpl - class osmq.util.EventCounterImpl.
 
EventCounterImpl() - Constructor for class osmq.util.EventCounterImpl
 
EventRate - class osmq.util.EventRate.
 
EventRate() - Constructor for class osmq.util.EventRate
 
EventRate(EventCounter) - Constructor for class osmq.util.EventRate
 
EventRateBean - class osmq.util.EventRateBean.
 
EventRateBean() - Constructor for class osmq.util.EventRateBean
 
EventRateMgr - class osmq.util.EventRateMgr.
A class that tracks time duration and number of events.
EventRateMgr() - Constructor for class osmq.util.EventRateMgr
 
ExceptionEventBean - class osmq.util.ExceptionEventBean.
 
ExceptionEventBean() - Constructor for class osmq.util.ExceptionEventBean
 
ExceptionListener - interface osmq.util.ExceptionListener.
If a Threaded process detects a serious problem it will inform the Threaded's ExceptionListener if one has been registered.
ExceptionListenerBase - class osmq.util.ExceptionListenerBase.
 
ExceptionListenerBase() - Constructor for class osmq.util.ExceptionListenerBase
 
ExceptionListenerImpl - class osmq.util.ExceptionListenerImpl.
 
ExceptionListenerImpl() - Constructor for class osmq.util.ExceptionListenerImpl
 
ExceptionLogger - class osmq.util.ExceptionLogger.
 
ExceptionLogger() - Constructor for class osmq.util.ExceptionLogger
 
eq(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
eq(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
equals(Decimal) - Method in class osmq.datatypes.Decimal
 
equals(Price) - Method in class osmq.datatypes.Price
 
equals(Object) - Method in class osmq.util.ByteString
 
err - Static variable in class osmq.logs.Logs
 

F

FAIL_EVENT - Static variable in class osmq.util.StateEvent
 
FLUSH_QUEUE - Static variable in class osmq.broker.ChangeRequestor
 
FLUSH_TOPICS - Static variable in class osmq.broker.ChangeRequestor
 
FOUR_DEC_PRECIS_MASK - Static variable in class osmq.uicontrols.Formatter
 
FactorUtil - class osmq.datatypes.FactorUtil.
 
FactorUtil(int) - Constructor for class osmq.datatypes.FactorUtil
 
FileUtil - class osmq.util.FileUtil.
 
FileUtil() - Constructor for class osmq.util.FileUtil
 
FilterListener - interface osmq.util.FilterListener.
 
FixedDecimal - class osmq.datatypes.FixedDecimal.
 
FixedDecimal() - Constructor for class osmq.datatypes.FixedDecimal
 
FixedDecimal(String) - Constructor for class osmq.datatypes.FixedDecimal
 
FixedDecimal(FixedDecimal) - Constructor for class osmq.datatypes.FixedDecimal
 
FixedDecimal(int) - Constructor for class osmq.datatypes.FixedDecimal
 
FixedDecimal(float) - Constructor for class osmq.datatypes.FixedDecimal
 
FixedDecimal(double) - Constructor for class osmq.datatypes.FixedDecimal
 
FixedDecimalRenderer - class osmq.tables.FixedDecimalRenderer.
 
FixedDecimalRenderer() - Constructor for class osmq.tables.FixedDecimalRenderer
 
FixedLengthRecord - class osmq.util.FixedLengthRecord.
Creates a Message or DataRecord from a string that represents a COBOL data record in display format.
FixedLengthRecord() - Constructor for class osmq.util.FixedLengthRecord
 
FixedLengthRecord(String) - Constructor for class osmq.util.FixedLengthRecord
 
Formatter - class osmq.uicontrols.Formatter.
 
Formatter() - Constructor for class osmq.uicontrols.Formatter
 
Formatter(String) - Constructor for class osmq.uicontrols.Formatter
 
fillDataRecord(DataRecord) - Method in class osmq.broker.StatsContainer
 
fillDataRecord(String) - Method in class osmq.broker.StatsContainer
 
findColumn(String) - Method in class osmq.tables.KeyedRowTableModel
 
findOrCreate(String) - Method in class osmq.broker.subqueues.SubscriberQueues
Return the Queue associated with a key.
findOrCreateAndLoad(String) - Method in class osmq.broker.subqueues.SubscriberQueues
Return the Queue associated with a key.
findQueue(String) - Method in class osmq.broker.subqueues.SubscriberQueues
Locate a Queue associated with the value key.
findSubstring(String) - Method in class osmq.util.StringParser
 
findTokenOccurance(String, int) - Method in class osmq.util.StringParser
Locates an occurance of a character within a string that matches a character in another string, and returns its offset.
findTokenOccurance(char, int) - Method in class osmq.util.StringParser
Locates an occurance of a character within a string and returns its offset.
findTokenOccurance(byte[], byte, int) - Method in class osmq.util.TokenFinder
Locates an occurance of a byte within a byte array and returns its offset.
findTokenOccurance(String, String, int) - Method in class osmq.util.TokenFinder
Locates an occurance of a character within a string that matches a character in another string, and returns its offset.
findTokenOccurance(String, char, int) - Method in class osmq.util.TokenFinder
Locates an occurance of a character within a string and returns its offset.
fireCloseEvent() - Method in class osmq.util.StateEventBean
 
fireFailEvent() - Method in class osmq.util.StateEventBean
 
fireHaltEvent() - Method in class osmq.util.StateEventBean
 
fireInitializationEvent() - Method in class osmq.util.StateEventBean
 
firePauseEvent() - Method in class osmq.util.StateEventBean
 
fireSizeChangeEvent() - Method in class osmq.util.StateEventBean
 
fireSizeDecreaseEvent() - Method in class osmq.util.StateEventBean
 
fireSizeIncreaseEvent() - Method in class osmq.util.StateEventBean
 
fireStateEvent() - Method in class osmq.util.StateEventBean
 
fireSuccessEvent() - Method in class osmq.util.StateEventBean
 
fireTimeEvent() - Method in class osmq.util.StateEventBean
 
fireUnpauseEvent() - Method in class osmq.util.StateEventBean
 
first() - Method in class osmq.util.KeyedOrderedList
Returns the first KeyedData item in the collection, or null if the collection is empty.
firstKey() - Method in class osmq.util.IntMap
 
firstToken() - Method in class osmq.util.CSVParser
 
firstToken() - Method in class osmq.util.DelimitedArrayParser
 
firstToken() - Method in class osmq.util.DelimitedStringParser
 
floatValue() - Method in class osmq.datatypes.Decimal
 
floatValue() - Method in class osmq.datatypes.FixedDecimal
 
floatValue() - Method in class osmq.datatypes.Price
 
floor() - Method in class osmq.datatypes.FixedDecimal
 
floor(FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
flush() - Method in interface osmq.io.WriterStream
 
flush() - Method in class osmq.io.ZipPacketOutputStream
 
flush() - Method in class osmq.net.SocketStreamFilter
 
flushNamedQueue(String) - Method in class osmq.broker.BrokerEngine
 
flushNamedQueue(String) - Method in class osmq.broker.ChangeRequestor
 
flushToPullCount(long) - Method in class osmq.mque.MQue
Empty records from the queue until the pulled count equals a specific value
flushTopicFor(String) - Method in class osmq.broker.ChangeRequestor
 
formatDateString(String) - Static method in class osmq.util.DateFormatter
Converts an unformatted date in "ccyymmdd" format to a formatted date in "ccyy-mm-dd" format (adding hyphens).
formatSQLDateString(String) - Static method in class osmq.util.DateFormatter
 
fullShutDown() - Method in class osmq.broker.BrokerEngine
 

G

ge(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
ge(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
get(int) - Method in class osmq.records.CoreRecord
Returns an element in the record.
get(Object) - Method in class osmq.tables.KeyedRowList
 
get(int) - Method in class osmq.tables.KeyedRowList
 
get() - Method in class osmq.util.InputSimDevice
 
get(Object) - Method in class osmq.util.KeyedOrderedList
Returns the KeyedData item with the key value of k.
get(int) - Method in class osmq.util.KeyedOrderedList
Returns the KeyedData item at row position p;
get() - Method in class osmq.util.LongWrapper
 
get() - Method in interface osmq.util.ObjectWrapper
 
get() - Method in interface osmq.util.Readable
 
getActiveHandler() - Method in class osmq.broker.handlers.PubStatus
 
getAddressedCount() - Method in class osmq.clients.SubscriberCountManager
Returns the total number of messages received that were addressed to this clientid, i.e., the include a recipient identifier in the message.
getAgentCount() - Static method in class osmq.broker.handlers.PublisherHandler
 
getAgentCount() - Static method in class osmq.broker.handlers.RecoveryHandler
 
getAgentCount() - Static method in class osmq.broker.handlers.SubscriberHandler
 
getAlertInterval() - Method in class osmq.util.DurationTimer
 
getAlertInterval() - Method in class osmq.util.TickEventBean
 
getAll() - Method in class osmq.records.CoreRecord
Returns all elements as an array
getAnonymousCount() - Method in class osmq.clients.SubscriberCountManager
Returns the total number of topical messages received that were available to all subscribers of that topic.
getAsArray() - Method in interface osmq.records.DataRecord
Returns an array that contains all element values
getAsArray() - Method in class osmq.records.DataRecordBean
Returns an array that contains all element values in the DataRecord
getAsArray() - Method in class osmq.records.DataRecordWrapper
 
getAsDataRecord() - Method in class osmq.broker.StatsContainer
 
getAsDelimitedString() - Method in class osmq.records.CoreRecord
Returns the element values as a delimited string.
getAsXml() - Method in class osmq.tables.ColumnAttrib
 
getAvg() - Method in class osmq.util.Stats
 
getAvgRate() - Method in class osmq.util.EventRate
 
getAvgRate() - Method in class osmq.util.RateRegulator
 
getBigDecimal(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a BigDecimal
getBigDecimal(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a BigDecimal
getBigDecimal(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a BigDecimal
getBigDecimal(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a BigDecimal
getBigDecimal(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a BigDecimal
getBoolean(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a boolean
getBoolean(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a boolean
getBoolean(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a boolean
getBoolean(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a boolean
getBoolean(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a boolean
getBrokerEngine() - Static method in class osmq.broker.Singletons
Returns common instance of this class.
getBrokerName() - Method in interface osmq.clients.ClientAdapter
Returns the name of the remote message broker for this session.
getBrokerName() - Method in interface osmq.clients.Publisher
Returns the name of the remote message broker for this session.
getBrokerName() - Method in class osmq.clients.PublisherBean
Returns the name of the remote message broker for this session.
getBrokerName() - Method in interface osmq.clients.Subscriber
Returns the name of the remote message broker for this session.
getBrokerName() - Method in class osmq.clients.SubscriberBean
Returns the name of the remote message broker for this session.
getBrokerName() - Method in class osmq.clients.ThreadedPublisherBean
Returns the name of the remote message broker for this session.
getBrokerName() - Method in class osmq.clients.TopicSubscriberBean
Returns the name of the remote message broker for this session.
getBuffer() - Method in class osmq.mcns.MulticastListener
 
getBuffer() - Method in class osmq.util.DynByteArray
 
getBufferSize() - Method in class osmq.util.DynByteArray
 
getBufferSize() - Method in class osmq.util.InputSimDevice
 
getBuildSubscribersToTopic(String) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
getBuilderID() - Method in interface osmq.messages.MessageBuilder
 
getByte(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a byte
getByte(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a byte
getByte(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a byte
getByte(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a byte
getByte(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a byte
getBytes() - Method in class osmq.messages.MessageHeader
 
getBytes() - Method in interface osmq.records.DataRecord
Returns the elements as an array of bytes.
getBytes() - Method in class osmq.records.DataRecordBean
Returns the dataset elements as an array of bytes.
getBytes() - Method in class osmq.records.DataRecordWrapper
Returns the dataset elements as an array of bytes.
getBytes() - Method in interface osmq.util.ByteArray
Returns the object as an array of bytes.
getBytes() - Method in class osmq.util.ByteArrayImpl
 
getBytes(int, int, byte[], int) - Method in class osmq.util.ByteString
 
getBytesWritten() - Method in class osmq.mque.MQue
Returns the cumulative length (in bytes) of all elements that have been written to the queue.
getCCYYMMDD() - Method in class osmq.util.DateConverter
 
getChannel() - Method in class osmq.mcns.MCRequestor
 
getChannel() - Method in class osmq.mcns.MCResponder
 
getChannel() - Method in class osmq.mcns.MulticastListener
 
getChar(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a char
getChar(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a char
getChar(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a char
getChar(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a char
getChar(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a char
getChildProcessedCount() - Method in class osmq.broker.handlers.ServerSocketProcessor
 
getClientBytes() - Method in interface osmq.messages.DataSetMessage
Returns the client (body) data as an array of bytes.
getClientBytes() - Method in class osmq.messages.DataSetMessageBean
Returns the client (body) data as an array of bytes.
getClientBytes() - Method in class osmq.messages.MessageBean
Returns the client (body) data as an array of bytes.
getClientID() - Method in interface osmq.clients.ClientAdapter
Returns the client identifier used by this session to communicate with the message broker.
getClientID() - Method in class osmq.clients.ClientIdentifier
 
getClientID() - Method in interface osmq.clients.Publisher
Returns the client identifier used by this session to communicate with the message broker.
getClientID() - Method in class osmq.clients.PublisherBean
Returns the client identifier used by this session to communicate with the message broker.
getClientID() - Method in interface osmq.clients.Subscriber
Returns the client identifier used by this session to communicate with the message broker.
getClientID() - Method in class osmq.clients.SubscriberBean
Returns the client identifier used by this session to communicate with the message broker.
getClientID() - Method in class osmq.clients.ThreadedPublisherBean
Returns the client identifier used by this session to communicate with the message broker.
getClientID() - Method in class osmq.clients.TopicSubscriberBean
Returns the client identifier used by this session to communicate with the message broker.
getClientIdentifier() - Method in class osmq.clients.ClientStream
 
getClientName() - Method in class osmq.broker.RemoteLogger
 
getClientText() - Method in class osmq.messages.MessageBean
Returns the client (body) data as a text String
getClock() - Method in class osmq.util.DurationTimer
 
getClone() - Method in class osmq.records.DataRecordBean
 
getColPosn() - Method in class osmq.uicontrols.BaseSyncField
 
getColonDelimitedHHMMSS() - Method in class osmq.util.Duration
 
getColumn(int) - Method in class osmq.tables.RowAttrib
 
getColumnAttrib(int) - Method in class osmq.tables.TableAttrib
 
getColumnClass(int) - Method in class osmq.tables.KeyedRowList
 
getColumnClass(int) - Method in class osmq.tables.KeyedRowTableModel
 
getColumnClass(int) - Method in class osmq.tables.ListenerTableMap
 
getColumnClass(int) - Method in class osmq.tables.TableAttrib
 
getColumnCount() - Method in class osmq.tables.KeyedRowList
 
getColumnCount() - Method in class osmq.tables.KeyedRowTableModel
 
getColumnCount() - Method in class osmq.tables.ListenerTableMap
 
getColumnDataType(int) - Method in class osmq.tables.RowAttrib
 
getColumnDataType(int) - Method in class osmq.tables.TableAttrib
 
getColumnName(int) - Method in class osmq.tables.KeyedRowList
 
getColumnName(int) - Method in class osmq.tables.KeyedRowTableModel
 
getColumnName(int) - Method in class osmq.tables.ListenerTableMap
 
getColumnName(int) - Method in class osmq.tables.TableAttrib
 
getColumnPreferredWidth(int) - Method in class osmq.tables.TableAttrib
 
getConnectionCount() - Method in interface osmq.clients.Subscriber
Returns the number of messages received by all subscriber threads in this application.
getConnectionCount() - Method in class osmq.clients.SubscriberBean
Returns a SubscriberCountManager that accumulates message counts for all ClientSubcribers associated with this connection.
getConnectionCount() - Method in class osmq.clients.TopicSubscriberBean
Returns a SubscriberCountManager that accumulates message counts for all ClientSubcribers associated with this connection.
getConnectionHandler() - Method in class osmq.clients.SubscriberBean
 
getConnectionHandler() - Method in class osmq.clients.TopicSubscriberBean
 
getConnectionPublishedCount() - Method in interface osmq.clients.Publisher
Returns the number of messages that have been published using this publisher's connection.
getConsolidatedSize(QueueStats) - Method in class osmq.broker.subqueues.SubscriberQueues
Return the consolidated number of element contained in all the queues contained in the set.
getContentSize() - Method in class osmq.util.DynByteArray
 
getControlMessageBuilder() - Method in class osmq.clients.BatchPublisher
Returns a reference to the MessageBuilder that will create preliminary and final control messages.
getCorrelationNumber() - Method in interface osmq.messages.DataSetMessage
Gets the identifier used to identify a group of transactions as related.
getCorrelationNumber() - Method in class osmq.messages.DataSetMessageBean
Gets the identifier used to identify a group of transactions as related.
getCorrelationNumber() - Method in interface osmq.messages.MessageAttributes
Gets the message attribute used to identify a group of related transactions.
getCorrelationNumber() - Method in class osmq.messages.MessageBean
Gets the identifier used to identify a group of transactions as related.
getCorrelationNumber() - Method in class osmq.messages.MessageHeader
Gets the identifier used to identify a group of transactions as related.
getCorrelationString() - Method in interface osmq.messages.DataSetMessage
 
getCorrelationString() - Method in class osmq.messages.DataSetMessageBean
 
getCorrelationString() - Method in interface osmq.messages.MessageAttributes
 
getCorrelationString() - Method in class osmq.messages.MessageBean
 
getCorrelationString() - Method in class osmq.messages.MessageHeader
 
getCount() - Method in class osmq.broker.RemoteLogger
 
getCount() - Method in class osmq.util.Accumulator
 
getCount() - Method in class osmq.util.CSVParser
 
getCount() - Method in class osmq.util.DelimitedArrayParser
 
getCount() - Method in class osmq.util.DelimitedStringParser
 
getCount() - Method in class osmq.util.EventRateBean
 
getCount() - Method in class osmq.util.EventRateMgr
Returns the number of events that have occured since the manager was instantiated or the manager was reset.
getCount() - Method in class osmq.util.Stats
 
getCount() - Method in class osmq.util.TopicsListeners
 
getCountFor(String) - Method in class osmq.util.IntMap
 
getCounter() - Method in class osmq.util.EventRate
 
getCounter() - Method in class osmq.util.EventRateMgr
 
getCounter() - Method in class osmq.util.SimpleEventRate
 
getCurrentFifo(String) - Method in class osmq.broker.subqueues.SubscriberQueues
 
getDataRecord() - Method in class osmq.broker.BrokerEngine
 
getDataRecord() - Method in class osmq.broker.PulsarManager
 
getDataRecord() - Method in class osmq.messages.MessageBean
Returns the client (body) data as a DataRecord.
getDataRecord() - Method in interface osmq.records.DataRecordGenerator
 
getDataRecord() - Method in class osmq.records.RecordFileReader
 
getDataRecord() - Method in class osmq.util.ThreadedReader
 
getDataRecordListener() - Method in class osmq.pulsar.DatasetPulsarListener
 
getDataRow(int) - Method in class osmq.tables.SortingTableModel
 
getDataType() - Method in class osmq.tables.ColumnAttrib
 
getDate(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a java.util.Date
getDate(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a java.util.Date
getDate(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a Date
getDate(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a Date
getDate(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a Java Date
getDated() - Method in interface osmq.logs.Log
 
getDated() - Method in class osmq.logs.PrintWriterLog
 
getDay() - Method in class osmq.util.DateConverter
 
getDayStamp() - Static method in class osmq.util.DateStamp
 
getDecPlaces() - Method in class osmq.datatypes.FactorUtil
 
getDefaultDelimiter() - Method in interface osmq.records.DataRecord
Returns the character that is used to delimit the various elements when the elements are strung together.
getDefaultDelimiter() - Method in class osmq.records.DataRecordBean
 
getDefaultDelimiter() - Method in class osmq.records.DataRecordWrapper
 
getDefaultListener() - Method in class osmq.util.TopicsListeners
 
getDefaultMessageListener() - Method in class osmq.clients.TopicSubscriberBean
 
getDefaultParms() - Static method in class osmq.broker.config.StartupParms
 
getDelayInSeconds() - Method in class osmq.pulsar.DynamicPulsar
 
getDelimitedHHMMSS(String) - Method in class osmq.util.Duration
 
getDelimiter() - Method in class osmq.util.CSVParser
 
getDevice() - Method in class osmq.util.ThreadedReader
 
getDottedGroupAddress() - Method in class osmq.mcns.MCResponder
 
getDottedGroupAddress() - Method in class osmq.mcns.MulticastListener
 
getDouble() - Method in class osmq.datatypes.Decimal
 
getDouble() - Method in class osmq.datatypes.Price
 
getDouble(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a double
getDouble(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a double
getDouble(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a double
getDouble(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a double
getDouble(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a double
getDouble(String) - Method in class osmq.uicontrols.Formatter
 
getDuplicate() - Method in class osmq.util.DynByteArray
 
getDurationMillis() - Method in class osmq.util.Timer
 
getDurationSeconds() - Method in class osmq.util.DurationClock
Returns duration in seconds
getDurationSeconds() - Method in class osmq.util.Timer
 
getDurationSecondsAsDouble() - Method in class osmq.util.Timer
 
getElementCount() - Method in interface osmq.messages.DataSetMessage
Returns the number of positions in the message body (including those that are empty)
getElementCount() - Method in class osmq.messages.DataSetMessageBean
Returns the number of positions in the DataRecord (including those that are empty)
getElementCount() - Method in interface osmq.records.DataRecord
Returns the number of element positions (including those that are empty)
getElementCount() - Method in class osmq.records.DataRecordBean
 
getElementCount() - Method in class osmq.records.DataRecordWrapper
Returns the number of positions in the DataRecord (including those that are empty)
getElementsAsString() - Method in interface osmq.messages.DataSetMessage
Returns the message body as a delimited String.
getElementsAsString() - Method in class osmq.messages.DataSetMessageBean
Returns the message body as a delimited String.
getEventCount() - Method in class osmq.mque.MQue
Returns the number of element read events.
getEventCount() - Method in interface osmq.util.EventCounter
 
getEventCount() - Method in class osmq.util.EventCounterImpl
 
getEventCount() - Method in class osmq.util.RateRegulator
 
getEventRate() - Method in class osmq.broker.StatsEngine
 
getException() - Method in class osmq.logs.PrintWriterLog
Returns Exception from last unsuccessful println() call
getExceptionListener() - Method in interface osmq.clients.ClientAdapter
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in interface osmq.clients.Publisher
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in class osmq.clients.PublisherBean
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in interface osmq.clients.Subscriber
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in class osmq.clients.SubscriberBean
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in class osmq.clients.ThreadedPublisherBean
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in class osmq.clients.TopicSubscriberBean
Return the ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
getExceptionListener() - Method in class osmq.pulsar.DatasetPulsarListener
 
getExceptionListener() - Method in class osmq.util.AbstractThreadable
Return the ExceptionListener that will be notified when there is an exception due to an I/O or communications failure.
getExceptionListener() - Method in class osmq.util.ExceptionListenerBase
 
getExceptionListener() - Method in class osmq.util.Threaded
 
getFactor() - Method in class osmq.datatypes.FactorUtil
 
getFieldsRead() - Method in class osmq.util.FixedLengthRecord
 
getFileName() - Method in class osmq.broker.RemoteLogger
 
getFileName() - Method in class osmq.broker.subqueues.TopicSubscriptions
 
getFileName() - Method in class osmq.util.InputSimDevice
 
getFilterListener() - Method in class osmq.util.ThreadedReader
 
getFirstTopic() - Method in class osmq.broker.subqueues.SubscriberQueue
 
getFloat(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a float
getFloat(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a float
getFloat(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a float
getFloat(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a float
getFloat(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a float
getFocusBuilder() - Method in class osmq.clients.BatchPublisher
 
getFocusBuilderName() - Method in class osmq.clients.BatchPublisher
 
getFormat() - Method in interface osmq.messages.DataSetMessage
Identifies the body format as either dataset, text or binary.
getFormat() - Method in class osmq.messages.DataSetMessageBean
Identifies the body format as either dataset, text or binary.
getFormat() - Method in interface osmq.messages.MessageAttributes
Identifies the body format as either dataset, text or binary.
getFormat() - Method in class osmq.messages.MessageBean
Identifies the body format as either text or binary.
getFormat() - Method in class osmq.messages.MessageHeader
 
getFormatMask() - Method in class osmq.datatypes.FactorUtil
 
getFormattedDateString(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message object as a formatted date string in CCYY-MM-DD format.
getFormattedDateString(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message object as a formatted date string in CCYY-MM-DD format.
getFormattedDateString(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a formatted date string in CCYY-MM-DD format.
getFormattedDateString(int) - Method in class osmq.records.DataRecordBean
 
getFormattedDateString(int) - Method in class osmq.records.DataRecordWrapper
 
getFormattedStamp() - Static method in class osmq.util.DateStamp
 
getFormattedString() - Method in class osmq.datatypes.Decimal
 
getFormattedString() - Method in class osmq.datatypes.Price
 
getFormattedString() - Method in class osmq.util.LongFormatter
 
getFreeMemory() - Static method in class osmq.util.RuntimeInfo
 
getFreeMemoryString() - Static method in class osmq.util.RuntimeInfo
 
getFrequency() - Method in class osmq.broker.PulsarManager
 
getGCFreeMemory() - Static method in class osmq.util.RuntimeInfo
 
getGenerator() - Method in class osmq.pulsar.DynamicPulsar
 
getGroupAddress() - Method in class osmq.mcns.NetworkScope
 
getGroupAddress() - Method in class osmq.pulsar.DynamicPulsar
 
getGroupAddress() - Method in class osmq.pulsar.ServicePulsar
 
getHeader() - Method in interface osmq.messages.DataSetMessage
Returns the message header values.
getHeader() - Method in class osmq.messages.DataSetMessageBean
Returns the message header values.
getHeader() - Method in class osmq.messages.MessageBean
Returns the message header values.
getHeaderBytes() - Method in interface osmq.messages.DataSetMessage
Returns the header data as an array of bytes.
getHeaderBytes() - Method in class osmq.messages.DataSetMessageBean
Returns the header data as an array of bytes.
getHeaderBytes() - Method in class osmq.messages.MessageBean
Returns the header data as an array of bytes.
getHostName() - Method in interface osmq.clients.ClientAdapter
Returns the message broker's host address as a DNS host name or IP address.
getHostName() - Method in interface osmq.clients.Publisher
Returns the message broker's host address as a DNS host name or IP address.
getHostName() - Method in class osmq.clients.PublisherBean
 
getHostName() - Method in interface osmq.clients.Subscriber
Returns the message broker's host address as a DNS host name or IP address.
getHostName() - Method in class osmq.clients.SubscriberBean
 
getHostName() - Method in class osmq.clients.ThreadedPublisherBean
 
getHostName() - Method in class osmq.clients.TopicSubscriberBean
 
getHostName() - Method in class osmq.net.RemoteService
 
getHostName() - Method in class osmq.net.RemoteServiceWrapper
 
getHours() - Method in class osmq.util.Duration
 
getID() - Method in class osmq.util.StateEvent
 
getID() - Method in class osmq.util.TickEvent
 
getIdentifier() - Method in class osmq.clients.TopicChangeRequestor
 
getImpliedDecimalString(int, int) - Method in class osmq.util.FixedLengthRecord
Trims leading spaces from the resulting string.
getInetAddress() - Method in class osmq.net.SocketStreamFilter
 
getInstanceName() - Method in class osmq.mque.MQue
Returns a name associated with this MQue instance.
getInt() - Method in class osmq.datatypes.Decimal
 
getInt() - Method in class osmq.datatypes.Price
 
getInt(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as an integer.
getInt(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as an integer.
getInt(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as an integer
getInt(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as an integer
getInt(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as an integer.
getIntegerString(int) - Method in class osmq.util.FixedLengthRecord
Trims leading spaces from the resulting string.
getIpAddress() - Method in class osmq.broker.subqueues.SubscriberQueue
 
getItemClass() - Method in class osmq.tables.ColumnAttrib
 
getIterations() - Method in class osmq.util.ThreadBean
Returns the number of time the derived class's iterativeProces() has been invoked successfully.
getIterations() - Method in class osmq.util.Threaded
Returns the number of time the derived class's iterativeProces() has been invoked successfully.
getIterator() - Method in class osmq.broker.subqueues.SubscriberQueues
 
getIterator() - Method in class osmq.tables.KeyedRowList
 
getIterator() - Method in class osmq.util.KeyedOrderedList
Returns an iterator to the KeyedOrderedList.
getIterator() - Method in class osmq.util.TopicSet
 
getIteratorOfTopics() - Method in class osmq.broker.subqueues.TopicSubscriptions
 
getKey() - Method in interface osmq.messages.DataSetMessage
Returns the unique identifier for the data contained in the message.
getKey() - Method in class osmq.messages.DataSetMessageBean
Returns the unique identifier for the data contained in the message.
getKey() - Method in interface osmq.messages.MessageAttributes
Returns the unique identifier for the data contained in the message.
getKey() - Method in class osmq.messages.MessageBean
Returns the unique identifier for the data contained in the message.
getKey() - Method in class osmq.messages.MessageHeader
Returns the unique identifier for the data contained in the message.
getKey() - Method in class osmq.records.KeyedDataRecordBean
 
getKey() - Method in interface osmq.util.KeyedData
 
getKeyAsInt() - Method in interface osmq.messages.DataSetMessage
 
getKeyAsInt() - Method in class osmq.messages.DataSetMessageBean
 
getKeyAsInt() - Method in interface osmq.messages.MessageAttributes
 
getKeyAsInt() - Method in class osmq.messages.MessageBean
 
getKeyAsInt() - Method in class osmq.messages.MessageHeader
 
getLastChange() - Method in class osmq.tables.KeyedRowList
 
getLastChange() - Method in class osmq.util.KeyedOrderedList
 
getLastFound() - Method in class osmq.util.TokenFinder
 
getLastPacketSize() - Method in class osmq.io.PacketInputStream
 
getLocalAddress() - Method in class osmq.broker.BrokerEngine
 
getLocalCount() - Method in class osmq.broker.handlers.PublisherHandler
 
getLong(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a long integer
getLong(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a long integer
getLong(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a long integer
getLong(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a long
getLong(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a long integer
getLong(String) - Method in class osmq.uicontrols.Formatter
 
getLong() - Method in class osmq.util.LongFormatter
 
getMask() - Method in class osmq.uicontrols.Formatter
 
getMask() - Method in class osmq.uicontrols.SyncDoubleField
 
getMask() - Method in class osmq.uicontrols.SyncTextField
 
getMax() - Method in class osmq.util.Stats
 
getMaxRate() - Method in class osmq.clients.BatchPublisher
Returns the maximum rate (in messages-per-second) at which message will be published.
getMaxThreshold() - Method in class osmq.mque.MQue
Returns the maximum capacity threshold (element count).
getMessage() - Method in interface osmq.messages.MessageBuilder
This method represents the method that builds the message content.
getMessage() - Method in class osmq.util.ThreadedReader
 
getMessageAsBytes() - Method in interface osmq.messages.DataSetMessage
Returns the message header and body as an array of bytes.
getMessageAsBytes() - Method in class osmq.messages.DataSetMessageBean
Returns the message header and body as an array of bytes.
getMessageAsBytes() - Method in interface osmq.messages.Message
 
getMessageAsBytes() - Method in class osmq.messages.MessageBean
Returns the message (header and body) as an array of bytes
getMessageAsString() - Method in class osmq.messages.MessageBean
Returns the message (header and body) as a text String.
getMessageCount() - Static method in class osmq.broker.handlers.PublisherHandler
 
getMessageCount() - Static method in class osmq.broker.handlers.RecoveryHandler
 
getMessageCount() - Static method in class osmq.broker.handlers.SubscriberHandler
 
getMessageCount() - Method in class osmq.clients.SubscriberCountManager
Returns the total number of messages received by this session, whether they were topical or recipient based.
getMessageListener() - Method in interface osmq.clients.Subscriber
Returns a reference to the MessageListener object that currently receives all topical and point-to-point messages for this client.
getMessageListener() - Method in class osmq.clients.SubscriberBean
 
getMessageListener() - Method in class osmq.util.TopicSet
 
getMillis() - Static method in class osmq.util.DateStamp
 
getMin() - Method in class osmq.util.Stats
 
getMinutes() - Method in class osmq.util.Duration
 
getModel() - Method in class osmq.tables.ListenerTableMap
 
getMonth() - Method in class osmq.util.DateConverter
 
getNElements(int, byte[], String[]) - Method in class osmq.util.DelimitedArrayParser
Passed a byte array that contains a delimited string.
getName() - Method in class osmq.broker.handlers.PubStatus
 
getNewRate() - Method in class osmq.util.EventRate
 
getNext() - Method in class osmq.tables.KeyedRowList
 
getNext() - Method in class osmq.util.KeyedOrderedList
First call returns the first KeyedData item in the collection, and subsequent calls return each of the subsequent items.
getNext() - Method in class osmq.util.ThreadedReader
 
getNextPacket() - Method in class osmq.mcns.MulticastListener
 
getObject(int) - Method in interface osmq.messages.DataSetMessage
Returns the value of the designated position in the message body.
getObject(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value of the designated position in the message body.
getObject(int) - Method in interface osmq.records.DataRecord
Returns the value of the designated position.
getObject(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as an Object
getObject(int) - Method in class osmq.records.DataRecordWrapper
Returns the value of the designated position in the DataRecord.
getOccurance() - Method in class osmq.util.StringParser
 
getOccurance() - Method in class osmq.util.TokenFinder
 
getOffsetIndex() - Method in interface osmq.messages.DataSetMessage
Returns the base index currently used to reference elements in the message body.
getOffsetIndex() - Method in class osmq.messages.DataSetMessageBean
Returns the base index currently used to reference elements in the message body.
getOffsetIndex() - Method in interface osmq.records.DataRecord
Returns the base index currently used to reference elements.
getOffsetIndex() - Method in class osmq.records.DataRecordBean
Returns the base index currently used to reference elements in the DataRecord.
getOffsetIndex() - Method in class osmq.records.DataRecordWrapper
Returns the base index currently used to reference elements in the DataRecord.
getOriginator() - Method in interface osmq.messages.DataSetMessage
Returns the identifier of the message sender (publisher).
getOriginator() - Method in class osmq.messages.DataSetMessageBean
Returns the identifier of the message sender (publisher).
getOriginator() - Method in interface osmq.messages.MessageAttributes
Returns the identifier of the message sender (publisher).
getOriginator() - Method in class osmq.messages.MessageBean
Returns the identifier of the message sender (publisher).
getOriginator() - Method in class osmq.messages.MessageHeader
Returns the identifier of the message sender (publisher).
getOutputQueue() - Method in class osmq.util.ThreadedReader
 
getPagingThreshold() - Method in class osmq.mque.MQue
Returns the paging threshold (in elements).
getPeakRate() - Method in class osmq.util.EventRate
 
getPipeline() - Static method in class osmq.broker.sorter.Pipeline
 
getPort() - Method in class osmq.broker.BrokerEngine
 
getPortID() - Method in class osmq.broker.handlers.ServerSocketProcessor
 
getPortID() - Method in interface osmq.clients.ClientAdapter
Returns the port ID that will be used to connect to the message broker.
getPortID() - Method in interface osmq.clients.Publisher
Returns the port id that will be used to connect to the message broker.
getPortID() - Method in class osmq.clients.PublisherBean
 
getPortID() - Method in interface osmq.clients.Subscriber
Returns the port ID that will be used to connect to the message broker.
getPortID() - Method in class osmq.clients.SubscriberBean
 
getPortID() - Method in class osmq.clients.ThreadedPublisherBean
 
getPortID() - Method in class osmq.clients.TopicSubscriberBean
 
getPortID() - Method in class osmq.net.DiscoveryServer
 
getPortID() - Method in class osmq.net.RemoteService
 
getPortID() - Method in class osmq.net.RemoteServiceWrapper
 
getPortID() - Method in class osmq.net.ServerSocketProcessor
 
getPosition() - Method in class osmq.util.StringParser
 
getPrecision() - Method in class osmq.util.DecimalConverter
 
getPriority() - Method in class osmq.broker.sorter.MessageSortingThread
 
getPriority() - Method in class osmq.util.AbstractThreadable
 
getPriority() - Method in interface osmq.util.Threadable
 
getPriority() - Method in class osmq.util.Threaded
 
getPriority() - Method in class osmq.util.TickEventBean
 
getPubName() - Method in class osmq.broker.handlers.PublisherHandler
 
getPublishedCount() - Method in class osmq.broker.handlers.PubStatus
 
getPublishedCount() - Method in interface osmq.clients.Publisher
Returns the number of messages that have been published by this Publisher.
getPullCount() - Method in class osmq.mque.MQue
Returns the number of elements that have been read from the queue since it was instantiated.
getPulsarPort() - Method in class osmq.pulsar.DatasetPulsarListener
 
getPulsarPort() - Method in class osmq.pulsar.HeartbeatListener
 
getPulsarRate() - Method in class osmq.broker.BrokerEngine
 
getPushCount() - Method in class osmq.mque.MQue
Returns the number of elements that have been written to the queue since it was instantiated.
getQeFlag() - Method in class osmq.mque.QueueException
 
getQueueCount() - Method in class osmq.broker.subqueues.SubscriberQueues
 
getQueuedCount() - Method in class osmq.clients.ThreadedPublisherBean
 
getRate() - Method in class osmq.util.EventRateBean
 
getRate() - Method in class osmq.util.SimpleEventRate
 
getRatePerSec() - Method in class osmq.util.EventRateMgr
 
getRawSeconds() - Method in class osmq.util.Duration
 
getRebuildFrequency() - Method in class osmq.broker.StatsEngine
 
getRecipient() - Method in interface osmq.messages.DataSetMessage
Returns the identifier of the message recipient, or null if the message is intended for all subscriber to the message topic.
getRecipient() - Method in class osmq.messages.DataSetMessageBean
Returns the identifier of the message recipient, or null if the message is intended for all subscriber to the message topic.
getRecipient() - Method in interface osmq.messages.MessageAttributes
Returns the identifier of the message recipient, or null if the message is intended for all subscriber to the message topic.
getRecipient() - Method in class osmq.messages.MessageBean
Returns the identifier of the message recipient, or null if the message is intended for all subscriber to the message topic.
getRecipient() - Method in class osmq.messages.MessageHeader
Returns the identifier of the message recipient, or null if the message is intended for all subscriber to the message topic.
getRecord() - Method in class osmq.pulsar.ServicePulsar
 
getRecordValue() - Method in class osmq.util.FixedLengthRecord
 
getRecoveryQueue() - Static method in class osmq.broker.handlers.RecoveryHandler
 
getRefreshedStats() - Method in class osmq.broker.StatsEngine
 
getRemoteAddress() - Method in class osmq.mcns.MulticastListener
 
getRemoteAddressString() - Method in class osmq.mcns.MulticastListener
 
getRemoteData() - Method in class osmq.mcns.MulticastListener
 
getRemoteIPString() - Method in class osmq.broker.handlers.PubStatus
 
getRemoteIPString() - Method in class osmq.broker.handlers.ServiceHandler
 
getRemoteMonitorIP() - Static method in class osmq.broker.handlers.ChangeHandler
 
getRemotePort() - Method in class osmq.mcns.MulticastListener
 
getRemoteService() - Method in class osmq.net.RemoteServiceWrapper
 
getRole() - Method in class osmq.clients.ClientStream
 
getRowCount() - Method in class osmq.tables.KeyedRowList
 
getRowCount() - Method in class osmq.tables.KeyedRowTableModel
 
getRowCount() - Method in class osmq.tables.ListenerTableMap
 
getRowCount() - Method in class osmq.uicontrols.ScrollingKeyedTable
 
getRowListenerList() - Method in class osmq.uicontrols.BaseSyncField
 
getRuntimeClock() - Method in class osmq.broker.BrokerEngine
 
getRuntimeClock() - Method in class osmq.broker.StatsEngine
 
getSQLDate(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message object as an SQL date
getSQLDate(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message object as an SQL date
getSQLDate(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a java.SQL.Date
getSQLDate(int) - Method in class osmq.records.DataRecordBean
 
getSQLDate(int) - Method in class osmq.records.DataRecordWrapper
 
getSaveFileName() - Method in class osmq.broker.subqueues.SubscriberQueue
 
getSaveFileName() - Method in class osmq.mque.PersistableMQue
 
getScope() - Static method in class osmq.mcns.NetworkScope
 
getSeconds() - Method in class osmq.util.Duration
 
getSelectedDataRow() - Method in class osmq.tables.KeyedRowTableModel
 
getSelectedVisRow() - Method in class osmq.tables.KeyedRowTableModel
 
getSequenceNumber() - Method in interface osmq.messages.DataSetMessage
Returns the relative sequence number of this message.
getSequenceNumber() - Method in class osmq.messages.DataSetMessageBean
Returns the relative sequence number of this message.
getSequenceNumber() - Method in interface osmq.messages.MessageAttributes
Returns the relative sequence number of this message.
getSequenceNumber() - Method in class osmq.messages.MessageBean
Returns the relative sequence number of this message.
getSequenceNumber() - Method in class osmq.messages.MessageHeader
Returns the relative sequence number of this message.
getSequenceNumber() - Method in class osmq.util.ThreadBean
 
getSequenceNumber() - Method in class osmq.util.Threaded
 
getServiceChannel() - Method in class osmq.pulsar.DynamicPulsar
 
getServiceID() - Method in class osmq.net.DiscoveryServer
 
getServiceID() - Method in class osmq.net.RemoteService
 
getServiceID() - Method in class osmq.net.RemoteServiceWrapper
 
getServiceName() - Method in class osmq.broker.BrokerEngine
 
getServiceName() - Method in class osmq.broker.RemoteLogger
 
getServiceName() - Method in class osmq.broker.SlaveRouterProcessor
 
getServiceName() - Method in class osmq.pulsar.ServicePulsar
 
getServicePort() - Method in class osmq.pulsar.ServicePulsar
 
getSessionCount() - Method in interface osmq.clients.Subscriber
Returns the number of messages received by this Subscriber instance.
getSessionCount() - Method in class osmq.clients.SubscriberBean
Returns a SubscriberCountManager that accumulates message counts for this ClientSubscriber instance.
getSessionCount() - Method in class osmq.clients.TopicSubscriberBean
Returns a SubscriberCountManager that accumulates message counts for this ClientSubscriber instance.
getShort(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a short integer
getShort(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a short integer
getShort(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a short integer
getShort(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a short
getShort(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a short integer
getSingleton() - Static method in class osmq.net.DiscoveryClient
 
getSingleton() - Static method in class osmq.util.ShutdownManager
 
getSlashDelimitedHHMMSS() - Method in class osmq.util.Duration
 
getSlaveQueueCount() - Method in class osmq.broker.BrokerEngine
 
getSlaveQueueCount() - Method in class osmq.broker.SlaveRouterProcessor
 
getSorter() - Static method in class osmq.broker.Singletons
 
getStamp() - Static method in class osmq.util.DateStamp
 
getStateEventListener() - Method in class osmq.broker.BrokerEngine
 
getStats() - Method in class osmq.broker.BrokerEngine
 
getStats() - Method in class osmq.broker.PulsarManager
 
getStatsEngine() - Method in class osmq.broker.BrokerEngine
 
getStreamFilter() - Method in class osmq.broker.handlers.ServiceHandler
 
getStreamMode() - Method in class osmq.net.RemoteService
 
getStreamMode() - Method in class osmq.net.RemoteServiceWrapper
 
getString() - Method in class osmq.datatypes.Decimal
 
getString() - Method in class osmq.datatypes.Price
 
getString(int) - Method in interface osmq.messages.DataSetMessage
Returns the value of the designated position in the message body as a String
getString(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value of the designated position in the message body as a String
getString() - Method in interface osmq.pulsar.StringGenerator
 
getString(int) - Method in interface osmq.records.DataRecord
Returns the value of the designated position as a String
getString(int) - Method in class osmq.records.DataRecordBean
Gets the value at the designated position in the DataRecord object as a String
getString(int) - Method in class osmq.records.DataRecordWrapper
Returns the value of the designated position in the DataRecord object as a String
getString() - Method in class osmq.util.ThreadedReader
 
getStringMillis() - Static method in class osmq.util.DateStamp
 
getSubscriberAndTopicSetIterator() - Method in class osmq.broker.subqueues.TopicSubscriptions
 
getSubscriberAndTopicSetIterator() - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
getSubscriberCountsContainer() - Method in class osmq.broker.StatsContainer
 
getSubscriberQueues() - Static method in class osmq.broker.Singletons
 
getSubscribersToTopic(String) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
getTableAttrib() - Method in class osmq.tables.KeyedRowTableModel
 
getTableAttrib() - Method in class osmq.uicontrols.KeyedTable
 
getTableAttributes() - Method in class osmq.tables.KeyedRowList
 
getText() - Method in class osmq.messages.MessageHeader
 
getText() - Method in interface osmq.records.DataRecord
Creates a delimited String from the elements The first character in the String is assumed to be the delimiting character.
getText() - Method in class osmq.records.DataRecordBean
Creates a delimited String from the DataRecord elements.
getText() - Method in class osmq.records.DataRecordWrapper
Creates a delimited String from the DataRecord elements The first character in the String is assumed to be the delimiting character.
getText(double) - Method in class osmq.uicontrols.Formatter
 
getText(long) - Method in class osmq.uicontrols.Formatter
 
getText(String) - Method in class osmq.uicontrols.Formatter
 
getText(int) - Method in class osmq.util.FixedLengthRecord
 
getThreadPriority() - Method in interface osmq.clients.Subscriber
Returns the thread priority that will be used by the message subscriber thread.
getThreadPriority() - Method in class osmq.clients.SubscriberBean
 
getThreadPriority() - Method in class osmq.clients.TopicSubscriberBean
 
getThreadable() - Method in class osmq.util.ThreadBean
 
getThreshold() - Method in class osmq.util.Accumulator
 
getThrottleRate() - Method in class osmq.util.RateRegulator
 
getTimeStamp() - Method in interface osmq.messages.DataSetMessage
Returns a timestamp indicating when the message was sent.
getTimeStamp() - Method in class osmq.messages.DataSetMessageBean
Returns a timestamp indicating when the message was sent.
getTimeStamp() - Method in interface osmq.messages.MessageAttributes
Returns a timestamp indicating when the message was sent.
getTimeStamp() - Method in class osmq.messages.MessageBean
Returns a timestamp indicating when the message was sent.
getTimeStamp() - Method in class osmq.messages.MessageHeader
Returns a timestamp indicating when the message was sent.
getTimeStamp() - Static method in class osmq.util.DateStamp
 
getTimeToLive() - Method in class osmq.mcns.MCResponder
 
getTimeToLive() - Method in class osmq.mcns.MulticastListener
 
getTimed() - Method in interface osmq.logs.Log
 
getTimed() - Method in class osmq.logs.PrintWriterLog
 
getTimeoutSeconds() - Method in class osmq.pulsar.DatasetPulsarListener
 
getTimeoutSeconds() - Method in class osmq.pulsar.HeartbeatListener
 
getTimeoutSecs() - Method in class osmq.mcns.MulticastListener
 
getTitle() - Method in class osmq.tables.ColumnAttrib
 
getToken(int) - Method in class osmq.util.CSVParser
 
getToken(int) - Method in class osmq.util.DelimitedArrayParser
 
getToken(int) - Method in class osmq.util.DelimitedStringParser
 
getTopic() - Method in interface osmq.messages.DataSetMessage
Returns the topic of the message.
getTopic() - Method in class osmq.messages.DataSetMessageBean
Returns the topic of the message.
getTopic() - Method in interface osmq.messages.MessageAttributes
Returns the topic of the message.
getTopic() - Method in class osmq.messages.MessageBean
Returns the topic of the message.
getTopic() - Method in class osmq.messages.MessageHeader
Returns the topic of the message.
getTopicCount() - Method in class osmq.broker.subqueues.TopicSubscriptions
 
getTopicCount() - Method in class osmq.clients.TopicSubscriberBean
 
getTotalBuilders() - Method in class osmq.clients.BatchPublisher
 
getTotalMemory() - Static method in class osmq.util.RuntimeInfo
 
getTotalMemoryString() - Static method in class osmq.util.RuntimeInfo
 
getTransaction() - Method in interface osmq.messages.DataSetMessage
Returns the identifier of the event or activity that caused the transaction to be generated.
getTransaction() - Method in class osmq.messages.DataSetMessageBean
Returns the identifier of the event or activity that caused the transaction to be generated.
getTransaction() - Method in interface osmq.messages.MessageAttributes
Returns the identifier of the event or activity that caused the transaction to be generated.
getTransaction() - Method in class osmq.messages.MessageBean
Returns the identifier of the event or activity that caused the transaction to be generated.
getTransaction() - Method in class osmq.messages.MessageHeader
Returns the identifier of the event or activity that caused the transaction to be generated.
getTransactionAsChar() - Method in interface osmq.messages.DataSetMessage
Returns the first character of the event identifer, or a null character if there is no event identifer
getTransactionAsChar() - Method in class osmq.messages.DataSetMessageBean
Returns the first character of the event identifer, or a null character if there is no event identifer
getTransactionAsChar() - Method in interface osmq.messages.MessageAttributes
Returns the first character of the transaction identifer, or a null character if there is no transaction identifer.
getTransactionAsChar() - Method in class osmq.messages.MessageBean
Returns the first character of the event identifer, or a null character if there is no event identifer
getTransactionAsChar() - Method in class osmq.messages.MessageHeader
Returns the first character of the event identifer, or a null character if there is no event identifer
getTtl() - Method in class osmq.mcns.NetworkScope
 
getType() - Method in interface osmq.messages.DataSetMessage
Identifies the message event type -- normally either MessageType.NOTIFICATION or MessageType.REQUEST.
getType() - Method in class osmq.messages.DataSetMessageBean
Identifies whether the event type is a MessageAttributes.NOTIFICATION or MessageAttributes.REQUEST.
getType() - Method in interface osmq.messages.MessageAttributes
Identifies whether the message type is a MessageType.NOTIFICATION or MessageType.REQUEST .
getType() - Method in class osmq.messages.MessageBean
Identifies whether the message type is a NOTIFICATION or REQUEST .
getType() - Method in class osmq.messages.MessageHeader
Identifies whether the event type is a NOTIFICATION or REQUEST .
getUnformattedDateString(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message object as an unformatted date string in CCYYMMDD format.
getUnformattedDateString(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message object as an unformatted date string in CCYYMMDD format.
getUnformattedDateString(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as an unformatted date string in CCYYMMDD format.
getUnformattedDateString(int) - Method in class osmq.records.DataRecordBean
 
getUnformattedDateString(int) - Method in class osmq.records.DataRecordWrapper
 
getUnformattedString() - Method in class osmq.util.LongFormatter
 
getUpperCaseString(int) - Method in interface osmq.messages.DataSetMessage
Returns the value at the designated position in the message body as a String with all characters forced into upper case.
getUpperCaseString(int) - Method in class osmq.messages.DataSetMessageBean
Returns the value at the designated position in the message body as a String with all characters forced into upper case.
getUpperCaseString(int) - Method in interface osmq.records.DataRecord
Returns the value at the designated position as a String with all characters forced into upper case.
getUpperCaseString(int) - Method in class osmq.records.DataRecordBean
 
getUpperCaseString(int) - Method in class osmq.records.DataRecordWrapper
Returns the value at the designated position in the DataRecord object as a String with all characters forced into upper case.
getUserDefinedName() - Method in class osmq.util.ThreadBean
 
getUserDefinedName() - Method in class osmq.util.Threaded
 
getValue() - Method in class osmq.util.DecimalConverter
 
getValueAt(int, int) - Method in class osmq.tables.KeyedRowList
 
getValueAt(int, int) - Method in class osmq.tables.KeyedRowTableModel
 
getValueAt(int, int) - Method in class osmq.tables.ListenerTableMap
 
getValueAt(int, int) - Method in class osmq.tables.SortingTableModel
 
getValuesIterator() - Static method in class osmq.broker.handlers.PubStatus
 
getVisColumnAttrib(int) - Method in class osmq.tables.TableAttrib
 
getVisColumnClass(int) - Method in class osmq.tables.TableAttrib
 
getVisColumnName(int) - Method in class osmq.tables.TableAttrib
 
getVisColumnPreferredWidth(int) - Method in class osmq.tables.TableAttrib
 
getVisCount() - Method in class osmq.tables.TableAttrib
 
getVisIndex(int) - Method in class osmq.tables.TableAttrib
 
getVisRow(int) - Method in class osmq.tables.SortingTableModel
 
getVisible() - Method in class osmq.tables.ColumnAttrib
 
getWidth() - Method in class osmq.tables.ColumnAttrib
 
getWrittenCount() - Method in class osmq.net.SocketStreamFilter
Returns the number of message writes
getXMLImpliedDecimalString(int, int) - Method in class osmq.util.FixedLengthRecord
Trims leading spaces from the resulting string.
getYear() - Method in class osmq.util.DateConverter
 
getYieldCount() - Method in class osmq.util.ThreadBean
 
getYieldToPeers() - Method in class osmq.util.Threaded
 
greaterThan(Decimal) - Method in class osmq.datatypes.Decimal
 
greaterThan(Price) - Method in class osmq.datatypes.Price
 
gt(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
gt(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 

H

HALT_EVENT - Static variable in class osmq.util.StateEvent
 
HEARTBEAT_ALARM_THRESHOLD - Static variable in interface osmq.pulsar.Threshold
 
HEARTBEAT_FREQUENCY - Static variable in interface osmq.pulsar.Threshold
 
HELD_COUNT - Static variable in class osmq.broker.StatsContainer
 
HIGHEST_PRIORITY - Static variable in class osmq.util.Threaded
 
HIGH_PRIORITY - Static variable in interface osmq.util.Threadable
 
HIGH_PRIORITY - Static variable in class osmq.util.Threaded
 
HeartbeatListener - class osmq.pulsar.HeartbeatListener.
An aggregate class used by a service's client to identify if and when a service fails.
HeartbeatListener() - Constructor for class osmq.pulsar.HeartbeatListener
 
HeartbeatTransmitter - class osmq.pulsar.HeartbeatTransmitter.
Used by a service to notify attached users that it is still alive.
halt() - Method in class osmq.clients.BatchPublisher
Terminate published messages.
hasADelimiter() - Method in class osmq.records.DataRecordBean
 
hasADelimiter() - Method in class osmq.records.DataRecordWrapper
 
hasADelimiter() - Method in interface osmq.util.ByteArray
 
hasADelimiter() - Method in class osmq.util.ByteArrayImpl
 
hasAValue(int) - Method in interface osmq.messages.DataSetMessage
Determines whether a position has a value (versus null)
hasAValue(int) - Method in class osmq.messages.DataSetMessageBean
Determines whether a position has a value (versus null)
hasAValue(int) - Method in interface osmq.records.DataRecord
Determines whether a position has a value (versus null)
hasAValue(int) - Method in class osmq.records.DataRecordBean
 
hasAValue(int) - Method in class osmq.records.DataRecordWrapper
Determines whether a position has a value (versus null)
hasAssignedCorrelationNumber() - Method in interface osmq.messages.DataSetMessage
Determines if there is a correlation identifier value.
hasAssignedCorrelationNumber() - Method in class osmq.messages.DataSetMessageBean
Determines if there is a correlation identifier value.
hasAssignedCorrelationNumber() - Method in interface osmq.messages.MessageAttributes
Determines if there is a correlation identifier value.
hasAssignedCorrelationNumber() - Method in class osmq.messages.MessageBean
Determines if there is a correlation identifier value.
hasAssignedCorrelationNumber() - Method in class osmq.messages.MessageHeader
 
hasAssignedKey() - Method in interface osmq.messages.DataSetMessage
Determines if there is a key value identifier.
hasAssignedKey() - Method in class osmq.messages.DataSetMessageBean
Determines if there is a key value identifier.
hasAssignedKey() - Method in interface osmq.messages.MessageAttributes
Determines if there is a key value identifier.
hasAssignedKey() - Method in class osmq.messages.MessageBean
Determines if there is a key value identifier.
hasAssignedKey() - Method in class osmq.messages.MessageHeader
 
hasAssignedOriginator() - Method in interface osmq.messages.DataSetMessage
Determines if there is an originator identifier.
hasAssignedOriginator() - Method in class osmq.messages.DataSetMessageBean
Determines whether a position has a value (versus null)
hasAssignedOriginator() - Method in interface osmq.messages.MessageAttributes
Determines whether a position has a value (versus null)
hasAssignedOriginator() - Method in class osmq.messages.MessageBean
Determines whether a position has a value (versus null)
hasAssignedOriginator() - Method in class osmq.messages.MessageHeader
 
hasAssignedRecipient() - Method in interface osmq.messages.DataSetMessage
Determine if there is a recipient identifier value.
hasAssignedRecipient() - Method in class osmq.messages.DataSetMessageBean
Determine if there is a recipient identifier value.
hasAssignedRecipient() - Method in interface osmq.messages.MessageAttributes
Determine if there is a recipient identifier value.
hasAssignedRecipient() - Method in class osmq.messages.MessageBean
Determine if there is a recipient identifier value.
hasAssignedRecipient() - Method in class osmq.messages.MessageHeader
Determine if there is a recipient identifier value.
hasAssignedTopic() - Method in interface osmq.messages.DataSetMessage
Determines if there is a topic identifier value.
hasAssignedTopic() - Method in class osmq.messages.DataSetMessageBean
Determines if there is a topic identifier value.
hasAssignedTopic() - Method in interface osmq.messages.MessageAttributes
Determines if there is a topic identifier value.
hasAssignedTopic() - Method in class osmq.messages.MessageBean
Determines if there is a topic identifier value.
hasAssignedTopic() - Method in class osmq.messages.MessageHeader
Determine if there is a topic identifier value.
hasMoreElements() - Method in class osmq.broker.BrokerEngine
 
hasMoreElements() - Method in class osmq.util.CSVParser
 
hasMoreElements() - Method in class osmq.util.DelimitedArrayParser
 
hasMoreElements() - Method in class osmq.util.DelimitedStringParser
 
hasMoreTokens() - Method in class osmq.util.CSVParser
 
hasMoreTokens() - Method in class osmq.util.DelimitedArrayParser
 
hasMoreTokens() - Method in class osmq.util.DelimitedStringParser
 
hasTerminated() - Method in class osmq.util.ThreadBean
 
hasTerminated() - Method in class osmq.util.Threaded
 
hasTopic(String) - Method in class osmq.util.TopicSet
 
hasTopic(String) - Method in class osmq.util.TopicsListeners
 
hasTopics() - Method in class osmq.broker.subqueues.SubscriberQueue
 
hhmmssToSeconds(String, String, String) - Static method in class osmq.util.Duration
 
hhmmssToSeconds(String) - Static method in class osmq.util.Duration
 
hhmmssToSeconds(int, int, int) - Static method in class osmq.util.Duration
 
hhmmssToSeconds(String, String, String) - Static method in class osmq.util.DurationUtil
 
hhmmssToSeconds(String) - Static method in class osmq.util.DurationUtil
 
hhmmssToSeconds(int, int, int) - Static method in class osmq.util.DurationUtil
 
highestSize() - Method in class osmq.mque.MQue
Returns the highest queue count (elements on the queue) since the queue was instantiated or since the max count was cleared.
hostNameIsSet() - Method in class osmq.net.RemoteService
 
hostNameIsSet() - Method in class osmq.net.RemoteServiceWrapper
 

I

INCREASED_PRIORITY - Static variable in interface osmq.util.Threadable
 
INCREASED_PRIORITY - Static variable in class osmq.util.Threaded
 
INITIALIZATION - Static variable in class osmq.util.Trace
 
INITIALIZATION_EVENT - Static variable in class osmq.util.StateEvent
 
INTEGER - Static variable in interface osmq.datatypes.DataType
 
INTEGER - Static variable in class osmq.util.FixedLengthRecord
 
INTEGER_MASK - Static variable in class osmq.uicontrols.Formatter
 
INT_BYTE_ARRAY_SZ - Static variable in interface osmq.io.Packet
 
Immutable - interface osmq.util.Immutable.
 
ImmutableException - exception osmq.util.ImmutableException.
Thrown when a method is invoked that would alter the state of an immutable data attribute.
ImmutableException() - Constructor for class osmq.util.ImmutableException
 
ImmutableException(String) - Constructor for class osmq.util.ImmutableException
 
ImmutableImpl - class osmq.util.ImmutableImpl.
 
ImmutableImpl() - Constructor for class osmq.util.ImmutableImpl
 
InputSimDevice - class osmq.util.InputSimDevice.
 
InputSimDevice() - Constructor for class osmq.util.InputSimDevice
 
InputSimDevice(String) - Constructor for class osmq.util.InputSimDevice
 
IntMap - class osmq.util.IntMap.
 
IntMap() - Constructor for class osmq.util.IntMap
 
IntegerRenderer - class osmq.tables.IntegerRenderer.
 
IntegerRenderer() - Constructor for class osmq.tables.IntegerRenderer
 
ignoreSubstring(String) - Method in class osmq.util.StringParser
 
increment() - Method in class osmq.util.Accumulator
 
increment() - Method in class osmq.util.EventCounterImpl
 
increment() - Method in class osmq.util.LongWrapper
 
incrementBy(int) - Method in class osmq.util.Accumulator
 
incrementBy(int) - Method in class osmq.util.EventCounterImpl
 
incrementCount() - Method in class osmq.util.EventRateBean
 
incrementCount() - Method in class osmq.util.EventRateMgr
 
incrementCountBy(int) - Method in class osmq.util.EventRateMgr
 
indexOf(byte) - Method in class osmq.util.ByteString
 
indexOf(byte, int) - Method in class osmq.util.ByteString
 
initializeBuffer(int) - Method in class osmq.util.DynByteArray
 
initializer() - Method in class osmq.util.AbstractThreadable
 
inshutdown() - Static method in class osmq.broker.subqueues.SubscriberQueue
 
intToHhmmssString(int) - Static method in class osmq.util.DurationUtil
 
intValue() - Method in class osmq.datatypes.Decimal
 
intValue() - Method in class osmq.datatypes.FixedDecimal
 
intValue() - Method in class osmq.datatypes.Price
 
isADataRecord() - Method in class osmq.records.DataRecordBean
 
isADataRecord() - Method in class osmq.records.DataRecordWrapper
 
isADataRecord() - Method in interface osmq.util.ByteArray
 
isADataRecord() - Method in class osmq.util.ByteArrayImpl
 
isActive() - Method in class osmq.broker.BrokerEngine
 
isActive() - Method in class osmq.broker.handlers.PubStatus
 
isActive() - Method in class osmq.mcns.MCResponder
 
isActiveService(String) - Method in class osmq.net.DiscoveryClient
 
isAllSet() - Method in class osmq.clients.ClientIdentifier
 
isAppendMode() - Method in class osmq.broker.RemoteLogger
 
isAttached() - Method in class osmq.broker.subqueues.SubscriberQueue
 
isAutoCommit() - Method in interface osmq.clients.Publisher
Returns true if the publisher is in auto-commit mode.
isAutoCommit() - Method in class osmq.clients.PublisherBean
 
isAutoCommit() - Method in class osmq.clients.ThreadedPublisherBean
 
isBinaryDataMode() - Method in class osmq.net.DiscoverySocket
 
isBinaryDataMode() - Method in class osmq.net.RemoteService
 
isBinaryDataMode() - Method in class osmq.net.RemoteServiceWrapper
 
isBinarySocketMode() - Method in class osmq.broker.handlers.ServerSocketProcessor
 
isBinarySocketMode() - Method in class osmq.net.ServerSocketProcessor
 
isBinarySocketStreams() - Method in class osmq.broker.BrokerEngine
 
isCanEdit() - Method in class osmq.tables.KeyedRowTableModel
 
isCellEditable(int, int) - Method in class osmq.tables.KeyedRowTableModel
 
isCellEditable(int, int) - Method in class osmq.tables.ListenerTableMap
 
isClosed() - Method in class osmq.mque.MQue
Returns true if the queue has been closed.
isConnected() - Method in class osmq.broker.ChangeRequestor
 
isCurrency() - Method in class osmq.datatypes.FixedDecimal
 
isDateStamped() - Method in class osmq.broker.RemoteLogger
 
isDemonPriority() - Method in class osmq.util.TickEventBean
 
isDiscovery() - Method in class osmq.pulsar.DynamicPulsar
 
isDiscovery() - Method in class osmq.pulsar.ServicePulsar
 
isEOF() - Method in class osmq.io.PacketInputStream
Returns true if the end of the stream was encountered.
isEmpty(int) - Method in interface osmq.messages.DataSetMessage
Determines if a position has no value (is empty)
isEmpty(int) - Method in class osmq.messages.DataSetMessageBean
Determines if a position has no value (is empty).
isEmpty() - Method in class osmq.mque.MQue
Returns true if the queue size (element count) is zero.
isEmpty(int) - Method in interface osmq.records.DataRecord
Determines if a position has no value (is empty).
isEmpty(int) - Method in class osmq.records.DataRecordBean
 
isEmpty(int) - Method in class osmq.records.DataRecordWrapper
Determines if a position has no value (is empty).
isEmpty() - Method in class osmq.tables.KeyedRowList
 
isEmpty() - Method in class osmq.util.KeyedOrderedList
 
isEmptyPacket() - Method in class osmq.mcns.MulticastListener
 
isExceptionOnNoResponse() - Method in class osmq.mcns.MCRequestor
 
isFlushOnClose() - Method in class osmq.broker.SlaveRouterProcessor
Returns true if calling close will result in messages being lost.
isFormatted() - Method in class osmq.uicontrols.Formatter
 
isHaltReads() - Method in class osmq.mque.MQue
Returns true if the queue is in a read halt state.
isHaltWrites() - Method in class osmq.mque.MQue
Returns true if the queue is in a write halt state.
isHeartbeat() - Method in class osmq.pulsar.DynamicPulsar
 
isHeartbeat() - Method in class osmq.pulsar.ServicePulsar
 
isImmutable() - Method in interface osmq.messages.DataSetMessage
Returns true if this is an immutable message.
isImmutable() - Method in class osmq.messages.DataSetMessageBean
Returns true if this is an immutable message.
isImmutable() - Method in class osmq.records.DataRecordWrapper
Returns true if this is an immutable message.
isImmutable() - Method in interface osmq.util.Immutable
 
isImmutable() - Method in class osmq.util.ImmutableImpl
Returns true if this is an immutable object.
isLan() - Method in class osmq.mcns.NetworkScope
 
isLoadTopicsOnCreate() - Method in class osmq.broker.BrokerEngine
 
isLoadTopicsOnCreate() - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
isMultipleOfCount(int) - Method in class osmq.util.Stats
 
isNamed() - Method in class osmq.net.RemoteService
 
isNamed() - Method in class osmq.net.RemoteServiceWrapper
 
isNull(int) - Method in class osmq.messages.DataSetMessageBean
Determines if a position has no value (has a null value).
isNull(int) - Method in interface osmq.records.DataRecord
Determines if a position has no value (is empty).
isNull(int) - Method in class osmq.records.DataRecordBean
 
isNull(int) - Method in class osmq.records.DataRecordWrapper
Determines if a position has no value (is a null value).
isOpen() - Method in class osmq.broker.RemoteLogger
 
isOpen() - Method in interface osmq.clients.ClientAdapter
Returns true if there is an active connection to the message broker.
isOpen() - Method in interface osmq.clients.Publisher
Returns true if there is a connection to the message broker.
isOpen() - Method in interface osmq.clients.Subscriber
Returns true if there is a connection to the message broker and subcription message are being accepted.
isOpen() - Method in class osmq.clients.SubscriberBean
Returns true if the open() method was called.
isOpen() - Method in class osmq.clients.TopicSubscriberBean
Returns true if the open() method was called.
isOpen() - Method in class osmq.mque.MQue
Returns true if the queue is in an opened state.
isOpen() - Method in class osmq.net.SocketStreamFilter
 
isOpen() - Method in class osmq.util.InputSimDevice
 
isOpen() - Method in interface osmq.util.Readable
 
isOpened() - Method in class osmq.broker.BrokerEngine
 
isPauseChildren() - Method in class osmq.broker.handlers.ServerSocketProcessor
 
isPausePublishers() - Static method in class osmq.broker.handlers.PublisherHandler
 
isPaused() - Method in class osmq.util.ThreadBean
 
isPaused() - Method in class osmq.util.Threaded
 
isPersistentTopics() - Method in interface osmq.clients.Subscriber
Returns true if the session is using persistent topics.
isPersistentTopics() - Method in class osmq.clients.SubscriberBean
 
isPersistentTopics() - Method in class osmq.clients.TopicSubscriberBean
 
isPublisherPaused() - Method in class osmq.broker.BrokerEngine
 
isPublishing() - Method in class osmq.clients.BatchPublisher
Returns true if this is a threaded publisher and messages are currently being published.
isRunning() - Method in class osmq.broker.StatsEngine
 
isRunning() - Method in class osmq.util.ThreadBean
 
isRunning() - Method in class osmq.util.Threaded
 
isRunning() - Method in class osmq.util.TickEventBean
 
isSafestore() - Method in class osmq.broker.BrokerEngine
 
isShowDays() - Method in class osmq.util.DurationClock
 
isShutdownCompleted() - Method in class osmq.util.Threaded
 
isThreaded() - Method in class osmq.clients.BatchPublisher
Returns true if batch publishing will be performed by a seperate thread, and false if by the thread that calls PublishMessages()
isThreaded() - Method in interface osmq.clients.Publisher
 
isThreaded() - Method in class osmq.clients.PublisherBean
 
isTimedOut() - Method in class osmq.mcns.MulticastListener
 
isTrimQuotes() - Method in class osmq.util.CSVParser
 
isUseKeys() - Method in class osmq.tables.KeyedRowList
 
isUseKeys() - Method in class osmq.tables.KeyedRowTableModel
 
isUseKeys() - Method in class osmq.uicontrols.KeyedTable
 
isUseKeys() - Method in class osmq.uicontrols.ScrollingKeyedTable
 
isUseKeys() - Method in class osmq.util.KeyedOrderedList
Returns true if keys are being used.
isWan() - Method in class osmq.mcns.NetworkScope
 
islocked() - Method in class osmq.util.DataLock
 

J

javaDateToString(Date) - Static method in class osmq.util.DateFormatter
Returns a date string in CCYYMMDD format

K

KILL_BROKER - Static variable in class osmq.broker.ChangeRequestor
 
KILL_SUBSCRIBER - Static variable in class osmq.broker.ChangeRequestor
 
KeyedData - interface osmq.util.KeyedData.
 
KeyedDataRecordBean - class osmq.records.KeyedDataRecordBean.
 
KeyedDataRecordBean() - Constructor for class osmq.records.KeyedDataRecordBean
Default constructor uses an ArrayContainer to implement the Container object.
KeyedDataRecordBean(Object[]) - Constructor for class osmq.records.KeyedDataRecordBean
 
KeyedDataRecordBean(int) - Constructor for class osmq.records.KeyedDataRecordBean
 
KeyedDataRecordBean(CoreRecord) - Constructor for class osmq.records.KeyedDataRecordBean
 
KeyedDataRecordBean(String) - Constructor for class osmq.records.KeyedDataRecordBean
 
KeyedDataRecordBean(byte[]) - Constructor for class osmq.records.KeyedDataRecordBean
 
KeyedOrderedList - class osmq.util.KeyedOrderedList.
A collection of objects accessible by position or key.
KeyedOrderedList() - Constructor for class osmq.util.KeyedOrderedList
 
KeyedRowList - class osmq.tables.KeyedRowList.
A collection of keyed objects with columns.
KeyedRowList() - Constructor for class osmq.tables.KeyedRowList
 
KeyedRowList(TableAttrib) - Constructor for class osmq.tables.KeyedRowList
 
KeyedRowTableModel - class osmq.tables.KeyedRowTableModel.
 
KeyedRowTableModel() - Constructor for class osmq.tables.KeyedRowTableModel
 
KeyedTable - class osmq.uicontrols.KeyedTable.
A java bean visual component grid that displays messages as a row with each message item displayed as a column.
KeyedTable() - Constructor for class osmq.uicontrols.KeyedTable
 
KeyedTable(TableAttrib) - Constructor for class osmq.uicontrols.KeyedTable
 
KeyedTable(TableModel) - Constructor for class osmq.uicontrols.KeyedTable
 
KeyedTable(TableModel, TableColumnModel) - Constructor for class osmq.uicontrols.KeyedTable
 
KeyedTable(TableModel, TableColumnModel, ListSelectionModel) - Constructor for class osmq.uicontrols.KeyedTable
 
killAll() - Static method in class osmq.util.Threaded
 
killAllInGroup() - Static method in class osmq.util.Threaded
This function destroys all the threads derived from Threaded.
killAllPublishers() - Static method in class osmq.broker.handlers.PublisherHandler
 
killAllSubscribers() - Static method in class osmq.broker.handlers.RecoveryHandler
 
killAllSubscribers() - Static method in class osmq.broker.handlers.SubscriberHandler
 
killBrokerEngine() - Method in class osmq.broker.ChangeRequestor
 
killNamedSubscriber(String) - Static method in class osmq.broker.handlers.SubscriberHandler
 
killSubscriberConnection(String) - Method in class osmq.broker.ChangeRequestor
 

L

LABEL_FOREGROUND_COLOR - Static variable in interface osmq.broker.config.BrokerConsts
 
LAN - Static variable in class osmq.mcns.NetworkScope
 
LAST_RATE - Static variable in class osmq.broker.StatsContainer
 
LOAD_TOPICS_ON_CREATE - Static variable in interface osmq.broker.config.BrokerConsts
 
LOCAL_DOTTED_IP_GROUP - Static variable in class osmq.mcns.NetworkScope
 
LOCAL_TTL - Static variable in class osmq.mcns.NetworkScope
 
LOG_FILE_NAME - Static variable in interface osmq.util.NetConsts
 
LONG - Static variable in interface osmq.datatypes.DataType
 
ListenerTableMap - class osmq.tables.ListenerTableMap.
 
ListenerTableMap() - Constructor for class osmq.tables.ListenerTableMap
 
Log - interface osmq.logs.Log.
 
Logs - class osmq.logs.Logs.
 
Logs() - Constructor for class osmq.logs.Logs
 
LongFormatter - class osmq.util.LongFormatter.
 
LongFormatter() - Constructor for class osmq.util.LongFormatter
 
LongFormatter(long) - Constructor for class osmq.util.LongFormatter
 
LongWrapper - class osmq.util.LongWrapper.
 
LongWrapper() - Constructor for class osmq.util.LongWrapper
 
lastIndexOf(byte) - Method in class osmq.util.ByteString
 
lastIndexOf(byte, int) - Method in class osmq.util.ByteString
 
le(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
le(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
length() - Method in class osmq.util.ByteString
 
lessThan(Decimal) - Method in class osmq.datatypes.Decimal
 
lessThan(Price) - Method in class osmq.datatypes.Price
 
loadConfigFile(String) - Method in class osmq.broker.BrokerEngine
 
loadDataRecord(DataRecord) - Method in interface osmq.records.DataRecordLoader
 
loadFromLocalFile() - Method in class osmq.mque.PersistableMQue
 
loadFromLocalFile(String) - Method in class osmq.mque.PersistableMQue
 
loadList(String) - Static method in class osmq.tables.KeyedRowList
 
loadList(String) - Static method in class osmq.util.KeyedOrderedList
Creates a KeyedOrderedList from the serialized instance saved to a file.
locate(String) - Method in class osmq.net.DiscoveryClient
locate service name embedded in es, and set the port and address of es.
locate(RemoteService) - Method in class osmq.net.DiscoveryClient
Locate service name embedded in es, and set the port and address of es.
lock() - Method in class osmq.clients.ClientIdentifier
 
lock() - Method in class osmq.util.DataLock
 
logException(Exception) - Static method in class osmq.util.ExceptionLogger
 
longValue() - Method in class osmq.datatypes.Decimal
 
longValue() - Method in class osmq.datatypes.FixedDecimal
 
longValue() - Method in class osmq.datatypes.Price
 
lt(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
lt(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 

M

MAX_LOOKUP_TRIES - Static variable in class osmq.mcns.MCNS
 
MCNS - class osmq.mcns.MCNS.
 
MCNS() - Constructor for class osmq.mcns.MCNS
 
MCNSException - exception osmq.mcns.MCNSException.
 
MCNSException() - Constructor for class osmq.mcns.MCNSException
 
MCNSException(String) - Constructor for class osmq.mcns.MCNSException
 
MCRequestor - class osmq.mcns.MCRequestor.
Sends a string to a multicast group/port, and waits for a response.
MCResponder - class osmq.mcns.MCResponder.
A threaded base class for respondants to requests on a multicast channel.
MC_TTL - Static variable in class osmq.broker.config.StartupParms
 
MEMORY_AVAIL - Static variable in class osmq.broker.StatsContainer
 
MESSAGE_RECORDER_NAME - Static variable in interface osmq.broker.config.BrokerConsts
 
MQue - class osmq.mque.MQue.
A thread-safe, byte-oriented FIFO (first-in first-out) queue that holds byte array and/or String elements.
MQue() - Constructor for class osmq.mque.MQue
 
MQue(String) - Constructor for class osmq.mque.MQue
 
MQue(String, long) - Constructor for class osmq.mque.MQue
 
MULTICAST - Static variable in class osmq.util.Trace
 
Message - interface osmq.messages.Message.
A unit of data that includes identifying attributes (such as a topic, action, data key, and correlation ID) and client data (body).
MessageAttributes - interface osmq.messages.MessageAttributes.
A multi-element data set (record) that includes identifying attributes such as a topic, action, data key, and correlation ID.
MessageBean - class osmq.messages.MessageBean.
A MessageBean is an implementation of the Message interface, and an alternative to the DataSetMessageBean implementation (DATASET).
MessageBean() - Constructor for class osmq.messages.MessageBean
 
MessageBean(String) - Constructor for class osmq.messages.MessageBean
 
MessageBean(byte[]) - Constructor for class osmq.messages.MessageBean
 
MessageBuilder - interface osmq.messages.MessageBuilder.
An interface that defines a method that creates one or more DataSetMessage objects.
MessageException - exception osmq.messages.MessageException.
 
MessageException() - Constructor for class osmq.messages.MessageException
 
MessageException(String) - Constructor for class osmq.messages.MessageException
 
MessageFactory - class osmq.messages.MessageFactory.
Each thread should allocate a seperate MessageFactory instance;
MessageFactory() - Constructor for class osmq.messages.MessageFactory
 
MessageFormat - interface osmq.messages.MessageFormat.
 
MessageHeader - class osmq.messages.MessageHeader.
 
MessageHeader() - Constructor for class osmq.messages.MessageHeader
 
MessageHeader(DataRecord) - Constructor for class osmq.messages.MessageHeader
 
MessageHeader(String) - Constructor for class osmq.messages.MessageHeader
 
MessageHeader(byte[]) - Constructor for class osmq.messages.MessageHeader
 
MessageListener - interface osmq.messages.MessageListener.
 
MessageSortingThread - class osmq.broker.sorter.MessageSortingThread.
takes network messages from an input fifo and places them into the appropriate output fifos.
MessageSortingThread(TopicalSubscriberQueues, MQue) - Constructor for class osmq.broker.sorter.MessageSortingThread
 
MessageType - interface osmq.messages.MessageType.
A multi-element data set (record) that includes identifying attributes such as a topic, action, data key, and correlation ID.
MulticastListener - class osmq.mcns.MulticastListener.
Utility bean that listens for a datagram on a predefined multicast group/port combination.
main(String[]) - Static method in class osmq.broker.Broker
 
main(String[]) - Static method in class osmq.datatypes.Currency
 
main(String[]) - Static method in class osmq.datatypes.Price
 
main(String[]) - Static method in class osmq.datatypes.Rate
 
main(String[]) - Static method in class osmq.messages.MessageBean
 
main(String[]) - Static method in class osmq.records.DataRecordBean
 
main(String[]) - Static method in class osmq.util.ByteString
 
main(String[]) - Static method in class osmq.util.CSVParser
 
main(String[]) - Static method in class osmq.util.DateFormatter
 
main(String[]) - Static method in class osmq.util.DelimitedArrayParser
 
main(String[]) - Static method in class osmq.util.Duration
 
main(String[]) - Static method in class osmq.util.Padding
 
main(String[]) - Static method in class osmq.util.TrimFormatter
 
mark(String) - Method in class osmq.util.StopWatch
 
max(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
maxMps - Variable in class osmq.broker.StatsContainer
 
merge(String[]) - Method in class osmq.util.CSVParser
 
min(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
minus(double) - Method in class osmq.datatypes.Price
 
minus(Price) - Method in class osmq.datatypes.Price
 
mul(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
mul(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 

N

NETWORK - Static variable in class osmq.util.Trace
 
NONE - Static variable in class osmq.tables.KeyedRowList
 
NONE - Static variable in class osmq.util.KeyedOrderedList
 
NOTIFICATION - Static variable in interface osmq.messages.MessageType
 
NULL_CHAR - Static variable in interface osmq.util.SpecialChars
 
NULL_INT_ARRAY - Static variable in class osmq.io.PacketOutputStream
 
NULL_STRING - Static variable in interface osmq.util.SpecialChars
 
NetConsts - interface osmq.util.NetConsts.
 
NetException - exception osmq.net.NetException.
 
NetException() - Constructor for class osmq.net.NetException
 
NetException(String) - Constructor for class osmq.net.NetException
 
NetworkScope - class osmq.mcns.NetworkScope.
This class should be modified to support the IP multicast topology used for discovery.
n2sort() - Method in class osmq.tables.SortingTableModel
 
ne(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
ne(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
neg() - Method in class osmq.datatypes.FixedDecimal
 
neg(FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
nextElement() - Method in class osmq.broker.BrokerEngine
 
nextElement() - Method in class osmq.mque.MQue
Returns the next element from the queue.
nextElement() - Method in class osmq.util.CSVParser
for implementing Enumeration
nextElement() - Method in class osmq.util.DelimitedArrayParser
for implementing Enumeration
nextElement() - Method in class osmq.util.DelimitedStringParser
for implementing Enumeration
nextEvent() - Method in class osmq.util.RateRegulator
 
nextKey() - Method in class osmq.util.IntMap
 
nextToken() - Method in class osmq.util.CSVParser
 
nextToken() - Method in class osmq.util.DelimitedArrayParser
 
nextToken() - Method in class osmq.util.DelimitedStringParser
 
normalShutdown() - Method in class osmq.broker.BrokerEngine
 
notEqual(Decimal) - Method in class osmq.datatypes.Decimal
 
notEqual(Price) - Method in class osmq.datatypes.Price
 
notifyListeners(Exception) - Method in class osmq.util.ExceptionEventBean
 

O

ONE - Static variable in class osmq.datatypes.FixedDecimal
 
ORIGINATOR - Static variable in interface osmq.messages.MessageAttributes
 
ObjectInFile - class osmq.io.ObjectInFile.
 
ObjectInFile(String) - Constructor for class osmq.io.ObjectInFile
 
ObjectOutFile - class osmq.io.ObjectOutFile.
 
ObjectOutFile(String) - Constructor for class osmq.io.ObjectOutFile
 
ObjectWrapper - interface osmq.util.ObjectWrapper.
 
OutputFileWriter - class osmq.io.OutputFileWriter.
 
OutputFileWriter(String) - Constructor for class osmq.io.OutputFileWriter
 
OutputFileWriter(String, boolean) - Constructor for class osmq.io.OutputFileWriter
 
onDataRecord(DataRecord) - Method in interface osmq.records.DataRecordListener
 
onDuration(DurationClock) - Method in interface osmq.util.DurationListener
 
onEvent(StateEvent) - Method in class osmq.broker.Broker
 
onEvent(StateEvent) - Method in class osmq.broker.BrokerEngine
 
onEvent(StateEvent) - Method in interface osmq.util.StateEventListener
 
onException(Exception) - Method in class osmq.broker.BrokerEngine
 
onException(Exception) - Method in class osmq.broker.sorter.MessageSortingThread
 
onException(Exception) - Method in class osmq.clients.PubConnectionHandler
 
onException(Exception) - Method in class osmq.clients.PublisherBean
 
onException(Exception) - Method in class osmq.util.AbstractThreadable
 
onException(Exception) - Method in class osmq.util.ExceptionEventBean
 
onException(Exception) - Method in interface osmq.util.ExceptionListener
Notify user of an exception.
onException(Exception) - Method in class osmq.util.ExceptionListenerImpl
 
onExceptionClose(Exception, Frame) - Method in class osmq.util.ShutdownManager
 
onFilter(byte[]) - Method in interface osmq.util.FilterListener
A class of objects that is passed an object.
onKeyedDataRow(KeyedDataRow) - Method in class osmq.uicontrols.KeyedTable
 
onKeyedDataRow(KeyedDataRow) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
onMessage(Message) - Method in class osmq.broker.RemoteLogger
 
onMessage(Message) - Method in class osmq.clients.SubscriberCountManager
 
onMessage(Message) - Method in interface osmq.messages.MessageListener
 
onMessage(Message) - Method in class osmq.util.TopicsListeners
 
onRequest(String) - Method in class osmq.net.DiscoveryServer
If passed string is my service name , return a string containing my service name and IP address.
onShutdown() - Method in class osmq.broker.handlers.PubStatus
 
onShutdown() - Method in interface osmq.util.ShutdownListener
Notify user of a shutdown.
onString(String) - Method in interface osmq.util.StringListener
 
onTickEvent(TickEvent) - Method in class osmq.broker.BrokerFaultMonitor
 
onTickEvent(TickEvent) - Method in class osmq.broker.StatsEngine
 
onTickEvent(TickEvent) - Method in class osmq.util.DurationTimer
 
onTickEvent(TickEvent) - Method in interface osmq.util.TickEventListener
 
open() - Method in class osmq.broker.RemoteLogger
 
open() - Method in interface osmq.clients.ClientAdapter
Locates and connect to the remote message broker, and performs the necessary client authentication.
open() - Method in interface osmq.clients.Publisher
Locates and connects to the remote message broker, and performs the necessary publisher authentication.
open() - Method in class osmq.clients.PublisherBean
 
open() - Method in interface osmq.clients.Subscriber
Locates and connects to the remote message broker.
open() - Method in class osmq.clients.SubscriberBean
Commences sending messages to the MessageListeners that have been registered by this ClientSubscriber instance.
open() - Method in class osmq.clients.ThreadedPublisherBean
 
open() - Method in class osmq.clients.TopicChangeRequestor
 
open() - Method in class osmq.clients.TopicSubscriberBean
Commences sending messages to the MessageListeners that have been registered by this ClientSubscriber instance.
open() - Method in class osmq.mcns.MulticastListener
 
open() - Method in class osmq.mque.MQue
Reopens a queue that has been closed.
open() - Method in class osmq.util.AbstractThreadable
 
open() - Method in class osmq.util.InputSimDevice
 
open() - Method in interface osmq.util.Readable
 
open() - Method in class osmq.util.ThreadBean
 
open() - Method in class osmq.util.ThreadedReader
 
openPublisher(PublisherHandler) - Static method in class osmq.broker.handlers.PubStatus
 
osmq.broker - package osmq.broker
 
osmq.broker.config - package osmq.broker.config
 
osmq.broker.handlers - package osmq.broker.handlers
 
osmq.broker.sorter - package osmq.broker.sorter
 
osmq.broker.subqueues - package osmq.broker.subqueues
 
osmq.clients - package osmq.clients
 
osmq.datatypes - package osmq.datatypes
 
osmq.io - package osmq.io
 
osmq.logs - package osmq.logs
 
osmq.mcns - package osmq.mcns
 
osmq.messages - package osmq.messages
 
osmq.mque - package osmq.mque
 
osmq.net - package osmq.net
 
osmq.pulsar - package osmq.pulsar
 
osmq.records - package osmq.records
 
osmq.tables - package osmq.tables
 
osmq.uicontrols - package osmq.uicontrols
 
osmq.util - package osmq.util
 
out - Static variable in class osmq.logs.Logs
 

P

PAGE_THRESHOLD - Static variable in class osmq.broker.config.StartupParms
 
PAUSE_BROKER - Static variable in class osmq.broker.ChangeRequestor
 
PAUSE_EVENT - Static variable in class osmq.util.StateEvent
 
PEAK_RATE - Static variable in class osmq.broker.StatsContainer
 
PHONE - Static variable in interface osmq.datatypes.DataType
 
PHONE_MASK - Static variable in class osmq.uicontrols.Formatter
 
PI - Static variable in class osmq.datatypes.FixedDecimal
 
PIPELINE_THRESHOLD - Static variable in interface osmq.broker.config.BrokerConsts
 
PIPE_BYTE - Static variable in interface osmq.util.SpecialChars
 
PIPE_CHAR - Static variable in interface osmq.util.SpecialChars
 
PORT_ID - Static variable in class osmq.broker.config.StartupParms
 
PUBLISHER_AGENTS - Static variable in class osmq.broker.StatsContainer
 
PUBLISHER_FLAG - Static variable in interface osmq.util.NetConsts
 
PUBLISHER_MSG_COUNT - Static variable in class osmq.broker.StatsContainer
 
PUBLISHER_PRIORITY - Static variable in interface osmq.broker.config.BrokerConsts
 
PUBLISHER_YIELD_COUNT - Static variable in interface osmq.broker.config.BrokerConsts
 
PUBLISH_DETAILS - Static variable in class osmq.broker.StatsContainer
 
PULL - Static variable in interface osmq.util.DistributionMode
 
PULSAR_CHANNEL - Static variable in class osmq.mcns.MCNS
 
PULSAR_PORT - Static variable in interface osmq.util.NetConsts
 
PULSE_SERV_ACTIVE - Static variable in class osmq.util.StateEvent
 
PUSH - Static variable in interface osmq.util.DistributionMode
 
Packet - interface osmq.io.Packet.
An input stream filer that supports reading an input stream as packets of bytes.
PacketFileInputStream - class osmq.io.PacketFileInputStream.
 
PacketFileInputStream(String) - Constructor for class osmq.io.PacketFileInputStream
 
PacketFileInputStream(File) - Constructor for class osmq.io.PacketFileInputStream
 
PacketFileOutputStream - class osmq.io.PacketFileOutputStream.
 
PacketFileOutputStream(String) - Constructor for class osmq.io.PacketFileOutputStream
 
PacketFileOutputStream(String, boolean) - Constructor for class osmq.io.PacketFileOutputStream
 
PacketFileSaver - class osmq.mque.PacketFileSaver.
Used to save elements from an MQue to a compressed file
PacketFileSaver(String) - Constructor for class osmq.mque.PacketFileSaver
 
PacketInputStream - class osmq.io.PacketInputStream.
An input stream filer that supports reading an input stream as packets of bytes.
PacketInputStream(InputStream) - Constructor for class osmq.io.PacketInputStream
 
PacketOutputStream - class osmq.io.PacketOutputStream.
 
PacketOutputStream(OutputStream) - Constructor for class osmq.io.PacketOutputStream
 
Padding - class osmq.util.Padding.
 
Padding() - Constructor for class osmq.util.Padding
 
Pauser - class osmq.util.Pauser.
 
Pauser() - Constructor for class osmq.util.Pauser
 
PersistableMQue - class osmq.mque.PersistableMQue.
An MQue that can load and persist entries to/from a file
PersistableMQue() - Constructor for class osmq.mque.PersistableMQue
 
PersistableMQue(String) - Constructor for class osmq.mque.PersistableMQue
 
PersistentMQue - class osmq.mque.PersistentMQue.
A persistent MQue implementation that loads its values from a local file when instantiated, and saves values to a file when closed.
PersistentMQue(String) - Constructor for class osmq.mque.PersistentMQue
 
Phone - class osmq.datatypes.Phone.
 
Phone(String) - Constructor for class osmq.datatypes.Phone
 
PhoneRenderer - class osmq.tables.PhoneRenderer.
 
PhoneRenderer() - Constructor for class osmq.tables.PhoneRenderer
 
Pipeline - class osmq.broker.sorter.Pipeline.
 
Pipeline() - Constructor for class osmq.broker.sorter.Pipeline
 
Price - class osmq.datatypes.Price.
An immutable data type representing Price.
Price() - Constructor for class osmq.datatypes.Price
 
Price(double) - Constructor for class osmq.datatypes.Price
 
Price(int) - Constructor for class osmq.datatypes.Price
 
Price(String) - Constructor for class osmq.datatypes.Price
 
PrintWriterLog - class osmq.logs.PrintWriterLog.
 
PrintWriterLog(OutputStreamWriter) - Constructor for class osmq.logs.PrintWriterLog
Turn a standard OutputStream into a DataOutputStream
PrintWriterLog(String) - Constructor for class osmq.logs.PrintWriterLog
Create an output file as a DataOuputStream, and append if one exists with the filename.
PrintWriterLog(OutputStream) - Constructor for class osmq.logs.PrintWriterLog
 
PrintWriterLog(String, boolean) - Constructor for class osmq.logs.PrintWriterLog
 
PubConnectionHandler - class osmq.clients.PubConnectionHandler.
A class the contains all the objects shared by all threads that access a common broker for publishing messages.
PubConnectionHandler() - Constructor for class osmq.clients.PubConnectionHandler
The publisher connection handler for the default service (osmq) and the common client ID.
PubConnectionHandler(RemoteService) - Constructor for class osmq.clients.PubConnectionHandler
 
PubConnectionHandler(RemoteService, ClientIdentifier) - Constructor for class osmq.clients.PubConnectionHandler
 
PubStatus - class osmq.broker.handlers.PubStatus.
 
PubStatus(String, PublisherHandler) - Constructor for class osmq.broker.handlers.PubStatus
 
Publisher - interface osmq.clients.Publisher.
A class used by client applications to write messages.
PublisherBean - class osmq.clients.PublisherBean.
A class used by client applications to write messages.
PublisherBean() - Constructor for class osmq.clients.PublisherBean
 
PublisherBean(PubConnectionHandler) - Constructor for class osmq.clients.PublisherBean
 
PublisherBean(RemoteService) - Constructor for class osmq.clients.PublisherBean
 
PublisherHandler - class osmq.broker.handlers.PublisherHandler.
 
PublisherHandler() - Constructor for class osmq.broker.handlers.PublisherHandler
 
PulsarManager - class osmq.broker.PulsarManager.
 
PulsarManager() - Constructor for class osmq.broker.PulsarManager
 
padLeft(String, int) - Static method in class osmq.util.Padding
 
padRight(String, int) - Static method in class osmq.util.Padding
 
parse(String) - Method in class osmq.util.CSVParser
 
parse(char, int, int) - Method in class osmq.util.FixedLengthRecord
Returns the next field based ont the parameter descriptor
pause() - Method in class osmq.util.Pauser
 
pausePublisherProcessing(boolean) - Method in class osmq.broker.BrokerEngine
 
plus(double) - Method in class osmq.datatypes.Price
 
plus(Price) - Method in class osmq.datatypes.Price
 
portIsSet() - Method in class osmq.net.RemoteService
 
portIsSet() - Method in class osmq.net.RemoteServiceWrapper
 
positionAtFirstField() - Method in class osmq.util.FixedLengthRecord
 
println(String) - Method in class osmq.broker.handlers.ServiceHandler
Writes a String value to the socket stream.
println(String) - Method in class osmq.io.PacketOutputStream
 
println(String) - Method in class osmq.io.StringOutputStream
Writes an integer (size) to the output stream as 4 bytes.
println(String) - Method in interface osmq.io.WriterStream
 
println(String) - Method in interface osmq.logs.Log
 
println(String) - Method in class osmq.logs.PrintWriterLog
 
println(String) - Method in class osmq.net.SocketStreamFilter
Print a string to the socket stream
printlnCounted(String) - Method in class osmq.net.SocketStreamFilter
Print a string to the socket stream and increments the write count
publish(Message) - Method in interface osmq.clients.Publisher
Writes a message to the outbound queue.
publishMessages() - Method in class osmq.clients.BatchPublisher
Called to initiate message publishing.
publishdetails - Variable in class osmq.broker.StatsContainer
 
publishedCount - Variable in class osmq.broker.StatsContainer
 
pullFromNamedQueue(String) - Method in class osmq.broker.subqueues.SubscriberQueues
Get the next message value from the queue associated with a key value.
pulled - Variable in class osmq.mque.QueueStats
 
pushed - Variable in class osmq.mque.QueueStats
 
put(byte[], String) - Method in class osmq.broker.subqueues.SubscriberQueues
Puts a value onto a named Queue.
put(KeyedDataRow) - Method in class osmq.tables.KeyedRowList
 
put(KeyedData) - Method in class osmq.util.KeyedOrderedList
Adds a KeyedData item to the list if there is no item with a matching key.
putBack(byte[]) - Method in class osmq.mque.MQue
Returns an element that was pulled from the queue.

Q

QE_CAPACITY_EXCEEDED - Static variable in class osmq.mque.QueueException
 
QE_CLOSED - Static variable in class osmq.mque.QueueException
 
QE_DOUBLE_PUSH_BACK - Static variable in class osmq.mque.QueueException
 
QE_READ_HALTED - Static variable in class osmq.mque.QueueException
 
QE_SAVING_TO_TEXT_FILE - Static variable in class osmq.mque.QueueException
 
QE_UNKNOWN - Static variable in class osmq.mque.QueueException
 
QE_WRITE_HALTED - Static variable in class osmq.mque.QueueException
 
QUEUE - Static variable in class osmq.util.Trace
 
QUEUE_DETAILS - Static variable in class osmq.broker.StatsContainer
 
QUEUE_THRESHOLD - Static variable in class osmq.broker.subqueues.SubscriberQueue
 
QueueException - exception osmq.mque.QueueException.
 
QueueException() - Constructor for class osmq.mque.QueueException
 
QueueException(String) - Constructor for class osmq.mque.QueueException
 
QueueException(String, int) - Constructor for class osmq.mque.QueueException
 
QueueStats - class osmq.mque.QueueStats.
 
QueueStats() - Constructor for class osmq.mque.QueueStats
 
queued - Variable in class osmq.mque.QueueStats
 
queuedCount - Variable in class osmq.broker.StatsContainer
 
queuedetails - Variable in class osmq.broker.StatsContainer
 

R

READBUF_SIZE - Static variable in class osmq.mcns.MCNS
 
RECIPIENT - Static variable in interface osmq.messages.MessageAttributes
 
RECORD_DELIMITER - Static variable in interface osmq.util.NetConsts
 
RECOVERY_FLAG - Static variable in interface osmq.util.NetConsts
 
RECOVERY_SERV_ATTACHED - Static variable in class osmq.util.StateEvent
 
RECOVERY_SERV_DETACHED - Static variable in class osmq.util.StateEvent
 
REFRESH_RATE_SECS - Static variable in class osmq.broker.config.StartupParms
 
RELOAD_TOPIC_TABLE - Static variable in class osmq.broker.config.StartupParms
 
REMOTE_ADMIN_IP - Static variable in class osmq.broker.config.StartupParms
 
REMOVED - Static variable in class osmq.tables.KeyedRowList
 
REMOVED - Static variable in class osmq.util.KeyedOrderedList
 
REPLACED - Static variable in class osmq.tables.KeyedRowList
 
REPLACED - Static variable in class osmq.util.KeyedOrderedList
 
REQUEST - Static variable in interface osmq.messages.MessageType
 
RESULT_FOUND_NAME - Static variable in class osmq.mcns.MCNS
 
RESULT_HOST_ADDRESS - Static variable in class osmq.mcns.MCNS
 
RESULT_HOST_PORT - Static variable in class osmq.mcns.MCNS
 
RESULT_SERVICE_STATUS - Static variable in class osmq.mcns.MCNS
 
RIGHTALIGN - Static variable in interface osmq.datatypes.DataType
 
ROLE_COMMAND - Static variable in class osmq.clients.ClientStream
 
ROLE_PUBLISHER - Static variable in class osmq.clients.ClientStream
 
ROLE_RECOVERY - Static variable in class osmq.clients.ClientStream
 
ROLE_SUBSCRIBER - Static variable in class osmq.clients.ClientStream
 
ROLE_TOPIC_CHG - Static variable in class osmq.clients.ClientStream
 
Rate - class osmq.datatypes.Rate.
An immutable data type representing Rate.
Rate() - Constructor for class osmq.datatypes.Rate
 
Rate(Decimal) - Constructor for class osmq.datatypes.Rate
 
Rate(double) - Constructor for class osmq.datatypes.Rate
 
Rate(int) - Constructor for class osmq.datatypes.Rate
 
Rate(String) - Constructor for class osmq.datatypes.Rate
 
RateRegulator - class osmq.util.RateRegulator.
 
RateRegulator() - Constructor for class osmq.util.RateRegulator
 
RateRegulator(int) - Constructor for class osmq.util.RateRegulator
 
Readable - interface osmq.util.Readable.
 
ReaderStream - interface osmq.io.ReaderStream.
 
RecordFileReader - class osmq.records.RecordFileReader.
 
RecordFileReader(String) - Constructor for class osmq.records.RecordFileReader
 
RecoveryHandler - class osmq.broker.handlers.RecoveryHandler.
Class that handles subscriber connections to the message broker.
RecoveryHandler() - Constructor for class osmq.broker.handlers.RecoveryHandler
 
RemoteLogger - class osmq.broker.RemoteLogger.
 
RemoteLogger() - Constructor for class osmq.broker.RemoteLogger
 
RemoteService - class osmq.net.RemoteService.
 
RemoteService() - Constructor for class osmq.net.RemoteService
 
RemoteService(String) - Constructor for class osmq.net.RemoteService
 
RemoteService(String, int, boolean) - Constructor for class osmq.net.RemoteService
 
RemoteServiceWrapper - class osmq.net.RemoteServiceWrapper.
 
RemoteServiceWrapper() - Constructor for class osmq.net.RemoteServiceWrapper
 
RemoteServiceWrapper(RemoteService) - Constructor for class osmq.net.RemoteServiceWrapper
 
RemoteServiceWrapper(String) - Constructor for class osmq.net.RemoteServiceWrapper
 
RemoteServiceWrapper(String, int) - Constructor for class osmq.net.RemoteServiceWrapper
 
RespondantListener - interface osmq.mcns.RespondantListener.
 
RightAlignRenderer - class osmq.tables.RightAlignRenderer.
 
RightAlignRenderer() - Constructor for class osmq.tables.RightAlignRenderer
 
RowAttrib - class osmq.tables.RowAttrib.
 
RowAttrib(int) - Constructor for class osmq.tables.RowAttrib
 
RowAttrib(int[]) - Constructor for class osmq.tables.RowAttrib
 
RowListener - interface osmq.tables.RowListener.
 
RowListenerList - interface osmq.tables.RowListenerList.
 
Rstring - class osmq.datatypes.Rstring.
 
Rstring(String) - Constructor for class osmq.datatypes.Rstring
 
RuntimeInfo - class osmq.util.RuntimeInfo.
 
RuntimeInfo() - Constructor for class osmq.util.RuntimeInfo
 
ratesliceMps - Variable in class osmq.broker.StatsContainer
 
read(byte[], int, int) - Method in class osmq.io.PacketInputStream
Reads len bytes of data from the input stream into an array of bytes.
read(byte[], int, int) - Method in class osmq.io.StringInputStream
Reads len bytes of data from the input stream into an array of bytes.
readBytes() - Method in class osmq.broker.handlers.ServiceHandler
 
readBytes(byte[]) - Method in class osmq.io.PacketInputStream
Returns the next packet of bytes from the underlying InputStream and copies them into the byte array passed by the calling function.
readBytes() - Method in class osmq.io.PacketInputStream
Returns the next packet of bytes from the underlying InputStream into a newly allocated byte array.
readBytes() - Method in interface osmq.io.ReaderStream
 
readBytes(byte[]) - Method in interface osmq.io.ReaderStream
 
readBytes(byte[]) - Method in class osmq.io.StringInputStream
 
readBytes() - Method in class osmq.io.StringInputStream
 
readBytes() - Method in class osmq.mque.MQue
Returns the next element in the queue as a byte array.
readBytes() - Method in class osmq.net.SocketStreamFilter
Reads the next byte array from the socket input stream.
readBytesNoWait() - Method in class osmq.mque.MQue
Returns the next element in the queue as a byte array.
readString() - Method in class osmq.mque.MQue
Returns the next element on the queue as a String.
readStringNoWait() - Method in class osmq.mque.MQue
Returns the next element on the queue as a String.
readln() - Method in class osmq.broker.handlers.ServiceHandler
 
readln() - Method in class osmq.io.PacketInputStream
Returns the next packet of bytes from the underlying InputStream returns it as a byte array.
readln() - Method in interface osmq.io.ReaderStream
 
readln() - Method in class osmq.io.StringInputStream
 
readln() - Method in class osmq.net.SocketStreamFilter
Reads the next String from the socket input stream.
reallocateIndexes() - Method in class osmq.tables.SortingTableModel
 
recalcSlice() - Method in class osmq.util.EventRate
 
refreshColumnSizes() - Method in class osmq.uicontrols.KeyedTable
 
refreshColumnSizes() - Method in class osmq.uicontrols.ScrollingKeyedTable
 
refreshDurationString() - Method in class osmq.util.DurationClock
Returns duration as a String in hh:mm:ss format
refreshDurationString(long) - Method in class osmq.util.DurationClock
 
refreshFrom(List) - Method in class osmq.tables.KeyedRowList
 
refreshFrom(KeyedRowList) - Method in class osmq.tables.KeyedRowList
 
refreshFrom(KeyedRowList) - Method in class osmq.tables.KeyedRowTableModel
 
refreshFrom(List) - Method in class osmq.tables.KeyedRowTableModel
 
reloadTopics() - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
remove(int) - Method in class osmq.tables.KeyedRowList
 
remove(int) - Method in class osmq.util.KeyedOrderedList
Removes a KeyedData item from the list.
removeATopic(String) - Method in class osmq.broker.subqueues.SubscriberQueue
 
removeDurationListener(DurationListener) - Method in class osmq.util.DurationTimer
 
removeEntry(String) - Method in class osmq.util.IntMap
 
removeExceptionListener(ExceptionListener) - Method in class osmq.broker.handlers.ServerSocketProcessor
 
removeExceptionListener(ExceptionListener) - Method in class osmq.net.ServerSocketProcessor
 
removeExceptionListener(ExceptionListener) - Method in class osmq.util.ExceptionEventBean
 
removeListener(StateEventListener) - Method in class osmq.pulsar.HeartbeatListener
 
removeMessageBuilder(MessageBuilder) - Method in class osmq.clients.BatchPublisher
Removes a MessageBuilder from the set that will publish messages.
removeRowListener(RowListener) - Method in class osmq.tables.KeyedRowTableModel
 
removeRowListener(RowListener) - Method in interface osmq.tables.RowListenerList
 
removeRowListener(RowListener) - Method in class osmq.uicontrols.KeyedTable
 
removeRowListener(RowListener) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
removeStateEventListener(StateEventListener) - Method in class osmq.broker.RemoteLogger
 
removeStateEventListener(StateEventListener) - Method in class osmq.net.DiscoveryServer
 
removeStateEventListener(StateEventListener) - Method in class osmq.util.StateEventBean
 
removeStatusUpdateListener(TickEventListener) - Method in class osmq.broker.StatsEngine
 
removeSubscription(MQue, String) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
removeSubscription(String) - Method in class osmq.clients.TopicChangeRequestor
 
removeTickEventListener(TickEventListener) - Method in class osmq.util.TickEventBean
 
removeTopic(String) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
removeTopic(String) - Method in interface osmq.clients.Subscriber
Terminates receiving messages for a specific topic.
removeTopic(String) - Method in class osmq.clients.SubscriberBean
Terminates receiving messages for a specific topic.
removeTopic(String) - Method in class osmq.clients.TopicSubscriberBean
Terminates sending messages to the listener of a specific topic.
repeatProcess() - Method in class osmq.util.AbstractThreadable
 
repeatableProcess() - Method in class osmq.broker.sorter.MessageSortingThread
 
repeatableProcess() - Method in interface osmq.util.Threadable
 
replace(byte, byte) - Method in class osmq.util.ByteString
 
resampleRate() - Method in class osmq.broker.BrokerEngine
 
reset() - Method in class osmq.util.DurationClock
 
reset() - Method in class osmq.util.EventCounterImpl
 
reset() - Method in class osmq.util.EventRateBean
 
reset() - Method in class osmq.util.EventRateMgr
Resets the time duration to zero and the number of events to zero.
reset() - Method in class osmq.util.Pauser
 
reset() - Method in class osmq.util.RateRegulator
 
reset() - Method in class osmq.util.SimpleEventRate
 
reset(String) - Method in class osmq.util.StopWatch
 
reset() - Method in class osmq.util.Timer
 
resetClock() - Method in class osmq.broker.StatsEngine
 
resetDuration() - Method in class osmq.util.DurationTimer
 
resetPosition() - Method in class osmq.util.StringParser
 
resetSize(int) - Method in class osmq.records.CoreRecord
Resets the number of elements in the record, and clears the value of each element.
resetSize(int) - Method in interface osmq.records.DataRecord
Resets the size (number of elements), and clears all the values
resetSize(int) - Method in class osmq.records.DataRecordBean
Resets the size (number of elements) in the DataRecord object, and clears all the values
resetSize(int) - Method in class osmq.records.DataRecordWrapper
Resets the size (number of elements) in the DataRecord object, and clears all the values
respond(Object) - Method in interface osmq.mcns.RespondantListener
 
rollback() - Method in interface osmq.clients.Publisher
Discards all messages that were published since the last call to commit() or rollback().
round() - Method in class osmq.datatypes.FixedDecimal
 
round(FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
rowEvent(DataRow) - Method in interface osmq.tables.RowListener
 
rowEvent(DataRow) - Method in class osmq.uicontrols.BaseSyncField
 
rowEvent(DataRow) - Method in class osmq.uicontrols.SyncDoubleField
 
rowEvent(DataRow) - Method in class osmq.uicontrols.SyncIntField
 
rowEvent(DataRow) - Method in class osmq.uicontrols.SyncLongField
 
rowEvent(DataRow) - Method in class osmq.uicontrols.SyncTextField
 
run() - Method in class osmq.broker.SlaveRouterProcessor
 
run() - Method in class osmq.clients.BatchPublisher
Called by the internal methods.
run() - Method in class osmq.util.ThreadBean
 
run() - Method in class osmq.util.Threaded
 
run() - Method in class osmq.util.TickEventBean
 

S

SECONDS - Static variable in class osmq.mcns.MCNS
 
SENDER_SEQ - Static variable in interface osmq.messages.MessageAttributes
 
SEND_TIMESTAMP - Static variable in interface osmq.messages.MessageAttributes
 
SERVER_NAME - Static variable in class osmq.broker.config.StartupParms
 
SERVICE_ACTIVE - Static variable in class osmq.mcns.MCNS
 
SERV_REQUESTS - Static variable in class osmq.util.Trace
 
SIX_DEC_PRECIS_MASK - Static variable in class osmq.uicontrols.Formatter
 
SIZE - Static variable in interface osmq.datatypes.DataType
 
SIZE_CHANGE_EVENT - Static variable in class osmq.util.StateEvent
 
SIZE_DECREASE_EVENT - Static variable in class osmq.util.StateEvent
 
SIZE_INCREASE_EVENT - Static variable in class osmq.util.StateEvent
 
SORTED_COUNT - Static variable in class osmq.broker.StatsContainer
 
SORTER_PRIORITY - Static variable in interface osmq.broker.config.BrokerConsts
 
SORTER_YIELD_COUNT - Static variable in interface osmq.broker.config.BrokerConsts
 
SSN - Static variable in interface osmq.datatypes.DataType
 
SSN_MASK - Static variable in class osmq.uicontrols.Formatter
 
STATE_EVENT - Static variable in class osmq.util.StateEvent
 
STATS_REFRESH_RATE - Static variable in interface osmq.broker.config.BrokerConsts
 
STRING - Static variable in interface osmq.datatypes.DataType
 
STRING_TERMINATOR_BYTE - Static variable in interface osmq.util.SpecialChars
 
SUBSCRIBER_AGENTS - Static variable in class osmq.broker.StatsContainer
 
SUBSCRIBER_FLAG - Static variable in interface osmq.util.NetConsts
 
SUBSCRIBER_MSG_COUNT - Static variable in class osmq.broker.StatsContainer
 
SUBSCRIBER_PRIORITY - Static variable in interface osmq.broker.config.BrokerConsts
 
SUBSCRIBER_THRESHOLD - Static variable in interface osmq.broker.config.BrokerConsts
 
SUBSCRIBER_YIELD_COUNT - Static variable in interface osmq.broker.config.BrokerConsts
 
SUCCESS_EVENT - Static variable in class osmq.util.StateEvent
 
ScrollingKeyedTable - class osmq.uicontrols.ScrollingKeyedTable.
A wrapper class that extends KeyedTable by adding vertical scrolling.
ScrollingKeyedTable(TableAttrib) - Constructor for class osmq.uicontrols.ScrollingKeyedTable
 
ScrollingKeyedTable() - Constructor for class osmq.uicontrols.ScrollingKeyedTable
 
ServerSocketProcessor - class osmq.broker.handlers.ServerSocketProcessor.
Listens for socket connections from publishers, subscribers, topic changers, and other valid clients, passing each to a dedicated worker thread of the correct type.
ServerSocketProcessor(ServerSocket) - Constructor for class osmq.broker.handlers.ServerSocketProcessor
 
ServerSocketProcessor() - Constructor for class osmq.broker.handlers.ServerSocketProcessor
 
ServerSocketProcessor - class osmq.net.ServerSocketProcessor.
Base class for socket server class that listens for publisher and subscriber connections, passing them to a dedicated thread.
ServerSocketProcessor(ServerSocket) - Constructor for class osmq.net.ServerSocketProcessor
 
ServerSocketProcessor() - Constructor for class osmq.net.ServerSocketProcessor
 
ServiceAlertTransmitter - class osmq.pulsar.ServiceAlertTransmitter.
Used by a service to notify of its location
ServiceHandler - class osmq.broker.handlers.ServiceHandler.
 
ServiceHandler() - Constructor for class osmq.broker.handlers.ServiceHandler
 
ServicePulsar - class osmq.pulsar.ServicePulsar.
MCNS (multicast Name Service) MulticastPulsar uses an ip multicast channel to repeatedly broadcast a service name, ip adddress and port at a fixed time frequency.
ShutdownListener - interface osmq.util.ShutdownListener.
If a Threaded process detects a serious problem it will inform the Threaded's ShutdownListener if one has been registered.
ShutdownManager - class osmq.util.ShutdownManager.
 
SimpleEventRate - class osmq.util.SimpleEventRate.
 
SimpleEventRate() - Constructor for class osmq.util.SimpleEventRate
 
SimpleEventRate(EventCounter) - Constructor for class osmq.util.SimpleEventRate
 
Singletons - class osmq.broker.Singletons.
 
Singletons() - Constructor for class osmq.broker.Singletons
 
SlaveRouterProcessor - class osmq.broker.SlaveRouterProcessor.
A class that attaches to a Message Router as a subscriber, subscribing to all topics, and saves subscribed messages to a Queue.
SlaveRouterProcessor() - Constructor for class osmq.broker.SlaveRouterProcessor
 
SocialSecurityNumber - class osmq.datatypes.SocialSecurityNumber.
 
SocialSecurityNumber(String) - Constructor for class osmq.datatypes.SocialSecurityNumber
 
SocketStreamFilter - class osmq.net.SocketStreamFilter.
Client stream for communicating with a remote service.
SocketStreamFilter(Socket, boolean) - Constructor for class osmq.net.SocketStreamFilter
 
SocketStreamFilter(DiscoverySocket) - Constructor for class osmq.net.SocketStreamFilter
 
SocketStreamFilter(RemoteService, ExceptionListener) - Constructor for class osmq.net.SocketStreamFilter
 
SortingTableModel - class osmq.tables.SortingTableModel.
 
SortingTableModel() - Constructor for class osmq.tables.SortingTableModel
 
SortingTableModel(TableModel) - Constructor for class osmq.tables.SortingTableModel
 
SpecialChars - interface osmq.util.SpecialChars.
 
SsnRenderer - class osmq.tables.SsnRenderer.
 
SsnRenderer() - Constructor for class osmq.tables.SsnRenderer
 
StartupParms - class osmq.broker.config.StartupParms.
 
StateEvent - class osmq.util.StateEvent.
 
StateEvent(Object, int) - Constructor for class osmq.util.StateEvent
 
StateEventBean - class osmq.util.StateEventBean.
 
StateEventBean() - Constructor for class osmq.util.StateEventBean
 
StateEventListener - interface osmq.util.StateEventListener.
 
Stats - class osmq.util.Stats.
 
Stats() - Constructor for class osmq.util.Stats
 
StatsContainer - class osmq.broker.StatsContainer.
 
StatsContainer() - Constructor for class osmq.broker.StatsContainer
 
StatsEngine - class osmq.broker.StatsEngine.
 
StatsEngine() - Constructor for class osmq.broker.StatsEngine
 
StopWatch - class osmq.util.StopWatch.
 
StopWatch() - Constructor for class osmq.util.StopWatch
 
StringGenerator - interface osmq.pulsar.StringGenerator.
 
StringInputStream - class osmq.io.StringInputStream.
An input stream filer that supports reading an input stream as newline-delimited strings.
StringInputStream(InputStream) - Constructor for class osmq.io.StringInputStream
 
StringListener - interface osmq.util.StringListener.
 
StringOutputStream - class osmq.io.StringOutputStream.
An OutputStream filter that supports writing Strings and ASCII byte arrays to an output stream.
StringOutputStream(OutputStream) - Constructor for class osmq.io.StringOutputStream
 
StringParser - class osmq.util.StringParser.
 
StringParser(String) - Constructor for class osmq.util.StringParser
 
Subscriber - interface osmq.clients.Subscriber.
An interface used by client applications to receive messages.
SubscriberBean - class osmq.clients.SubscriberBean.
A class used by client applications to receive messages.
SubscriberBean() - Constructor for class osmq.clients.SubscriberBean
 
SubscriberBean(RemoteService) - Constructor for class osmq.clients.SubscriberBean
 
SubscriberBean(SubConnectionHandler) - Constructor for class osmq.clients.SubscriberBean
 
SubscriberCountManager - class osmq.clients.SubscriberCountManager.
 
SubscriberCountManager() - Constructor for class osmq.clients.SubscriberCountManager
 
SubscriberHandler - class osmq.broker.handlers.SubscriberHandler.
Class that handles subscriber connections to the message broker.
SubscriberHandler() - Constructor for class osmq.broker.handlers.SubscriberHandler
 
SubscriberQueue - class osmq.broker.subqueues.SubscriberQueue.
A Message queue created for a named subscriber.
SubscriberQueue(String) - Constructor for class osmq.broker.subqueues.SubscriberQueue
 
SubscriberQueues - class osmq.broker.subqueues.SubscriberQueues.
Multi-queue object, where each queue is identified by a unique string key value.
SubscriberQueues() - Constructor for class osmq.broker.subqueues.SubscriberQueues
 
SyncDoubleField - class osmq.uicontrols.SyncDoubleField.
A visual component that displays a column (cell) value from a corresponding table.
SyncDoubleField() - Constructor for class osmq.uicontrols.SyncDoubleField
 
SyncDoubleField(String) - Constructor for class osmq.uicontrols.SyncDoubleField
 
SyncIntField - class osmq.uicontrols.SyncIntField.
A visual component that displays a column (cell) value from a corresponding table.
SyncIntField() - Constructor for class osmq.uicontrols.SyncIntField
 
SyncIntField(String) - Constructor for class osmq.uicontrols.SyncIntField
 
SyncLongField - class osmq.uicontrols.SyncLongField.
/** A visual component that displays a column (cell) value from a corresponding table.
SyncLongField() - Constructor for class osmq.uicontrols.SyncLongField
 
SyncLongField(String) - Constructor for class osmq.uicontrols.SyncLongField
 
SyncTextField - class osmq.uicontrols.SyncTextField.
A visual component that displays a column (cell) value from a corresponding table.
SyncTextField() - Constructor for class osmq.uicontrols.SyncTextField
 
safestore - Static variable in class osmq.logs.Logs
 
save(String) - Method in class osmq.tables.KeyedRowList
 
save(String) - Method in class osmq.util.KeyedOrderedList
Saves a serialized instance of the KeyedOrderedList to a file.
saveAsLocalFile() - Method in class osmq.mque.PersistableMQue
 
saveQueue(MQue) - Method in class osmq.mque.PacketFileSaver
 
saveSlaveQueue() - Method in class osmq.broker.SlaveRouterProcessor
Saves the data on the slave Queue to a permenant file.
saveTopicSets(String) - Method in class osmq.broker.subqueues.TopicSubscriptions
 
scratch(String) - Static method in class osmq.util.FileUtil
 
sendPaused(boolean) - Method in class osmq.broker.ChangeRequestor
 
sendRequest(String) - Method in class osmq.mcns.MCRequestor
Writes a string to the multicast channel and wait for a response.
set(int, Object) - Method in class osmq.records.CoreRecord
Sets a record element to the value of an object.
set(long) - Method in class osmq.util.LongWrapper
 
setAlertInterval(int) - Method in class osmq.util.DurationTimer
 
setAlertInterval(int) - Method in class osmq.util.TickEventBean
 
setAll(Object[]) - Method in class osmq.records.CoreRecord
Sets all elements from an array of object
setAllHaltReads(boolean) - Method in class osmq.broker.subqueues.SubscriberQueues
 
setAllHaltWrites(boolean) - Method in class osmq.broker.subqueues.SubscriberQueues
 
setAndTranslate(double) - Method in class osmq.util.DecimalConverter
 
setAppendMode(boolean) - Method in class osmq.broker.RemoteLogger
 
setArray(byte[]) - Method in class osmq.util.DelimitedArrayParser
 
setAudit(Log) - Static method in class osmq.logs.Logs
 
setAutoCommit(boolean) - Method in interface osmq.clients.Publisher
Turns on or off the autocommitment of published messages to the message broker.
setAutoCommit(boolean) - Method in class osmq.clients.PublisherBean
Turns on or off the autocommitment of published messages to the message broker.
setAutoCommit(boolean) - Method in class osmq.clients.ThreadedPublisherBean
Turns on or off the autocommitment of published messages to the message broker.
setBigDecimal(int, BigDecimal) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a BigDecimal value
setBigDecimal(int, BigDecimal) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a BigDecimal value
setBigDecimal(int, BigDecimal) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a BigDecimal value
setBigDecimal(int, BigDecimal) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a BigDecimal value
setBigDecimal(int, BigDecimal) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a BigDecimal value
setBinaryDataMode(boolean) - Method in class osmq.net.RemoteService
 
setBinaryDataMode(boolean) - Method in class osmq.net.RemoteServiceWrapper
 
setBinarySocketMode(boolean) - Method in class osmq.broker.handlers.ServerSocketProcessor
if binary is true, the socket will be opened in binary content mode.
setBinarySocketMode(boolean) - Method in class osmq.net.ServerSocketProcessor
if binary is true, the socket will be opened in binary content mode.
setBinarySocketStreams(boolean) - Method in class osmq.broker.BrokerEngine
 
setBoolean(int, boolean) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a boolean value
setBoolean(int, boolean) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a boolean value
setBoolean(int, boolean) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a boolean value
setBoolean(int, boolean) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a boolean value
setBoolean(int, boolean) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a boolean value
setBrokerName(String) - Method in interface osmq.clients.ClientAdapter
Defines the named message broker that should be used for message processing (publishing or subscribing).
setBrokerName(String) - Method in interface osmq.clients.Publisher
Defines the named message broker that should be used for message processing (publishing).
setBrokerName(String) - Method in class osmq.clients.PublisherBean
Defines the named message broker to use for message processing (sending and receiving).
setBrokerName(String) - Method in interface osmq.clients.Subscriber
Defines the named message broker that should be used for message processing (subscription and receiving message).
setBrokerName(String) - Method in class osmq.clients.SubscriberBean
Defines (overrides) the named message broker to be used for message processing (sending and receiving).
setBrokerName(String) - Method in class osmq.clients.ThreadedPublisherBean
Defines the named message broker to use for message processing (sending and receiving).
setBrokerName(String) - Method in class osmq.clients.TopicSubscriberBean
Defines (overrides) the named message broker to be used for message processing (sending and receiving).
setBufferSize(int) - Method in class osmq.util.InputSimDevice
 
setByte(int, byte) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a byte value
setByte(int, byte) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a byte value
setByte(int, byte) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a byte value
setByte(int, byte) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a byte value
setByte(int, byte) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a byte value
setBytes(byte[]) - Method in interface osmq.records.DataRecord
Sets the elements to the values found in a delimited array of bytes.
setBytes(byte[]) - Method in class osmq.records.DataRecordBean
Sets the value of element in the DataRecord to values found in a byte array
setBytes(byte[]) - Method in class osmq.records.DataRecordWrapper
Sets the DataRecord elements to the values found in a delimited array of bytes.
setBytes(byte[]) - Method in interface osmq.util.ByteArray
 
setBytes(byte[]) - Method in class osmq.util.ByteArrayImpl
 
setCanEdit(boolean) - Method in class osmq.tables.KeyedRowTableModel
 
setChannel(int) - Method in class osmq.mcns.MCRequestor
 
setChannel(int) - Method in class osmq.mcns.MCResponder
 
setChannel(int) - Method in class osmq.mcns.MulticastListener
 
setChar(int, char) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a char value
setChar(int, char) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a char value
setChar(int, char) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a char value
setChar(int, char) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a char value
setChar(int, char) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a char value
setClientBytes(DataRecord) - Method in interface osmq.messages.DataSetMessage
Sets the client (body) data from values in a message body.
setClientBytes(byte[]) - Method in interface osmq.messages.DataSetMessage
Sets the client (body) data from an array of bytes.
setClientBytes(DataRecord) - Method in class osmq.messages.DataSetMessageBean
Sets the client (body) data from values in a message body.
setClientBytes(byte[]) - Method in class osmq.messages.DataSetMessageBean
Sets the client (body) data from an array of bytes.
setClientBytes(byte[]) - Method in class osmq.messages.MessageBean
Sets the client (body) data from values in a message body.
setClientID(String) - Method in interface osmq.clients.ClientAdapter
Sets the identity of the application as a message originator (publisher)
setClientID(String) - Method in class osmq.clients.ClientIdentifier
 
setClientID(String) - Method in interface osmq.clients.Publisher
Sets the identity of the application as a message originator (publisher)
setClientID(String) - Method in class osmq.clients.PublisherBean
Sets the identity of the application as a message originator (publisher)
setClientID(String) - Method in interface osmq.clients.Subscriber
Sets the identity of the application as a message recipient/subscriber
setClientID(String) - Method in class osmq.clients.SubscriberBean
Sets the identity of the application as a message recipient/subscriber
setClientID(String) - Method in class osmq.clients.ThreadedPublisherBean
Sets the identity of the application as a message originator (publisher)
setClientID(String) - Method in class osmq.clients.TopicSubscriberBean
Sets the identity of the application as a message recipient/subscriber
setClientIdentifier(ClientIdentifier) - Method in class osmq.clients.ClientStream
 
setClientIdentifier(ClientIdentifier) - Method in class osmq.clients.TopicChangeRequestor
 
setClientName(String) - Method in class osmq.broker.RemoteLogger
 
setClientText(String) - Method in class osmq.messages.MessageBean
Sets the body values to a String.
setClock(DurationClock) - Method in class osmq.util.DurationTimer
 
setColPosn(int) - Method in class osmq.uicontrols.BaseSyncField
 
setColumn(ColumnAttrib, int) - Method in class osmq.tables.RowAttrib
 
setContentSize(int) - Method in class osmq.util.DynByteArray
 
setControlMessageBuilder(MessageBuilder) - Method in class osmq.clients.BatchPublisher
Sets the control MessageBuilder that will create preliminary and a final control message.
setCorrelationNumber(long) - Method in interface osmq.messages.DataSetMessage
Sets the identifier used to identify a group of transactions as related.
setCorrelationNumber(long) - Method in class osmq.messages.DataSetMessageBean
Sets the identifier used to identify a group of transactions as related.
setCorrelationNumber(long) - Method in interface osmq.messages.MessageAttributes
 
setCorrelationNumber(long) - Method in class osmq.messages.MessageBean
Sets the identifier used to identify a group of transactions as related.
setCorrelationNumber(long) - Method in class osmq.messages.MessageHeader
 
setCorrelationString(String) - Method in interface osmq.messages.DataSetMessage
Sets the identifier used to identify a group of transactions as related.
setCorrelationString(String) - Method in class osmq.messages.DataSetMessageBean
Sets the identifier used to identify a group of transactions as related.
setCorrelationString(String) - Method in interface osmq.messages.MessageAttributes
 
setCorrelationString(String) - Method in class osmq.messages.MessageBean
Sets the identifier used to identify a group of transactions as related.
setCorrelationString(String) - Method in class osmq.messages.MessageHeader
 
setCount(long) - Method in class osmq.util.Accumulator
 
setCounter(EventCounter) - Method in class osmq.util.EventRate
 
setCounter(EventCounter) - Method in class osmq.util.EventRateMgr
 
setCounter(EventCounter) - Method in class osmq.util.SimpleEventRate
 
setCurrency(boolean) - Method in class osmq.datatypes.FixedDecimal
 
setCurrencyMask() - Method in class osmq.uicontrols.Formatter
 
setCurrencyMask() - Method in class osmq.uicontrols.SyncDoubleField
 
setDataRecord(DataRecord) - Method in class osmq.messages.MessageBean
Sets the body values to a DataRecord.
setDataRecordListener(DataRecordListener) - Method in class osmq.pulsar.DatasetPulsarListener
 
setDataType(int) - Method in class osmq.tables.ColumnAttrib
 
setDate(int, Date) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a Date value
setDate(int, Date) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a Date value
setDate(int, Date) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a Date value
setDate(int, Date) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a date/time value
setDate(int, Date) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a Date value
setDateStamped(boolean) - Method in class osmq.broker.RemoteLogger
 
setDateString(int, String) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to an date value.
setDateString(int, String) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to an date value.
setDateString(int, String) - Method in interface osmq.records.DataRecord
 
setDateString(int, String) - Method in class osmq.records.DataRecordBean
 
setDateString(int, String) - Method in class osmq.records.DataRecordWrapper
 
setDated(boolean) - Method in interface osmq.logs.Log
 
setDated(boolean) - Method in class osmq.logs.PrintWriterLog
 
setDecimalString(int, String) - Method in interface osmq.messages.DataSetMessage
 
setDecimalString(int, String) - Method in class osmq.messages.DataSetMessageBean
 
setDecimalString(int, String) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a String value that represents a decimal value.
setDecimalString(int, String) - Method in class osmq.records.DataRecordBean
 
setDecimalString(int, String) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a decimal String value
setDefaultListener(MessageListener) - Method in class osmq.util.TopicsListeners
 
setDefaultMessageListener(MessageListener) - Method in class osmq.clients.TopicSubscriberBean
Defines the listener that will be passed a Message when a one arrives that is addressed specificially to this client or contains a topic to which the client has subscribed.
setDelayInSeconds(int) - Method in class osmq.pulsar.DynamicPulsar
 
setDelimter(char) - Method in class osmq.util.CSVParser
 
setDemonPriority(boolean) - Method in class osmq.util.TickEventBean
 
setDevice(Readable) - Method in class osmq.util.ThreadedReader
 
setDiscovery(boolean) - Method in class osmq.pulsar.DynamicPulsar
 
setDiscovery(boolean) - Method in class osmq.pulsar.ServicePulsar
 
setDottedGroupAddress(String) - Method in class osmq.mcns.MCResponder
 
setDottedGroupAddress(String) - Method in class osmq.mcns.MulticastListener
 
setDouble(int, double) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a double value
setDouble(int, double) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a double value
setDouble(int, double) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a double value
setDouble(int, double) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a double value
setDouble(int, double) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a double value
setElementCount(int) - Method in interface osmq.messages.DataSetMessage
 
setElementCount(int) - Method in class osmq.messages.DataSetMessageBean
 
setErr(OutputStream) - Static method in class osmq.logs.Logs
 
setExceptionListener(ExceptionListener) - Method in interface osmq.clients.ClientAdapter
Sets an ExceptionListener that will be notified if there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in interface osmq.clients.Publisher
Sets an ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in class osmq.clients.PublisherBean
Sets an ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in interface osmq.clients.Subscriber
Sets an ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in class osmq.clients.SubscriberBean
Sets an ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in class osmq.clients.ThreadedPublisherBean
Sets an ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in class osmq.clients.TopicSubscriberBean
Sets an ExceptionListener that will be notified when there is an exception due to an inability to connect with the broker, or due to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in class osmq.pulsar.DatasetPulsarListener
 
setExceptionListener(ExceptionListener) - Method in class osmq.util.AbstractThreadable
Sets an ExceptionListener that will be notified when there is an exception due to an inability to an I/O or communications failure.
setExceptionListener(ExceptionListener) - Method in class osmq.util.ExceptionListenerBase
 
setExceptionListener(ExceptionListener) - Method in class osmq.util.Threaded
Registers a listener that will be notified if the thread is being halted due to an exception that was thrown by the derived class's iterativeProcess() method.
setExceptionOnNoResponse(boolean) - Method in class osmq.mcns.MCRequestor
 
setFileName(String) - Method in class osmq.broker.RemoteLogger
 
setFileName(String) - Method in class osmq.util.InputSimDevice
 
setFilterListener(FilterListener) - Method in class osmq.util.ThreadedReader
 
setFixedSize(int, int) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
setFloat(int, float) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a float value
setFloat(int, float) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a float value
setFloat(int, float) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a float value
setFloat(int, float) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a float value
setFloat(int, float) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a float value
setFlushOnClose(boolean) - Method in class osmq.broker.SlaveRouterProcessor
Defines whether the messages will be discarded when the broker is closed.
setFormat(char) - Method in interface osmq.messages.DataSetMessage
Sets the body format identifier.
setFormat(char) - Method in class osmq.messages.DataSetMessageBean
Sets the body format identifier.
setFormat(char) - Method in interface osmq.messages.MessageAttributes
Sets the attributes that identifies the type of data contained in the message body.
setFormat(char) - Method in class osmq.messages.MessageBean
 
setFormat(char) - Method in class osmq.messages.MessageHeader
 
setFrequency(int) - Method in class osmq.broker.PulsarManager
 
setFromArray(Object[]) - Method in interface osmq.records.DataRecord
Sets the data elements from the values in an array.
setFromArray(Object[]) - Method in class osmq.records.DataRecordBean
 
setFromArray(Object[]) - Method in class osmq.records.DataRecordWrapper
Sets the data elements from the values in an array.
setFromDelimitedString(String) - Method in class osmq.records.CoreRecord
Sets the element values from those contained in a delimited string.
setGenerator(StringGenerator) - Method in class osmq.pulsar.DynamicPulsar
 
setGroupAddress(String) - Method in class osmq.mcns.NetworkScope
 
setGroupAddress(String) - Method in class osmq.pulsar.DynamicPulsar
 
setGroupAddress(String) - Method in class osmq.pulsar.ServicePulsar
 
setHaltWrites(boolean) - Method in class osmq.mque.MQue
Sets the write halt mode.
setHandler(PublisherHandler) - Method in class osmq.broker.handlers.PubStatus
 
setHeader(MessageHeader) - Method in interface osmq.messages.DataSetMessage
Sets the message header values.
setHeader(MessageHeader) - Method in class osmq.messages.DataSetMessageBean
Sets the message header values.
setHeader(MessageHeader) - Method in class osmq.messages.MessageBean
Sets the message header values.
setHeaderBytes(byte[]) - Method in interface osmq.messages.DataSetMessage
Sets the header data from an array of bytes.
setHeaderBytes(byte[]) - Method in class osmq.messages.DataSetMessageBean
Sets the header data from an array of bytes.
setHeaderBytes(byte[]) - Method in class osmq.messages.MessageBean
Sets the header data from an array of bytes.
setHeartbeat(boolean) - Method in class osmq.pulsar.DynamicPulsar
 
setHeartbeat(boolean) - Method in class osmq.pulsar.ServicePulsar
 
setHostName(String) - Method in interface osmq.clients.ClientAdapter
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in interface osmq.clients.Publisher
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in class osmq.clients.PublisherBean
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in interface osmq.clients.Subscriber
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in class osmq.clients.SubscriberBean
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in class osmq.clients.ThreadedPublisherBean
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in class osmq.clients.TopicSubscriberBean
Overrides the host name / IP address of the remote server;
setHostName(String) - Method in class osmq.net.RemoteService
 
setHostName(String) - Method in class osmq.net.RemoteServiceWrapper
 
setImmutable() - Method in interface osmq.messages.DataSetMessage
Sets the message state to immutable. The values of an immutable message cannot be modified.
setImmutable() - Method in class osmq.messages.DataSetMessageBean
Sets the message state to immutable. The values of an immutable message cannot be modified.
setImmutable() - Method in class osmq.messages.MessageBean
Sets the message state to immutable. The values of an immutable message cannot be modified.
setImmutable() - Method in class osmq.records.DataRecordWrapper
Sets the DataRecord's state to immutable. The values of an immutable DataRecord cannot be modified.
setImmutable() - Method in interface osmq.util.Immutable
 
setImmutable() - Method in class osmq.util.ImmutableImpl
 
setInShutdown() - Static method in class osmq.broker.subqueues.SubscriberQueue
 
setInstanceName(String) - Method in class osmq.mque.MQue
Sets a name associated with this MQue instance.
setInt(int, int) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to an int value
setInt(int, int) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to an int value
setInt(int, int) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to an int value
setInt(int, int) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to an integer value
setInt(int, int) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to an int value
setInt(int) - Method in class osmq.uicontrols.SyncIntField
 
setIpAddress(String) - Method in class osmq.broker.subqueues.SubscriberQueue
 
setKey(String) - Method in interface osmq.messages.DataSetMessage
Sets the unique identifier for the data contained in the message.
setKey(String) - Method in class osmq.messages.DataSetMessageBean
Sets the unique identifier for the data contained in the message.
setKey(String) - Method in interface osmq.messages.MessageAttributes
 
setKey(String) - Method in class osmq.messages.MessageBean
Sets the unique identifier for the data contained in the message.
setKey(String) - Method in class osmq.messages.MessageHeader
 
setKey(String) - Method in class osmq.records.KeyedDataRecordBean
 
setKeyAsInt(int) - Method in interface osmq.messages.DataSetMessage
Sets the unique identifier for the data contained in the message.
setKeyAsInt(int) - Method in class osmq.messages.DataSetMessageBean
Sets the unique identifier for the data contained in the message.
setKeyAsInt(int) - Method in interface osmq.messages.MessageAttributes
 
setKeyAsInt(int) - Method in class osmq.messages.MessageBean
 
setKeyAsInt(int) - Method in class osmq.messages.MessageHeader
 
setLanScope() - Static method in class osmq.mcns.NetworkScope
 
setLoadTopicOnCreate(boolean) - Method in class osmq.broker.BrokerEngine
 
setLoadTopicOnCreate(boolean) - Method in class osmq.broker.subqueues.TopicalSubscriberQueues
 
setLong(int, long) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a long value
setLong(int, long) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a long value
setLong(int, long) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a long value
setLong(int, long) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a long value
setLong(int, long) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a long value
setLong(long) - Method in class osmq.util.LongFormatter
 
setMask(String) - Method in class osmq.uicontrols.Formatter
 
setMask(String) - Method in class osmq.uicontrols.SyncDoubleField
 
setMask(String) - Method in class osmq.uicontrols.SyncTextField
 
setMaxRate(int) - Method in class osmq.clients.BatchPublisher
Sets the maximum rate of message publishing (in messages per second).
setMaxThreshold(int) - Method in class osmq.mque.MQue
Sets the maximum capacity threshold.
setMessageListener(MessageListener) - Method in interface osmq.clients.Subscriber
Defines the MessageListener object that will receive all the topical and point-to-point messages for this client.
setMessageListener(MessageListener) - Method in class osmq.clients.SubscriberBean
Defines the listener that will be passed a Message when a one arrives that is addressed specificially to this client or contains a topic to which the client has subscribed.
setMessageListener(MessageListener) - Method in class osmq.util.TopicSet
 
setModel(TableModel) - Method in class osmq.tables.ListenerTableMap
 
setModel(TableModel) - Method in class osmq.tables.SortingTableModel
 
setNull(int) - Method in interface osmq.messages.DataSetMessage
Sets the value at the designated position in the message body to null
setNull(int) - Method in class osmq.messages.DataSetMessageBean
Sets the value at the designated position in the message body to null
setNull(int) - Method in interface osmq.records.DataRecord
Sets the value at the designated position to null
setNull(int) - Method in class osmq.records.DataRecordBean
Sets the element at the designated position in the DataRecord object to null
setNull(int) - Method in class osmq.records.DataRecordWrapper
Sets the value at the designated position in the DataRecord to null
setObject(int, Object) - Method in interface osmq.messages.DataSetMessage
Sets the value at the designated position in the message body
setObject(int, Object) - Method in class osmq.messages.DataSetMessageBean
Sets the value at the designated position in the message body
setObject(int, Object) - Method in interface osmq.records.DataRecord
Sets the value at the designated position
setObject(int, Object) - Method in class osmq.records.DataRecordBean
Sets the element at the designated position in the DataRecord object to a Object value
setObject(int, Object) - Method in class osmq.records.DataRecordWrapper
Sets the value at the designated position in the DataRecord object
setObjectValue(int, ColumnAttrib, Object) - Method in class osmq.tables.KeyedRowTableModel
 
setOffsetIndex(int) - Method in interface osmq.messages.DataSetMessage
Sets the base index used to reference elements in the message body.
setOffsetIndex(int) - Method in class osmq.messages.DataSetMessageBean
Sets the base index used to reference elements in the message body.
setOffsetIndex(int) - Method in interface osmq.records.DataRecord
Sets the base index used to reference elements.
setOffsetIndex(int) - Method in class osmq.records.DataRecordBean
Sets the indexing scheme by indicating the index of the first element in the DataRecord.
setOffsetIndex(int) - Method in class osmq.records.DataRecordWrapper
Sets the base index used to reference elements in the DataRecord.
setOriginator(String) - Method in interface osmq.messages.DataSetMessage
Sets the identifier of the message sender (publisher).
setOriginator(String) - Method in class osmq.messages.DataSetMessageBean
Sets the identifier of the message sender (publisher).
setOriginator(String) - Method in interface osmq.messages.MessageAttributes
Sets the identifier of the message sender/originator.
setOriginator(String) - Method in class osmq.messages.MessageBean
Sets the identifier of the message sender (publisher).
setOriginator(String) - Method in class osmq.messages.MessageHeader
Sets the identifier of the message sender/originator.
setOut(OutputStream) - Static method in class osmq.logs.Logs
 
setOutputQueue(Writable) - Method in class osmq.util.ThreadedReader
 
setPagingThreshold(int) - Method in class osmq.mque.MQue
Sets the element count threshold, where overflow elements are paged to disk.
setParent(ServerSocketProcessor) - Method in class osmq.broker.handlers.ServiceHandler
 
setPartner(JTable) - Method in class osmq.tables.SortingTableModel
 
setPausePublishers(boolean) - Static method in class osmq.broker.handlers.PublisherHandler
 
setPaused(boolean) - Method in class osmq.util.ThreadBean
 
setPaused(boolean) - Method in class osmq.util.Threaded
 
setPersistentTopics(boolean) - Method in interface osmq.clients.Subscriber
Defines whether the session will employ persistent topics.
setPersistentTopics(boolean) - Method in class osmq.clients.SubscriberBean
A method used to identify whether topical message subscription should persist after the ClientSubscriber has terminated.
setPersistentTopics(boolean) - Method in class osmq.clients.TopicSubscriberBean
A method used to identify whether topical message subscription should persist after the ClientSubscriber has terminated.
setPhoneMask() - Method in class osmq.uicontrols.Formatter
 
setPhoneMask() - Method in class osmq.uicontrols.SyncTextField
 
setPort(int) - Method in class osmq.broker.BrokerEngine
 
setPortID(int) - Method in class osmq.broker.handlers.ServerSocketProcessor
 
setPortID(int) - Method in interface osmq.clients.ClientAdapter
Sets the port ID that the remote message server uses for connections.
setPortID(int) - Method in interface osmq.clients.Publisher
Overrides the port ID that the remote message server uses for connections.
setPortID(int) - Method in class osmq.clients.PublisherBean
Overrides the port id of the remote server;
setPortID(int) - Method in interface osmq.clients.Subscriber
Sets the port ID that the remote message server uses for connections.
setPortID(int) - Method in class osmq.clients.SubscriberBean
Overrides the port id of the remote server;
setPortID(int) - Method in class osmq.clients.ThreadedPublisherBean
Overrides the port id of the remote server;
setPortID(int) - Method in class osmq.clients.TopicSubscriberBean
Overrides the port id of the remote server;
setPortID(int) - Method in class osmq.net.RemoteService
 
setPortID(int) - Method in class osmq.net.RemoteServiceWrapper
 
setPortID(int) - Method in class osmq.net.ServerSocketProcessor
 
setPrecision(int) - Method in class osmq.util.DecimalConverter
 
setPreferredWidth(int) - Method in class osmq.uicontrols.BaseSyncField
 
setPriority(int) - Method in class osmq.util.Threaded
 
setPriority(int) - Method in class osmq.util.TickEventBean
 
setPulsarPort(int) - Method in class osmq.pulsar.DatasetPulsarListener
 
setPulsarPort(int) - Method in class osmq.pulsar.HeartbeatListener
 
setPulsarRate(int) - Method in class osmq.broker.BrokerEngine
 
setRawSeconds(int) - Method in class osmq.util.Duration
 
setRebuildFrequencey(int) - Method in class osmq.broker.StatsEngine
 
setRecipient(String) - Method in interface osmq.messages.DataSetMessage
Sets the unique recipient that will receive the message.
setRecipient(String) - Method in class osmq.messages.DataSetMessageBean
Sets the unique recipient that will receive the message.
setRecipient(String) - Method in interface osmq.messages.MessageAttributes
Sets the unique recipient that will receive the message.
setRecipient(String) - Method in class osmq.messages.MessageBean
Sets the unique recipient that will receive the message.
setRecipient(String) - Method in class osmq.messages.MessageHeader
Sets the unique recipient that will receive the message.
setRecordValue(String) - Method in class osmq.util.FixedLengthRecord
 
setRemoteMonitorIP(String) - Static method in class osmq.broker.handlers.ChangeHandler
 
setRole(String) - Method in class osmq.clients.ClientStream
 
setRowListenerList(RowListenerList) - Method in class osmq.uicontrols.BaseSyncField
 
setSafestore(boolean) - Method in class osmq.broker.BrokerEngine
 
setSelectionModel(ListSelectionModel) - Method in class osmq.tables.KeyedRowTableModel
 
setSequenceNumber(long) - Method in interface osmq.messages.DataSetMessage
Sets the sequence number for this message.
setSequenceNumber(long) - Method in class osmq.messages.DataSetMessageBean
Sets the sequence number for this message.
setSequenceNumber(long) - Method in interface osmq.messages.MessageAttributes
Sets the sequence number for this message.
setSequenceNumber(long) - Method in class osmq.messages.MessageBean
Sets the sequence number for this message.
setSequenceNumber(long) - Method in class osmq.messages.MessageHeader
Sets the sequence number for this message.
setServiceChannel(int) - Method in class osmq.pulsar.DynamicPulsar
 
setServiceID(String) - Method in class osmq.net.RemoteService
 
setServiceID(String) - Method in class osmq.net.RemoteServiceWrapper
 
setServiceName(String) - Method in class osmq.broker.BrokerEngine
 
setServiceName(String) - Method in class osmq.broker.RemoteLogger
 
setServiceName(String) - Method in class osmq.broker.SlaveRouterProcessor
 
setServiceName(String) - Method in class osmq.broker.StatsEngine
 
setServiceName(String) - Method in class osmq.pulsar.ServicePulsar
 
setServicePort(int) - Method in class osmq.pulsar.ServicePulsar
 
setShort(int, short) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a short value
setShort(int, short) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a short value
setShort(int, short) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a short value
setShort(int, short) - Method in class osmq.records.DataRecordBean
Sets the element of the designated position in the DataRecord object to a short value
setShort(int, short) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a short value
setShowDays(boolean) - Method in class osmq.util.DurationClock
 
setSocket(Socket, boolean) - Method in class osmq.net.SocketStreamFilter
This method may be called to replace an exisiting socket.
setSocket(DiscoverySocket) - Method in class osmq.net.SocketStreamFilter
This method may be called to replace an exisiting socket.
setSorter(ThreadBean) - Static method in class osmq.broker.Singletons
 
setSortingTableModel(SortingTableModel) - Method in class osmq.tables.KeyedRowTableModel
 
setSsnMask() - Method in class osmq.uicontrols.Formatter
 
setSsnMask() - Method in class osmq.uicontrols.SyncTextField
 
setStartupValues(DataRecord) - Method in class osmq.broker.BrokerEngine
 
setStateEventListener(StateEventListener) - Method in class osmq.broker.BrokerEngine
 
setStatsEngine(StatsEngine) - Method in class osmq.broker.PulsarManager
 
setStreamFilter(SocketStreamFilter) - Method in class osmq.broker.handlers.ServiceHandler
 
setStreamMode(String) - Method in class osmq.net.RemoteService
 
setStreamMode(String) - Method in class osmq.net.RemoteServiceWrapper
 
setString(int, String) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to a String value
setString(int, String) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to a String value
setString(int, String) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a String value
setString(int, String) - Method in class osmq.records.DataRecordBean
Sets the element at the designated position in the DataRecord object to a String value
setString(int, String) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to a String value
setString(String) - Method in class osmq.util.CSVParser
 
setString(String) - Method in class osmq.util.DelimitedStringParser
 
setSubscriberStats() - Method in class osmq.broker.StatsContainer
 
setSubscriberThreshold(int) - Static method in class osmq.broker.Singletons
 
setTableAttrib(TableAttrib) - Method in class osmq.tables.KeyedRowTableModel
 
setTableAttrib(TableAttrib) - Method in class osmq.uicontrols.KeyedTable
 
setTableAttrib(TableAttrib) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
setTableAttributes(TableAttrib) - Method in class osmq.tables.KeyedRowList
 
setText(String) - Method in interface osmq.records.DataRecord
Sets the elements to the values found in a delimited String.
setText(String) - Method in class osmq.records.DataRecordBean
Sets the value of element in the DataRecord to values found in a delimited String.
setText(String) - Method in class osmq.records.DataRecordWrapper
Sets the DataRecord elements to the values found in a delimited String.
setThreadPriority(int) - Method in interface osmq.clients.Subscriber
Sets the thread priority for the subscriber notification thread.
setThreadPriority(int) - Method in class osmq.clients.SubscriberBean
 
setThreadPriority(int) - Method in class osmq.clients.TopicSubscriberBean
 
setThreadable(Threadable) - Method in class osmq.util.ThreadBean
 
setThreaded(boolean) - Method in class osmq.clients.BatchPublisher
Determines whether batch publishing will be performed by a seperate thread, or by the thread that calls PublishMessages().
setThreaded(boolean) - Method in interface osmq.clients.Publisher
 
setThreaded(boolean) - Method in class osmq.clients.PublisherBean
 
setThreshold(long) - Method in class osmq.util.Accumulator
 
setThresholdOverride(int) - Method in class osmq.broker.subqueues.SubscriberQueues
 
setThrottleRate(int) - Method in class osmq.util.RateRegulator
 
setTimeStamp(long) - Method in interface osmq.messages.DataSetMessage
Sets the time the message was publisherd.
setTimeStamp(long) - Method in class osmq.messages.DataSetMessageBean
Sets the time the message was publisherd.
setTimeStamp(long) - Method in interface osmq.messages.MessageAttributes
Sets the time the message was publisherd.
setTimeStamp(long) - Method in class osmq.messages.MessageBean
Sets the time the message was publisherd.
setTimeStamp(long) - Method in class osmq.messages.MessageHeader
Sets the time the message was publisherd.
setTimeToLive(int) - Method in class osmq.mcns.MCResponder
 
setTimeToLive(int) - Method in class osmq.mcns.MulticastListener
 
setTimed(boolean) - Method in interface osmq.logs.Log
 
setTimed(boolean) - Method in class osmq.logs.PrintWriterLog
 
setTimeoutSeconds(int) - Method in class osmq.pulsar.DatasetPulsarListener
 
setTimeoutSeconds(int) - Method in class osmq.pulsar.HeartbeatListener
 
setTimeoutSecs(int) - Method in class osmq.mcns.MulticastListener
 
setTitle(String) - Method in class osmq.tables.ColumnAttrib
 
setTopic(String) - Method in interface osmq.messages.DataSetMessage
Sets the topic that identifies the message contents.
setTopic(String) - Method in class osmq.messages.DataSetMessageBean
Sets the topic that identifies the message contents.
setTopic(String) - Method in interface osmq.messages.MessageAttributes
 
setTopic(String) - Method in class osmq.messages.MessageBean
Sets the topic that identifies the message contents.
setTopic(String) - Method in class osmq.messages.MessageHeader
 
setTrace(OutputStream) - Static method in class osmq.logs.Logs
 
setTransaction(String) - Method in interface osmq.messages.DataSetMessage
Sets the transaction identifer.
setTransaction(String) - Method in class osmq.messages.DataSetMessageBean
Sets the transaction identifer.
setTransaction(String) - Method in interface osmq.messages.MessageAttributes
 
setTransaction(String) - Method in class osmq.messages.MessageBean
Sets the transaction identifer.
setTransaction(String) - Method in class osmq.messages.MessageHeader
 
setTransactionAsChar(char) - Method in interface osmq.messages.DataSetMessage
Sets the transaction identifer to a char value.
setTransactionAsChar(char) - Method in class osmq.messages.DataSetMessageBean
Sets the transaction identifer to a char value.
setTransactionAsChar(char) - Method in interface osmq.messages.MessageAttributes
 
setTransactionAsChar(char) - Method in class osmq.messages.MessageBean
 
setTransactionAsChar(char) - Method in class osmq.messages.MessageHeader
 
setTrimQuotes(boolean) - Method in class osmq.util.CSVParser
 
setTrimmedString(int, String) - Method in interface osmq.messages.DataSetMessage
 
setTrimmedString(int, String) - Method in class osmq.messages.DataSetMessageBean
 
setTrimmedString(int, String) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to a String value.
setTrimmedString(int, String) - Method in class osmq.records.DataRecordBean
 
setTrimmedString(int, String) - Method in class osmq.records.DataRecordWrapper
 
setTtl(int) - Method in class osmq.mcns.NetworkScope
 
setType(char) - Method in interface osmq.messages.DataSetMessage
Sets the message type.
setType(char) - Method in class osmq.messages.DataSetMessageBean
Sets the message type.
setType(char) - Method in interface osmq.messages.MessageAttributes
Sets the message type.
setType(char) - Method in class osmq.messages.MessageBean
Sets the event type.
setType(char) - Method in class osmq.messages.MessageHeader
Sets the message type.
setUpperCaseString(int, String) - Method in interface osmq.messages.DataSetMessage
Sets the element at the designated position in the message body to an upper-case String value
setUpperCaseString(int, String) - Method in class osmq.messages.DataSetMessageBean
Sets the element at the designated position in the message body to an upper-case String value
setUpperCaseString(int, String) - Method in interface osmq.records.DataRecord
Sets the element at the designated position to an upper-case String value
setUpperCaseString(int, String) - Method in class osmq.records.DataRecordBean
 
setUpperCaseString(int, String) - Method in class osmq.records.DataRecordWrapper
Sets the element at the designated position in the DataRecord object to an upper-case String value
setUseKeys(boolean) - Method in class osmq.tables.KeyedRowList
If true, key value of object will determine whether an object is added or replaced when put() is called.
setUseKeys(boolean) - Method in class osmq.tables.KeyedRowTableModel
 
setUseKeys(boolean) - Method in class osmq.uicontrols.KeyedTable
 
setUseKeys(boolean) - Method in class osmq.uicontrols.ScrollingKeyedTable
 
setUseKeys(boolean) - Method in class osmq.util.KeyedOrderedList
If true, key value of object will determine whether an object is added or replaced when put() is called.
setUserDefinedName(String) - Method in class osmq.util.ThreadBean
 
setUserDefinedName(String) - Method in class osmq.util.Threaded
 
setValue(Object) - Method in class osmq.tables.CurrencyRenderer
 
setValue(Object) - Method in class osmq.tables.FixedDecimalRenderer
 
setValue(Object) - Method in class osmq.tables.IntegerRenderer
 
setValue(Object) - Method in class osmq.tables.PhoneRenderer
 
setValue(Object) - Method in class osmq.tables.SsnRenderer
 
setValue(double) - Method in class osmq.util.DecimalConverter
 
setValueAt(Object, int, int) - Method in class osmq.tables.ListenerTableMap
 
setValueAt(Object, int, int) - Method in class osmq.tables.SortingTableModel
 
setVis(Log) - Static method in class osmq.logs.Logs
 
setVisible(boolean) - Method in class osmq.tables.ColumnAttrib
 
setWanScope() - Static method in class osmq.mcns.NetworkScope
 
setWidth(int) - Method in class osmq.tables.ColumnAttrib
 
setWorkerClass(Class, String) - Method in class osmq.broker.handlers.ServerSocketProcessor
 
setYieldCount(int) - Method in class osmq.util.ThreadBean
 
setYieldCount(int) - Method in class osmq.util.Threaded
Used to control whether to give up time slice to threads with the same priority.
showContents() - Method in class osmq.tables.KeyedRowList
 
showContents(Log) - Method in class osmq.util.KeyedOrderedList
 
showContents() - Method in class osmq.util.KeyedOrderedList
 
showMark(String) - Method in class osmq.util.StopWatch
 
showReset(String) - Method in class osmq.util.StopWatch
 
showStats() - Method in class osmq.util.Stats
 
shutDown() - Method in class osmq.broker.BrokerEngine
 
shutdownRequested() - Method in class osmq.util.AbstractThreadable
 
shutdownRequested() - Method in class osmq.util.Threaded
 
shuttlesort(int[], int[], int, int) - Method in class osmq.tables.SortingTableModel
 
size(String) - Method in class osmq.broker.subqueues.SubscriberQueues
 
size() - Method in class osmq.mque.MQue
Returns the number of elements currently on the queue.
size() - Method in class osmq.records.CoreRecord
 
size() - Method in class osmq.tables.KeyedRowList
 
size() - Method in class osmq.tables.RowAttrib
 
size() - Method in class osmq.util.KeyedOrderedList
 
sleepSecs(int) - Static method in class osmq.util.ThreadBean
 
sleepSecs(int) - Static method in class osmq.util.Threaded
 
sleepTenths(int) - Static method in class osmq.util.ThreadBean
 
sleepTenths(int) - Static method in class osmq.util.Threaded
 
sliceReset() - Method in class osmq.util.EventRate
 
sort(Object) - Method in class osmq.tables.SortingTableModel
 
sortByColumn(int) - Method in class osmq.tables.SortingTableModel
 
sortByColumn(int, boolean) - Method in class osmq.tables.SortingTableModel
 
sortCompleted() - Method in class osmq.uicontrols.KeyedTable
 
sorted - Variable in class osmq.broker.StatsContainer
 
spaces(int) - Static method in class osmq.util.Padding
 
sqrt() - Method in class osmq.datatypes.FixedDecimal
 
sqrt(FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
start() - Method in class osmq.broker.BrokerEngine
 
start() - Method in class osmq.broker.BrokerFaultMonitor
 
start() - Method in class osmq.broker.PulsarManager
 
start() - Method in class osmq.broker.StatsEngine
 
start(String, int, boolean) - Method in class osmq.net.DiscoveryServer
 
start() - Method in class osmq.util.Threaded
This method first calls the derived class's initialize() method, and then begins iteratively executing the derived class's iterativeProcess() function.
startNotifications() - Method in class osmq.util.DurationTimer
 
startTimeAsDateString() - Method in class osmq.util.Timer
 
stop() - Method in class osmq.broker.BrokerEngine
 
stop() - Method in class osmq.broker.BrokerFaultMonitor
 
stop() - Method in class osmq.broker.PulsarManager
 
stop() - Method in class osmq.broker.StatsEngine
 
stop() - Method in class osmq.clients.ThreadedPublisherBean
 
stop() - Method in class osmq.util.Threaded
Halt execution of the thread processing
stop() - Method in class osmq.util.TickEventBean
 
stopNotifications() - Method in class osmq.util.DurationTimer
 
stringToDate(String) - Static method in class osmq.util.DateFormatter
Converts a date string in CCYYMMDD format to a Date object
sub(FixedDecimal) - Method in class osmq.datatypes.FixedDecimal
 
sub(FixedDecimal, FixedDecimal) - Static method in class osmq.datatypes.FixedDecimal
 
substring(int) - Method in class osmq.util.ByteString
 
substring(int, int) - Method in class osmq.util.ByteString
 
subtract(double) - Method in class osmq.datatypes.Decimal
 
subtract(Decimal) - Method in class osmq.datatypes.Decimal
 
successfulInit() - Method in class osmq.util.Threaded
 
swap(int, int) - Method in class osmq.tables.SortingTableModel
 

T

TASK_COMPLETED - Static variable in class osmq.util.StateEvent
 
TASK_INBOUND - Static variable in interface osmq.broker.config.BrokerConsts
 
TASK_OUTBOUND - Static variable in interface osmq.broker.config.BrokerConsts
 
TASK_SORTER - Static variable in interface osmq.broker.config.BrokerConsts
 
TASK_SUBSCRIBE - Static variable in interface osmq.broker.config.BrokerConsts
 
TASK_UNKNOWN - Static variable in interface osmq.broker.config.BrokerConsts
 
TERMINATION - Static variable in class osmq.util.Trace
 
TEST_ALIVE_FREQUENCY - Static variable in class osmq.mcns.MCNS
 
TEST_ALIVE_FREQUENCY - Static variable in interface osmq.pulsar.Threshold
 
TEXT - Static variable in interface osmq.messages.MessageFormat
 
TEXT - Static variable in class osmq.util.FixedLengthRecord
 
TIMEOUT_THRESHOLD - Static variable in interface osmq.pulsar.Threshold
 
TIME_DURATION - Static variable in class osmq.broker.StatsContainer
 
TIME_EVENT - Static variable in class osmq.util.StateEvent
 
TOPIC - Static variable in interface osmq.messages.MessageAttributes
 
TOPIC_CHG - Static variable in interface osmq.messages.MessageType
 
TOPIC_CHG_HANDLER_PRIORITY - Static variable in interface osmq.broker.config.BrokerConsts
 
TOPIC_DETAILS - Static variable in class osmq.broker.StatsContainer
 
TOPIC_FILE_NAME - Static variable in interface osmq.util.NetConsts
 
TOPIC_FLAG - Static variable in interface osmq.util.NetConsts
 
TOTAL_ATTRIBUTES - Static variable in interface osmq.messages.MessageAttributes
 
TOTAL_MEMORY - Static variable in class osmq.broker.StatsContainer
 
TOTAL_PARMS - Static variable in class osmq.broker.config.StartupParms
 
TRACE_ON - Static variable in interface osmq.broker.config.BrokerConsts
 
TRANSACTION - Static variable in interface osmq.messages.MessageAttributes
 
TRANS_ADD - Static variable in interface osmq.messages.MessageAttributes
 
TRANS_DELETE - Static variable in interface osmq.messages.MessageAttributes
 
TRANS_UPDATE - Static variable in interface osmq.messages.MessageAttributes
 
TYPE - Static variable in interface osmq.messages.MessageAttributes
 
TableAttrib - class osmq.tables.TableAttrib.
A container of ColumnAttrib object.
TableAttrib() - Constructor for class osmq.tables.TableAttrib
 
TempFile - class osmq.util.TempFile.
 
TempFile(File) - Constructor for class osmq.util.TempFile
 
TempFile() - Constructor for class osmq.util.TempFile
 
ThreadBean - class osmq.util.ThreadBean.
Base class for objects that need a seperate thread to iteratively perform a task.
ThreadBean() - Constructor for class osmq.util.ThreadBean
 
ThreadBean(Threadable) - Constructor for class osmq.util.ThreadBean
 
Threadable - interface osmq.util.Threadable.
Base class for objects that need a seperate thread to iteratively perform a task.
Threaded - class osmq.util.Threaded.
Base class for objects that need a seperate thread to iteratively perform a task.
Threaded() - Constructor for class osmq.util.Threaded
 
ThreadedPublisherBean - class osmq.clients.ThreadedPublisherBean.
A multi-threaded class derived from the PublisherBean class.
ThreadedPublisherBean() - Constructor for class osmq.clients.ThreadedPublisherBean
 
ThreadedPublisherBean(PubConnectionHandler) - Constructor for class osmq.clients.ThreadedPublisherBean
 
ThreadedPublisherBean(RemoteService) - Constructor for class osmq.clients.ThreadedPublisherBean
 
ThreadedReader - class osmq.util.ThreadedReader.
 
ThreadedReader() - Constructor for class osmq.util.ThreadedReader
 
ThreadedReader(Readable) - Constructor for class osmq.util.ThreadedReader
 
Threshold - interface osmq.pulsar.Threshold.
 
TickEvent - class osmq.util.TickEvent.
 
TickEventBean - class osmq.util.TickEventBean.
 
TickEventBean() - Constructor for class osmq.util.TickEventBean
 
TickEventListener - interface osmq.util.TickEventListener.
 
Timer - class osmq.util.Timer.
 
Timer() - Constructor for class osmq.util.Timer
 
TokenFinder - class osmq.util.TokenFinder.
 
TokenFinder() - Constructor for class osmq.util.TokenFinder
 
TopicChangeHandler - class osmq.broker.handlers.TopicChangeHandler.
An aggregate of the MRouter class that listens on a multicast channgel for topic change requests and updates a RouterMux to reflect the change (Add or drop a topic/subscriber pair).
TopicChangeHandler() - Constructor for class osmq.broker.handlers.TopicChangeHandler
 
TopicChangeRequestor - class osmq.clients.TopicChangeRequestor.
A client component that submits one or more change requests to the router/server.
TopicSet - class osmq.util.TopicSet.
 
TopicSet() - Constructor for class osmq.util.TopicSet
 
TopicSubscriberBean - class osmq.clients.TopicSubscriberBean.
A class used by client applications to receive messages.
TopicSubscriberBean() - Constructor for class osmq.clients.TopicSubscriberBean
 
TopicSubscriptions - class osmq.broker.subqueues.TopicSubscriptions.
Used to associate a topic with one or more subscribers.
TopicSubscriptions() - Constructor for class osmq.broker.subqueues.TopicSubscriptions
 
TopicSubscriptions(String) - Constructor for class osmq.broker.subqueues.TopicSubscriptions
 
TopicalSubscriberQueues - class osmq.broker.subqueues.TopicalSubscriberQueues.
Extends SubscriberQueues, adding topical subscription processing.
TopicalSubscriberQueues() - Constructor for class osmq.broker.subqueues.TopicalSubscriberQueues
 
TopicsListeners - class osmq.util.TopicsListeners.
Supports differentiating MessageListener instance by topic.
TopicsListeners() - Constructor for class osmq.util.TopicsListeners
 
Trace - class osmq.util.Trace.
 
Trace() - Constructor for class osmq.util.Trace
 
TrimFormatter - class osmq.util.TrimFormatter.
 
TrimFormatter() - Constructor for class osmq.util.TrimFormatter
 
tableChanged(TableModelEvent) - Method in class osmq.tables.ListenerTableMap
 
tableChanged(TableModelEvent) - Method in class osmq.tables.SortingTableModel
 
terminateAllChildren() - Static method in class osmq.broker.handlers.TopicChangeHandler
 
terminationProcess() - Method in class osmq.util.AbstractThreadable
 
testStateEvent() - Method in class osmq.util.StateEventBean
 
times(int) - Method in class osmq.datatypes.Decimal
 
times(int) - Method in class osmq.datatypes.Price
 
toASCII(char) - Static method in class osmq.util.EbcdicTranslator
Passed an EBCDIC charater and returns its ASCII equivalent
toASCII(String) - Method in class osmq.util.EbcdicTranslator
 
toASCII(StringBuffer, StringBuffer) - Method in class osmq.util.EbcdicTranslator
Passed an ASCII StringBuffer and returns its EBCDIC equivalent
toCharArray() - Method in class osmq.util.ByteString
 
toEBCDIC(char) - Static method in class osmq.util.EbcdicTranslator
Passed an ASCII character and returns its EBCDIC equivalent
toEBCDIC(String) - Method in class osmq.util.EbcdicTranslator
 
toEBCDIC(StringBuffer, StringBuffer) - Method in class osmq.util.EbcdicTranslator
Passed an EBCDIC StringBuffer and returns its ASCII equivalent
toString() - Method in class osmq.datatypes.Decimal
 
toString() - Method in class osmq.datatypes.FixedDecimal
 
toString() - Method in class osmq.datatypes.Phone
 
toString() - Method in class osmq.datatypes.Price
 
toString() - Method in class osmq.datatypes.Rstring
 
toString() - Method in class osmq.datatypes.SocialSecurityNumber
 
toString() - Method in interface osmq.messages.DataSetMessage
 
toString() - Method in class osmq.messages.DataSetMessageBean
 
toString() - Method in class osmq.mque.MQue
 
toString() - Method in class osmq.net.RemoteService
 
toString() - Method in class osmq.net.RemoteServiceWrapper
 
toString() - Method in class osmq.records.DataRecordBean
 
toString() - Method in class osmq.records.DataRecordWrapper
 
toString() - Method in class osmq.util.ByteString
 
toString() - Method in class osmq.util.DecimalConverter
 
toString() - Method in class osmq.util.DurationClock
Returns value of last refreshDurationString()
toString() - Method in class osmq.util.DurationTimer
 
toString() - Method in class osmq.util.DynByteArray
 
topicdetails - Variable in class osmq.broker.StatsContainer
 
totalmemory - Variable in class osmq.broker.StatsContainer
 
trace - Static variable in class osmq.logs.Logs
 
trim() - Method in class osmq.util.ByteString
 
trimChar(String, char) - Static method in class osmq.util.TrimFormatter
 
trimDate2(String) - Static method in class osmq.util.DateFormatter
 
trimDateString(String) - Static method in class osmq.util.DateFormatter
 
trimDecimal(String) - Static method in class osmq.util.TrimFormatter
 
trimInteger(String) - Static method in class osmq.util.TrimFormatter
Removes leading zeros and trims spaces from an interger string.
typeToClass(int) - Static method in class osmq.tables.ColumnAttrib
 

U

UNKNOWN - Static variable in interface osmq.datatypes.DataType
 
UNKNOWN - Static variable in interface osmq.messages.MessageFormat
 
UNPAUSE_BROKER - Static variable in class osmq.broker.ChangeRequestor
 
UNPAUSE_EVENT - Static variable in class osmq.util.StateEvent
 
UNSORTED_COUNT - Static variable in class osmq.broker.StatsContainer
 
USE_BINARY_MODE - Static variable in class osmq.broker.config.StartupParms
 
USE_DISCOVERY - Static variable in class osmq.broker.config.StartupParms
 
USE_PULSE - Static variable in class osmq.broker.config.StartupParms
 
USE_SAFESTORE - Static variable in interface osmq.broker.config.BrokerConsts
 
USE_SAFESTORE - Static variable in class osmq.broker.config.StartupParms
 
USE_TRACE - Static variable in class osmq.broker.config.StartupParms
 
unformatDecimalString(String) - Static method in class osmq.util.TrimFormatter
 
unlock() - Method in class osmq.util.DataLock
 
unsorted - Variable in class osmq.broker.StatsContainer
 
upProcessCount() - Method in class osmq.broker.handlers.ServerSocketProcessor
 
updated() - Method in class osmq.tables.KeyedRowList
 
updated() - Method in class osmq.util.KeyedOrderedList
 
useAuditLog(boolean) - Static method in class osmq.logs.Logs
 
useErrLogFile(boolean) - Static method in class osmq.logs.Logs
 
useSafeStoreLog(boolean) - Static method in class osmq.logs.Logs
 
useTraceLog(boolean) - Static method in class osmq.logs.Logs
 

V

VERY_HIGH_PRIORITY - Static variable in interface osmq.util.Threadable
 
VERY_HIGH_PRIORITY - Static variable in class osmq.util.Threaded
 
validString() - Method in class osmq.util.StringParser
 
valueChanged(ListSelectionEvent) - Method in class osmq.tables.KeyedRowTableModel
 
vis - Static variable in class osmq.logs.Logs
 

W

WAN - Static variable in class osmq.mcns.NetworkScope
 
Writable - interface osmq.util.Writable.
A listener that is passed an Object.
WriterStream - interface osmq.io.WriterStream.
 
waitForUnlock() - Method in class osmq.util.DataLock
 
wasFound() - Method in class osmq.util.TokenFinder
 
wasNull() - Method in interface osmq.messages.DataSetMessage
Returns true if the lastfetched element was a null object, or an object with a string length of zero.
wasNull() - Method in class osmq.messages.DataSetMessageBean
Returns true if the lastfetched element was a null object, or an object with a string length of zero.
wasNull() - Method in class osmq.records.CoreRecord
Returns true if the last get() returned a null object, or the last get() object had a string length of zero
wasNull() - Method in interface osmq.records.DataRecord
Returns true if the last fetched element was a null object, or the last fetched has a string length of zero.
wasNull() - Method in class osmq.records.DataRecordBean
Returns true if the lastfetched element was a null object, or an object with a string length of zero.
wasNull() - Method in class osmq.records.DataRecordWrapper
Returns true if the lastfetched element was a null object, or an object with a string length of zero.
write(byte[], int, int) - Method in class osmq.io.PacketOutputStream
Writes the byte array to the underlying output stream, maintaining size information so that the corollary BytePacketReader can fetch packets in the same byte size units.
writeAllFromQue(MQue) - Method in class osmq.mque.MQue
Pulls elements from another queue, writing them to this queue.
writeBytes(byte[]) - Method in class osmq.broker.handlers.ServiceHandler
 
writeBytes(byte[]) - Method in class osmq.io.PacketOutputStream
 
writeBytes(byte[]) - Method in class osmq.io.StringOutputStream
 
writeBytes(byte[]) - Method in interface osmq.io.WriterStream
 
writeBytes(byte[]) - Method in class osmq.mque.MQue
Creates a duplicate copy of the byte array and writes it to the queue.
writeBytes(byte[]) - Method in class osmq.net.SocketStreamFilter
Write an array of bytes to the socket stream
writeBytes(byte[]) - Method in interface osmq.util.Writable
A class of objects that is passed an object.
writeBytesCounted(byte[]) - Method in class osmq.net.SocketStreamFilter
Write an array of bytes to the socket stream and increments the write count
writeBytesNoDuplicate(byte[]) - Method in class osmq.mque.MQue
Writes the byte array to the queue without duplicating it.
writeNull() - Method in class osmq.io.PacketOutputStream
Writes a null object to the stream which is ignored by the corresponding PacketInputStream.
writeNull() - Method in class osmq.io.StringOutputStream
 
writeNull() - Method in interface osmq.io.WriterStream
Writes a null object to the stream which is ignored by the corresponding ReaderStream.
writeNull() - Method in class osmq.net.SocketStreamFilter
Used to test active socket connections.
writeSlaveToQueue(PersistableMQue) - Method in class osmq.broker.SlaveRouterProcessor
Takes the data that has been written and transfers it to the target Queue.
writeString(String) - Method in class osmq.mque.MQue
Writes a String to the queue.

Z

ZERO - Static variable in class osmq.datatypes.FixedDecimal
 
ZeroPrice - Static variable in class osmq.datatypes.Price
 
ZipPacketFileInputStream - class osmq.io.ZipPacketFileInputStream.
 
ZipPacketFileInputStream(String) - Constructor for class osmq.io.ZipPacketFileInputStream
 
ZipPacketFileInputStream(File) - Constructor for class osmq.io.ZipPacketFileInputStream
 
ZipPacketFileOutputStream - class osmq.io.ZipPacketFileOutputStream.
 
ZipPacketFileOutputStream(String) - Constructor for class osmq.io.ZipPacketFileOutputStream
 
ZipPacketFileOutputStream(String, boolean) - Constructor for class osmq.io.ZipPacketFileOutputStream
 
ZipPacketInputStream - class osmq.io.ZipPacketInputStream.
 
ZipPacketInputStream(GZIPInputStream) - Constructor for class osmq.io.ZipPacketInputStream
 
ZipPacketOutputStream - class osmq.io.ZipPacketOutputStream.
 
ZipPacketOutputStream(GZIPOutputStream) - Constructor for class osmq.io.ZipPacketOutputStream
 

_

_buffer - Variable in class osmq.mcns.MulticastListener
 
_duplicate(byte[]) - Method in class osmq.messages.MessageBean
 

A B C D E F G H I J K L M N O P Q R S T U V W Z _
(c) 2000 - 2003 MQue Systems
All Rights Reserved