Index

A | B | C | D | E | F | G | H | I | L | M | N | P | R | S | T | U | V

A

ack() (AMPS.Client method)
add() (AMPS.DefaultServerChooser method)
add_ack_type() (AMPS.Command method)
add_all() (AMPS.DefaultServerChooser method)
add_connection_state_listener() (AMPS.Client method)
add_message_handler() (AMPS.Client method)
allocate_message() (AMPS.Client method)
allocateMessage() (AMPS.Client method)
AlreadyConnected
AlreadyConnectedException
AMPS (module)
AMPSException
append() (AMPS.CompositeMessageBuilder method)
(AMPS.FIXBuilder method)
(AMPS.NVFIXBuilder method)
authenticate() (AMPS.DefaultAuthenticator method)
AuthenticationError
AuthenticationException

B

BadFilter
BadFilterException
BadRegexTopic
BadRegexTopicException
bookmark_subscribe() (AMPS.Client method)

C

clear() (AMPS.CompositeMessageBuilder method)
Client (class in AMPS)
Client.Bookmarks (class in AMPS)
Client.ConnectionStateListener (class in AMPS)
ClientNameInUse
close() (AMPS.Client method)
(AMPS.MessageStream method)
CMessageHandler (class in AMPS)
Command (class in AMPS)
CommandError
CommandException
CommandTimedOut
CommandTypeError
completed() (AMPS.DefaultAuthenticator method)
CompositeMessageBuilder (class in AMPS)
CompositeMessageParser (class in AMPS)
conflate() (AMPS.MessageStream method)
connect() (AMPS.Client method)
(AMPS.HAClient method)
connect_and_logon() (AMPS.HAClient method)
ConnectionError
ConnectionException
ConnectionRefused
ConnectionRefusedException
convert_version_to_number() (AMPS.Client method)
CorruptedRecord

D

DefaultAuthenticator (class in AMPS)
DefaultServerChooser (class in AMPS)
delta_publish() (AMPS.Client method)
delta_subscribe() (AMPS.Client method)
deltaPublish() (AMPS.Client method)
deltaSubscribe() (AMPS.Client method)
discard() (AMPS.HAClient method)
(AMPS.MMapBookmarkStore method)
(AMPS.MemoryBookmarkStore method)
(AMPS.RingBookmarkStore method)
discard_message() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
disconnect() (AMPS.Client method)
Disconnected
DisconnectedException

E

execute() (AMPS.Client method)
execute_async() (AMPS.Client method)
ExponentialDelayStrategy (class in AMPS)

F

FIXBuilder (class in AMPS)
FixedDelayStrategy (class in AMPS)
FIXShredder (class in AMPS)
flush() (AMPS.Client method)

G

get_ack_batch_size() (AMPS.Client method)
get_ack_timeout() (AMPS.Client method)
get_ack_type() (AMPS.Message method)
get_auto_ack() (AMPS.Client method)
get_batch_size() (AMPS.Message method)
get_bookmark() (AMPS.Message method)
get_bookmark_seq_no() (AMPS.Message method)
get_client_name() (AMPS.Message method)
get_command() (AMPS.Message method)
get_command_id() (AMPS.Message method)
get_connect_wait_duration() (AMPS.ExponentialDelayStrategy method)
(AMPS.FixedDelayStrategy method)
get_correlation_id() (AMPS.Message method)
get_current_authenticator() (AMPS.DefaultServerChooser method)
get_current_uri() (AMPS.DefaultServerChooser method)
get_data() (AMPS.CompositeMessageBuilder method)
(AMPS.Message method)
get_data_raw() (AMPS.Message method)
get_default_max_depth() (AMPS.Client method)
get_depth() (AMPS.MessageStream method)
get_duplicate_message_handler() (AMPS.Client method)
get_error() (AMPS.DefaultServerChooser method)
get_exception_listener() (AMPS.Client method)
get_expiration() (AMPS.Message method)
get_filter() (AMPS.Message method)
get_group_seq_no() (AMPS.Message method)
get_lease_period() (AMPS.Message method)
get_logon_correlation_data() (AMPS.Client method)
get_logon_options() (AMPS.HAClient method)
get_matches() (AMPS.Message method)
get_max_depth() (AMPS.MessageStream method)
get_message_size() (AMPS.Message method)
get_message_type() (AMPS.Message method)
get_most_recent() (AMPS.HAClient method)
(AMPS.MMapBookmarkStore method)
(AMPS.MemoryBookmarkStore method)
(AMPS.RingBookmarkStore method)
get_name() (AMPS.Client method)
get_old_style_version() (AMPS.VersionInfo method)
get_oldest_bookmark_seq() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
get_options() (AMPS.Message method)
get_part() (AMPS.CompositeMessageParser method)
get_part_raw() (AMPS.CompositeMessageParser method)
get_password() (AMPS.Message method)
get_query_id() (AMPS.Message method)
get_reason() (AMPS.Message method)
get_reconnect_delay_strategy() (AMPS.HAClient method)
get_records_inserted() (AMPS.Message method)
get_records_returned() (AMPS.Message method)
get_records_updated() (AMPS.Message method)
get_retry_on_disconnect() (AMPS.Client method)
get_sequence() (AMPS.Message method)
get_server_chooser() (AMPS.HAClient method)
get_server_version() (AMPS.Client method)
get_server_version_info() (AMPS.Client method)
get_sow_deleted() (AMPS.Message method)
get_sow_key() (AMPS.Message method)
get_sow_keys() (AMPS.Message method)
get_status() (AMPS.Message method)
get_string() (AMPS.FIXBuilder method)
(AMPS.NVFIXBuilder method)
get_sub_id() (AMPS.Message method)
get_sub_ids() (AMPS.Message method)
get_timestamp() (AMPS.Message method)
get_top_n() (AMPS.Message method)
get_topic() (AMPS.Message method)
get_topic_matches() (AMPS.Message method)
get_unpersisted_count() (AMPS.Client method)
(AMPS.HybridPublishStore method)
(AMPS.MemoryPublishStore method)
(AMPS.PublishStore method)
get_uri() (AMPS.Client method)
get_user_id() (AMPS.Message method)
get_version_number() (AMPS.VersionInfo method)
get_version_string() (AMPS.VersionInfo method)
getAckType() (AMPS.Message method)
getBatchSize() (AMPS.Message method)
getBookmark() (AMPS.Message method)
getClientName() (AMPS.Message method)
getCommand() (AMPS.Message method)
getCommandId() (AMPS.Message method)
getCorrelationId() (AMPS.Message method)
getData() (AMPS.Message method)
getExpiration() (AMPS.Message method)
getFilter() (AMPS.Message method)
getGroupSequenceNumber() (AMPS.Message method)
getLeasePeriod() (AMPS.Message method)
getMatches() (AMPS.Message method)
getMessageLength() (AMPS.Message method)
getMessageType() (AMPS.Message method)
getName() (AMPS.Client method)
getOptions() (AMPS.Message method)
getPassword() (AMPS.Message method)
getQueryID() (AMPS.Message method)
getReason() (AMPS.Message method)
getRecordsInserted() (AMPS.Message method)
getRecordsReturned() (AMPS.Message method)
getRecordsUpdated() (AMPS.Message method)
getSequence() (AMPS.Message method)
getSowDelete() (AMPS.Message method)
getSowKey() (AMPS.Message method)
getSowKeys() (AMPS.Message method)
getStatus() (AMPS.Message method)
getSubscriptionId() (AMPS.Message method)
getSubscriptionIds() (AMPS.Message method)
getTimestamp() (AMPS.Message method)
getTopic() (AMPS.Message method)
getTopicMatches() (AMPS.Message method)
getTopNRecordsReturned() (AMPS.Message method)
getUserId() (AMPS.Message method)

H

HAClient (class in AMPS)
HybridPublishStore (class in AMPS)

I

InvalidMessageTypeOptions
InvalidTopicError
InvalidTopicException
InvalidTransportOptions
InvalidTransportOptionsException
InvalidUriException
InvalidUriFormat
is_discarded() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)

L

LocalStorageError
log() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
logon() (AMPS.Client method)
(AMPS.HAClient method)

M

max_depth() (AMPS.MessageStream method)
MemoryBookmarkStore (class in AMPS)
MemoryPublishStore (class in AMPS)
Message (class in AMPS)
Message.Options (class in AMPS)
MessageStream (class in AMPS)
MessageTypeError
MessageTypeException
MessageTypeNotFound
MMapBookmarkStore (class in AMPS)

N

name() (AMPS.Client method)
NameInUseException
next (AMPS.MessageStream attribute)
next() (AMPS.DefaultServerChooser method)
no_persisted_acks() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
NotEntitledError
NotEntitledException
NVFIXBuilder (class in AMPS)
NVFIXShredder (class in AMPS)

P

parse() (AMPS.CompositeMessageParser method)
persisted() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
persisted_index() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
prune() (AMPS.MMapBookmarkStore method)
prune_store() (AMPS.HAClient method)
publish() (AMPS.Client method)
publish_flush() (AMPS.Client method)
PublishStore (class in AMPS)
purge() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
purge_sub_id() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)

R

Reason (class in AMPS)
remove_connection_state_listener() (AMPS.Client method)
remove_message_handler() (AMPS.Client method)
report_failure() (AMPS.DefaultServerChooser method)
report_success() (AMPS.DefaultServerChooser method)
reset() (AMPS.Command method)
(AMPS.ExponentialDelayStrategy method)
(AMPS.FIXBuilder method)
(AMPS.FixedDelayStrategy method)
(AMPS.Message method)
(AMPS.NVFIXBuilder method)
retry() (AMPS.DefaultAuthenticator method)
RetryOperation
RetryOperationException
RingBookmarkStore (class in AMPS)

S

send() (AMPS.Client method)
set_ack_batch_size() (AMPS.Client method)
set_ack_timeout() (AMPS.Client method)
set_ack_type() (AMPS.Message method)
set_auto_ack() (AMPS.Client method)
set_batch_size() (AMPS.Command method)
(AMPS.Message method)
set_bookmark() (AMPS.Command method)
(AMPS.Message method)
set_bookmark_store() (AMPS.Client method)
set_client_name() (AMPS.Message method)
set_command() (AMPS.Message method)
set_command_id() (AMPS.Command method)
(AMPS.Message method)
set_correlation_id() (AMPS.Command method)
(AMPS.Message method)
set_data() (AMPS.Command method)
(AMPS.Message method)
set_default_max_depth() (AMPS.Client method)
set_disconnect_handler() (AMPS.Client method)
set_duplicate_message_handler() (AMPS.Client method)
set_exception_listener() (AMPS.Client method)
set_expiration() (AMPS.Command method)
(AMPS.Message method)
set_failed_write_handler() (AMPS.Client method)
set_filter() (AMPS.Command method)
(AMPS.Message method)
set_global_command_type_message_handler() (AMPS.Client method)
set_group_seq_no() (AMPS.Message method)
set_heartbeat() (AMPS.Client method)
set_last_chance_message_handler() (AMPS.Client method)
set_lease_period() (AMPS.Message method)
set_logon_correlation_data() (AMPS.Client method)
set_logon_options() (AMPS.HAClient method)
set_matches() (AMPS.Message method)
set_message_size() (AMPS.Message method)
set_message_type() (AMPS.Message method)
set_name() (AMPS.Client method)
set_options() (AMPS.Command method)
(AMPS.Message method)
set_order_by() (AMPS.Command method)
set_password() (AMPS.Message method)
set_publish_store() (AMPS.Client method)
set_query_id() (AMPS.Message method)
set_reason() (AMPS.Message method)
set_reconnect_delay() (AMPS.HAClient method)
set_reconnect_delay_strategy() (AMPS.HAClient method)
set_records_inserted() (AMPS.Message method)
set_records_returned() (AMPS.Message method)
set_records_updated() (AMPS.Message method)
set_resize_handler() (AMPS.HybridPublishStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.MemoryBookmarkStore method)
(AMPS.MemoryPublishStore method)
(AMPS.PublishStore method)
(AMPS.RingBookmarkStore method)
set_retry_on_disconnect() (AMPS.Client method)
set_sequence() (AMPS.Message method)
set_server_chooser() (AMPS.HAClient method)
set_server_version() (AMPS.MemoryBookmarkStore method)
(AMPS.MMapBookmarkStore method)
(AMPS.RingBookmarkStore method)
set_sow_deleted() (AMPS.Message method)
set_sow_key() (AMPS.Command method)
(AMPS.Message method)
set_sow_keys() (AMPS.Command method)
(AMPS.Message method)
set_status() (AMPS.Message method)
set_sub_id() (AMPS.Command method)
(AMPS.Message method)
set_sub_ids() (AMPS.Message method)
set_timeout() (AMPS.Command method)
(AMPS.HAClient method)
set_timestamp() (AMPS.Message method)
set_top_n() (AMPS.Command method)
(AMPS.Message method)
set_topic() (AMPS.Command method)
(AMPS.Message method)
set_topic_matches() (AMPS.Message method)
set_transport_filter() (AMPS.Client method)
set_unhandled_message_handler() (AMPS.Client method)
set_user_id() (AMPS.Message method)
set_version() (AMPS.VersionInfo method)
setAckType() (AMPS.Message method)
setBatchSize() (AMPS.Message method)
setBookmark() (AMPS.Message method)
setClientName() (AMPS.Message method)
setCommand() (AMPS.Message method)
setCommandId() (AMPS.Message method)
setCorrelationId() (AMPS.Message method)
setData() (AMPS.Message method)
setDisconnectHandler() (AMPS.Client method)
setExceptionListener() (AMPS.Client method)
setExpiration() (AMPS.Message method)
setFilter() (AMPS.Message method)
setGroupSequenceNumber() (AMPS.Message method)
setLeasePeriod() (AMPS.Message method)
setMatches() (AMPS.Message method)
setMessageLength() (AMPS.Message method)
setMessageType() (AMPS.Message method)
setName() (AMPS.Client method)
setOnDisconnectHandler() (AMPS.Client method)
setOptions() (AMPS.Message method)
setPassword() (AMPS.Message method)
setQueryID() (AMPS.Message method)
setReason() (AMPS.Message method)
setRecordsInserted() (AMPS.Message method)
setRecordsReturned() (AMPS.Message method)
setRecordsUpdated() (AMPS.Message method)
setSequence() (AMPS.Message method)
setSowDelete() (AMPS.Message method)
setSowKey() (AMPS.Message method)
setSowKeys() (AMPS.Message method)
setStatus() (AMPS.Message method)
setSubscriptionId() (AMPS.Message method)
setSubscriptionIds() (AMPS.Message method)
setTimestamp() (AMPS.Message method)
setTopic() (AMPS.Message method)
setTopicMatches() (AMPS.Message method)
setTopNRecordsReturned() (AMPS.Message method)
setUnhandledMessageHandler() (AMPS.Client method)
setUserId() (AMPS.Message method)
size() (AMPS.CompositeMessageParser method)
sow() (AMPS.Client method)
sow_and_delta_subscribe() (AMPS.Client method)
sow_and_subscribe() (AMPS.Client method)
sow_delete() (AMPS.Client method)
sow_delete_by_data() (AMPS.Client method)
sow_delete_by_keys() (AMPS.Client method)
sowAndDeltaSubscribe() (AMPS.Client method)
sowAndSubscribe() (AMPS.Client method)
sowDelete() (AMPS.Client method)
ssl_init() (in module AMPS)
ssl_load_verify_locations() (in module AMPS)
ssl_set_verify() (in module AMPS)
start_timer() (AMPS.Client method)
stop_timer() (AMPS.Client method)
Store (class in AMPS)
StreamError
StreamException
SubidInUseException
subscribe() (AMPS.Client method)
SubscriptionAlreadyExists
SubscriptionAlreadyExistsException

T

TimedOut
TimedOutException
timeout() (AMPS.MessageStream method)
to_map() (AMPS.FIXShredder method)
(AMPS.NVFIXShredder method)
TransportError
TransportException
TransportNotFound
TransportTypeException
truncate_on_close() (AMPS.PublishStore method)

U

UnknownError
UnknownException
unsubscribe() (AMPS.Client method)

V

VersionInfo (class in AMPS)