Index

A

ack() (AMPS.Client method) (AMPS.Message 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 BadSowKeyException 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.ConflatingRecoveryPointAdapter method) (AMPS.MessageStream method) (AMPS.SOWRecoveryPointAdapter 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) ConflatingRecoveryPointAdapter (class in AMPS) 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) discard_up_to() (AMPS.HybridPublishStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) disconnect() (AMPS.Client method) Disconnected DisconnectedException DuplicateLogonException

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.Command method) (AMPS.Message method) get_ack_type_enum() (AMPS.Command method) get_auto_ack() (AMPS.Client method) get_batch_size() (AMPS.Message method) get_bookmark() (AMPS.Message method) (AMPS.RecoveryPoint 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_default_resubscription_timeout() (AMPS.HAClient method) get_depth() (AMPS.MessageStream method) get_duplicate_message_handler() (AMPS.Client method) get_error() (AMPS.DefaultServerChooser method) get_error_on_publish_gap() (AMPS.Client method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) get_exception_listener() (AMPS.Client method) (AMPS.SOWRecoveryPointAdapter method) get_expiration() (AMPS.Message method) get_filter() (AMPS.Message method) get_group_seq_no() (AMPS.Message method) get_heartbeat() (AMPS.Message method) get_last_persisted() (AMPS.HybridPublishStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) get_lease_period() (AMPS.Message method) get_logon_correlation_data() (AMPS.Client method) get_logon_options() (AMPS.HAClient method) get_lowest_unpersisted() (AMPS.HybridPublishStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore 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_name_hash() (AMPS.Client method) get_name_hash_value() (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_order_by() (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_resubscription_timeout() (AMPS.HAClient method) get_retry_on_disconnect() (AMPS.Client method) get_sequence() (AMPS.Command method) (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_ssl() (AMPS.Client method) get_status() (AMPS.Message method) get_string() (AMPS.FIXBuilder method) (AMPS.NVFIXBuilder method) get_sub_id() (AMPS.Message method) (AMPS.RecoveryPoint method) get_sub_ids() (AMPS.Message method) get_timeout_interval() (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() (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) getHeartbeat() (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) getOrderBy() (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) getTimeoutInterval() (AMPS.Message method) getTimestamp() (AMPS.Message method) getTopic() (AMPS.Message method) getTopicMatches() (AMPS.Message method) getTopNRecordsReturned() (AMPS.Message method) getUserId() (AMPS.Message method) getVersion() (AMPS.Message method)

H

HAClient (class in AMPS)

HybridPublishStore (class in AMPS)

I

InvalidBookmarkException InvalidMessageTypeOptions InvalidOptionsException InvalidOrderByException InvalidSubIdException 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) LogonRequiredException

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 MissingFieldsException MMapBookmarkStore (class in AMPS)

N

name() (AMPS.Client method) NameInUseException next() (AMPS.ConflatingRecoveryPointAdapter method) (AMPS.DefaultServerChooser method) (AMPS.SOWRecoveryPointAdapter 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.ConflatingRecoveryPointAdapter method) (AMPS.MMapBookmarkStore method) (AMPS.SOWRecoveryPointAdapter method) prune_store() (AMPS.HAClient method) publish() (AMPS.Client method)

publish_flush() (AMPS.Client method) PublishException PublishStore (class in AMPS) PublishStoreGapException purge() (AMPS.ConflatingRecoveryPointAdapter method) (AMPS.MMapBookmarkStore method) (AMPS.MemoryBookmarkStore method) (AMPS.RingBookmarkStore method) (AMPS.SOWRecoveryPointAdapter method) purge_sub_id() (AMPS.MemoryBookmarkStore method) (AMPS.MMapBookmarkStore method) (AMPS.RingBookmarkStore method)

R

Reason (class in AMPS) RecoveryPoint (class in AMPS) remove_connection_state_listener() (AMPS.Client method) remove_message_handler() (AMPS.Client method) replay() (AMPS.HybridPublishStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) replay_single() (AMPS.HybridPublishStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore 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.Command method) (AMPS.Message method) set_ack_type_enum() (AMPS.Command 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_cancel() (AMPS.Message.Options method) set_client_name() (AMPS.Message method) set_command() (AMPS.Message method) set_command_id() (AMPS.Command method) (AMPS.Message method) set_conflation() (AMPS.Message.Options method) set_conflation_key() (AMPS.Message.Options 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_default_resubscription_timeout() (AMPS.HAClient method) set_disconnect_handler() (AMPS.Client method) set_duplicate_message_handler() (AMPS.Client method) set_error_on_publish_gap() (AMPS.Client method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) set_exception_listener() (AMPS.Client method) (AMPS.SOWRecoveryPointAdapter method) set_expiration() (AMPS.Command method) (AMPS.Message method) set_failed_resubscribe_handler() (AMPS.HAClient method) set_failed_write_handler() (AMPS.Client method) set_filter() (AMPS.Command method) (AMPS.Message method) set_fully_durable() (AMPS.Message.Options method) set_global_command_type_message_handler() (AMPS.Client method) set_group_seq_no() (AMPS.Message method) set_grouping() (AMPS.Message.Options method) set_heartbeat() (AMPS.Client method) (AMPS.Message method) set_last_chance_message_handler() (AMPS.Client method) set_lease_period() (AMPS.Message method) set_live() (AMPS.Message.Options method) set_logon_correlation_data() (AMPS.Client method) set_logon_options() (AMPS.HAClient method) set_matches() (AMPS.Message method) set_max_backlog() (AMPS.Message.Options method) set_message_size() (AMPS.Message method) set_message_type() (AMPS.Message method) set_name() (AMPS.Client method) set_no_empties() (AMPS.Message.Options method) set_no_sowkey() (AMPS.Message.Options method) set_none() (AMPS.Message.Options method) set_OOF() (AMPS.Message.Options method) set_options() (AMPS.Command method) (AMPS.Message method) set_order_by() (AMPS.Command method) (AMPS.Message method) set_password() (AMPS.Message method) set_pause() (AMPS.Message.Options method) set_projection() (AMPS.Message.Options method) set_publish_store() (AMPS.Client method) set_query_id() (AMPS.Command method) (AMPS.Message method) set_rate() (AMPS.Message.Options method) set_rate_max_gap() (AMPS.Message.Options 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_replace() (AMPS.Message.Options method) set_resize_handler() (AMPS.HybridPublishStore method) (AMPS.MMapBookmarkStore method) (AMPS.MemoryBookmarkStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) (AMPS.RingBookmarkStore method) set_resubscription_timeout() (AMPS.HAClient method) set_resume() (AMPS.Message.Options method) set_retry_on_disconnect() (AMPS.Client method) set_send_keys() (AMPS.Message.Options method) set_sequence() (AMPS.Command method) (AMPS.Message method) set_server_chooser() (AMPS.HAClient method) set_server_version() (AMPS.MemoryBookmarkStore method) (AMPS.MMapBookmarkStore method) (AMPS.RingBookmarkStore method) set_skip_n() (AMPS.Message.Options 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_thread_created_callback() (AMPS.Client method) set_timeout() (AMPS.Command method) (AMPS.HAClient method) set_timeout_interval() (AMPS.Message method) set_timestamp() (AMPS.Message method) (AMPS.Message.Options method) set_top_n() (AMPS.Command method) (AMPS.Message method) (AMPS.Message.Options 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.Message method) (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) setHeartbeat() (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) setOrderBy() (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) setTimeoutInterval() (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) setVersion() (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) SOWRecoveryPointAdapter (class in AMPS) ssl_get_context() (in module AMPS) 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) store() (AMPS.HybridPublishStore method) (AMPS.MemoryPublishStore method) (AMPS.PublishStore method) StoreException 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)

update() (AMPS.ConflatingRecoveryPointAdapter method) (AMPS.SOWRecoveryPointAdapter method) UsageException

V

VersionInfo (class in AMPS)