|
OSMQ v2.0.1 |
|||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
|||||||||
PREV NEXT | FRAMES NO FRAMES |