OSMQ
v2.0.1

Constant Field Values


Contents
osmq.broker.*

osmq.broker.Broker
public static final java.lang.String CONFIG_NAME "config.ini"

osmq.broker.ChangeRequestor
public static final java.lang.String FLUSH_QUEUE "F"
public static final java.lang.String FLUSH_TOPICS "T"
public static final java.lang.String KILL_BROKER "X"
public static final java.lang.String KILL_SUBSCRIBER "K"
public static final java.lang.String PAUSE_BROKER "P"
public static final java.lang.String UNPAUSE_BROKER "U"

osmq.broker.StatsContainer
public static final int AVG_RATE 5
public static final int BROKER_NAME 1
public static final int BYTES_PUBLISHED 11
public static final int ELEMENT_COUNT 18
public static final int HELD_COUNT 4
public static final int LAST_RATE 7
public static final int MEMORY_AVAIL 14
public static final int PEAK_RATE 6
public static final int PUBLISH_DETAILS 18
public static final int PUBLISHER_AGENTS 8
public static final int PUBLISHER_MSG_COUNT 10
public static final int QUEUE_DETAILS 16
public static final int SORTED_COUNT 3
public static final int SUBSCRIBER_AGENTS 9
public static final int SUBSCRIBER_MSG_COUNT 12
public static final int TIME_DURATION 13
public static final int TOPIC_DETAILS 17
public static final int TOTAL_MEMORY 15
public static final int UNSORTED_COUNT 2

osmq.broker.config.BrokerConsts
public static final int ACCEPT_LISTENER_PRIORITY 9
public static final boolean BINARY_SOCKET_STREAMS true
public static final java.lang.String CONFIG_NAME "config.ini"
public static final java.lang.String DEFAULT_BROKER_SERVICE_NAME "OSMQ1"
public static final boolean LOAD_TOPICS_ON_CREATE true
public static final java.lang.String MESSAGE_RECORDER_NAME "MRECORDER"
public static final int PIPELINE_THRESHOLD 1000
public static final int PUBLISHER_PRIORITY 4
public static final int PUBLISHER_YIELD_COUNT 2
public static final int SORTER_PRIORITY 8
public static final int SORTER_YIELD_COUNT 100
public static final int STATS_REFRESH_RATE 5
public static final int SUBSCRIBER_PRIORITY 8
public static final int SUBSCRIBER_THRESHOLD 200
public static final int SUBSCRIBER_YIELD_COUNT 50
public static final int TASK_INBOUND 1
public static final int TASK_OUTBOUND 2
public static final int TASK_SORTER 4
public static final int TASK_SUBSCRIBE 3
public static final int TASK_UNKNOWN 0
public static final int TOPIC_CHG_HANDLER_PRIORITY 9
public static final boolean TRACE_ON false
public static final boolean USE_SAFESTORE false

osmq.broker.config.StartupParms
public static final int MC_TTL 12
public static final int PAGE_THRESHOLD 8
public static final int PORT_ID 3
public static final int REFRESH_RATE_SECS 7
public static final int RELOAD_TOPIC_TABLE 1
public static final int REMOTE_ADMIN_IP 9
public static final int SERVER_NAME 2
public static final int TOTAL_PARMS 12
public static final int USE_BINARY_MODE 10
public static final int USE_DISCOVERY 11
public static final int USE_PULSE 4
public static final int USE_SAFESTORE 5
public static final int USE_TRACE 6

osmq.broker.handlers.ChangeHandler
public static final java.lang.String ALL_OPTION "ALL"

osmq.clients.*

osmq.clients.ClientStream
public static final java.lang.String ROLE_COMMAND "C"
public static final java.lang.String ROLE_PUBLISHER "P"
public static final java.lang.String ROLE_RECOVERY "R"
public static final java.lang.String ROLE_SUBSCRIBER "S"
public static final java.lang.String ROLE_TOPIC_CHG "T"

osmq.clients.TopicChangeRequestor
public static final java.lang.String ADD_STRING "+ "
public static final java.lang.String DROP_STRING "- "

osmq.datatypes.*

osmq.datatypes.DataType
public static final int CHAR 3
public static final int CURRENCY 7
public static final int DECIMAL 8
public static final int DOUBLE 6
public static final int INTEGER 4
public static final int LONG 5
public static final int PHONE 11
public static final int RIGHTALIGN 2
public static final int SIZE 9
public static final int SSN 10
public static final int STRING 1
public static final int UNKNOWN 0

osmq.io.*

osmq.io.Packet
public static final int INT_BYTE_ARRAY_SZ 4

osmq.mcns.*

osmq.mcns.MCNS
public static final int ALARM_THRESHOLD_SECONDS 30
public static final int CLIENT_SOCKET_TIMEOUT 3000
public static final int DISCOVERY_CHANNEL 4547
public static final int ERROR_DISOVERY_SERVER_NOT_RESPONDING 3
public static final int ERROR_NO_SERVICE_ENTRY 1
public static final int ERROR_SERVICE_NOT_ALIVE 2
public static final int MAX_LOOKUP_TRIES 3
public static final int PULSAR_CHANNEL 4546
public static final int READBUF_SIZE 1024
public static final int RESULT_FOUND_NAME 0
public static final int RESULT_HOST_ADDRESS 1
public static final int RESULT_HOST_PORT 2
public static final int RESULT_SERVICE_STATUS 3
public static final int SECONDS 1000
public static final int SERVICE_ACTIVE 0
public static final int TEST_ALIVE_FREQUENCY 30

osmq.mcns.NetworkScope
public static final java.lang.String EXTENDED_DOTTED_IP_GROUP "238.50.34.15"
public static final int EXTENDED_TTL 3
public static final int LAN 0
public static final java.lang.String LOCAL_DOTTED_IP_GROUP "239.10.10.10"
public static final int LOCAL_TTL 1
public static final int WAN 1

osmq.messages.*

osmq.messages.MessageAttributes
public static final int CONTENT_FORMAT 5
public static final int CORRELATION_ID 8
public static final int DATA_KEY 6
public static final int ORIGINATOR 4
public static final int RECIPIENT 1
public static final int SEND_TIMESTAMP 9
public static final int SENDER_SEQ 10
public static final int TOPIC 2
public static final int TOTAL_ATTRIBUTES 10
public static final char TRANS_ADD 65
public static final char TRANS_DELETE 68
public static final char TRANS_UPDATE 85
public static final int TRANSACTION 7
public static final int TYPE 3

osmq.messages.MessageFormat
public static final char BINARY 66
public static final char DATASET 68
public static final char TEXT 84
public static final char UNKNOWN 85

osmq.messages.MessageType
public static final char BATCH_CONTROL 66
public static final char DENIAL 68
public static final char NOTIFICATION 78
public static final char REQUEST 82
public static final char TOPIC_CHG 84

osmq.mque.*

osmq.mque.QueueException
public static final int QE_CAPACITY_EXCEEDED 2
public static final int QE_CLOSED 4
public static final int QE_DOUBLE_PUSH_BACK 5
public static final int QE_READ_HALTED 3
public static final int QE_SAVING_TO_TEXT_FILE 6
public static final int QE_UNKNOWN 0
public static final int QE_WRITE_HALTED 1

osmq.net.*

osmq.net.RemoteService
public static final boolean DEFAULT_STREAM_MODE_BINARY true

osmq.pulsar.*

osmq.pulsar.Threshold
public static final int ALIVE_ALARM_THRESHOLD 65
public static final int HEARTBEAT_ALARM_THRESHOLD 22
public static final int HEARTBEAT_FREQUENCY 10
public static final int TEST_ALIVE_FREQUENCY 30
public static final int TIMEOUT_THRESHOLD 30

osmq.records.*

osmq.records.CoreRecord
public static final java.lang.String DELIMITER_STRING "|"

osmq.records.DataRecord
public static final char DEFAULT_DELIMITER 124

osmq.tables.*

osmq.tables.KeyedRowList
public static final int ADDED 1
public static final int NONE 0
public static final int REMOVED 3
public static final int REPLACED 2

osmq.uicontrols.*

osmq.uicontrols.Formatter
public static final char ANY_CHAR 42
public static final java.lang.String CURRENCY_MASK "###,###,###,###,##0.00"
public static final char DIGIT_CHAR 35
public static final java.lang.String FOUR_DEC_PRECIS_MASK "###,###,###,###,##0.0###"
public static final java.lang.String INTEGER_MASK "###,###,###,###,##0"
public static final java.lang.String PHONE_MASK "(###)###-####"
public static final java.lang.String SIX_DEC_PRECIS_MASK "###,###,###,###,##0.0#####"
public static final java.lang.String SSN_MASK "###-##-####"

osmq.util.*

osmq.util.DistributionMode
public static final int PULL 1
public static final int PUSH 0

osmq.util.FixedLengthRecord
public static final char DECIMAL 68
public static final char INTEGER 73
public static final char TEXT 84

osmq.util.KeyedOrderedList
public static final int ADDED 1
public static final int NONE 0
public static final int REMOVED 3
public static final int REPLACED 2

osmq.util.NetConsts
public static final java.lang.String COMMAND_FLAG "C"
public static final int DEFAULT_BROKER_PORT 3016
public static final java.lang.String LOG_FILE_NAME "log.txt"
public static final java.lang.String PUBLISHER_FLAG "P"
public static final int PULSAR_PORT 3017
public static final java.lang.String RECORD_DELIMITER "~"
public static final java.lang.String RECOVERY_FLAG "R"
public static final java.lang.String SUBSCRIBER_FLAG "S"
public static final java.lang.String TOPIC_FILE_NAME "topics.ini"
public static final java.lang.String TOPIC_FLAG "T"

osmq.util.SpecialChars
public static final char NULL_CHAR 0
public static final java.lang.String NULL_STRING ""
public static final byte PIPE_BYTE 124
public static final char PIPE_CHAR 124
public static final byte STRING_TERMINATOR_BYTE 13

osmq.util.StateEvent
public static final int CLOSE_EVENT 5
public static final int DISCOVERY_SERV_ACTIVE 12
public static final int FAIL_EVENT 3
public static final int HALT_EVENT 6
public static final int INITIALIZATION_EVENT 4
public static final int PAUSE_EVENT 10
public static final int PULSE_SERV_ACTIVE 13
public static final int RECOVERY_SERV_ATTACHED 14
public static final int RECOVERY_SERV_DETACHED 15
public static final int SIZE_CHANGE_EVENT 7
public static final int SIZE_DECREASE_EVENT 9
public static final int SIZE_INCREASE_EVENT 8
public static final int STATE_EVENT 17
public static final int SUCCESS_EVENT 2
public static final int TASK_COMPLETED 16
public static final int TIME_EVENT 1
public static final int UNPAUSE_EVENT 11

osmq.util.Threadable
public static final int HIGH_PRIORITY 7
public static final int INCREASED_PRIORITY 6
public static final int VERY_HIGH_PRIORITY 8

osmq.util.Threaded
public static final int HIGH_PRIORITY 7
public static final int HIGHEST_PRIORITY 9
public static final int INCREASED_PRIORITY 6
public static final int VERY_HIGH_PRIORITY 8


(c) 2000 - 2003 MQue Systems
All Rights Reserved