Index (AMPS Java Client (5.3.2.1.6d15937f.540279))

A B C D E F G H I J L M N O P R S T U V W X Y Z _

A

ack(byte[], int, int, byte[], int, int) - Method in class com.crankuptheamps.client.Client: ACKs a message from a message queue with a byte-array topic and bookmark
ack(Field, Field) - Method in class com.crankuptheamps.client.Client: ACKs a message queue message using Field objects from a message.
ack(String, String) - Method in class com.crankuptheamps.client.Client: ACKs a message queue message.
ack(byte[], int, int, byte[], int, int, byte[], int, int) - Method in class com.crankuptheamps.client.Client: ACKs a message from a message queue with a byte-array topic and bookmark
ack(Field, Field, Field) - Method in class com.crankuptheamps.client.Client: ACKs a message queue message using Field objects from a message.
ack(String, String, String) - Method in class com.crankuptheamps.client.Client: ACKs a message queue message.
ack() - Method in class com.crankuptheamps.client.Message: Used to acknowledge a queue message is processed.
ack(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Used to acknowledge a queue message is processed.
ack(Field) - Method in class com.crankuptheamps.client.Message: Used to acknowledge a queue message is processed.
ack(String) - Method in class com.crankuptheamps.client.Message: Used to acknowledge a queue message is processed.
Ack - Static variable in class com.crankuptheamps.client.Message.Command
AckConflationInterval(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the ack_conflation interval for a logon command.
AckType() - Constructor for class com.crankuptheamps.client.Message.AckType
AckTypeField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of the Acknowlegement Type.
AckTypeField() - Constructor for class com.crankuptheamps.client.fields.AckTypeField
adapterUpdate(Field, BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Used inernally to update the RecoveryPointAdapter if there is one.
adapterUpdate(Field, BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Used inernally to update the RecoveryPointAdapter if there is one.
add(String) - Method in class com.crankuptheamps.client.DefaultServerChooser: Adds a URI to self.
addAckType(int) - Method in class com.crankuptheamps.client.Command: Adds an additional ackType to the ackTypes already set for this Command.
addAll(T) - Method in class com.crankuptheamps.client.DefaultServerChooser: Adds URIs to self.
addConnectionStateListener(ConnectionStateListener) - Method in class com.crankuptheamps.client.Client: Adds a ConnectionStateListener instance that will be invoked when this client connects or disconnects.
addMessageHandler(CommandId, MessageHandler, int, boolean) - Method in class com.crankuptheamps.client.Client: Adds a MessageHandler for a given CommandId to self.
addRoute(CommandId, MessageHandler, int, int, boolean) - Method in class com.crankuptheamps.client.MessageRouter: Adds a route to self.
allocateMessage() - Method in class com.crankuptheamps.client.Client: Creates a new Message appropriate for this client.
allocateMessage() - Method in class com.crankuptheamps.client.FIXProtocol: Allocates a new FIX Message.
allocateMessage() - Method in class com.crankuptheamps.client.JSONProtocol: Allocates a new JSON Message.
allocateMessage() - Method in class com.crankuptheamps.client.NVFIXProtocol
allocateMessage() - Method in interface com.crankuptheamps.client.Protocol
allocateMessage() - Method in class com.crankuptheamps.client.TCPTransport
allocateMessage() - Method in interface com.crankuptheamps.client.Transport
allocateMessage() - Method in class com.crankuptheamps.client.XMLProtocol: Allocates room for a new XML message.
AlreadyConnectedException - Exception in com.crankuptheamps.client.exception: Thrown when connect is called while there is already an active connection to AMPS.
AlreadyConnectedException() - Constructor for exception com.crankuptheamps.client.exception.AlreadyConnectedException
AlreadyConnectedException(String) - Constructor for exception com.crankuptheamps.client.exception.AlreadyConnectedException
AlreadyConnectedException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.AlreadyConnectedException
AMPS_3 - Static variable in class com.crankuptheamps.client.Client.Version
AMPS_4 - Static variable in class com.crankuptheamps.client.Client.Version
AMPS_5 - Static variable in class com.crankuptheamps.client.Client.Version
AMPS_MIN_PUB_STORE_DISCARDED_VERSION - Static variable in class com.crankuptheamps.client.BlockPublishStore
AMPS_TIMESTAMP_LENGTH - Static variable in class com.crankuptheamps.client.AMPSTimestamp: The length of a valid AMPS timestamp in bytes.
AMPSException - Exception in com.crankuptheamps.client.exception: Base class for exceptions thrown by the AMPS Java client.
AMPSException() - Constructor for exception com.crankuptheamps.client.exception.AMPSException
AMPSException(String) - Constructor for exception com.crankuptheamps.client.exception.AMPSException
AMPSException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.AMPSException
AMPSException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.AMPSException
AMPSRunnable - Interface in com.crankuptheamps.client: An interface that can be implemented to create background tasks that execute when a TCPTransport is idle.
AMPSTimestamp - Class in com.crankuptheamps.client: Provides an easy way to extract the date/time parts from an AMPS timestamp.
AMPSTimestamp(String) - Constructor for class com.crankuptheamps.client.AMPSTimestamp: Parses an AMPS timestamp into a new object.
AMPSTimestamp(byte[], int, int) - Constructor for class com.crankuptheamps.client.AMPSTimestamp: Parses an AMPS timestamp into a new object.
append(byte[], int, int) - Method in class com.crankuptheamps.client.CompositeMessageBuilder: Appends a message part to this object.
append(String) - Method in class com.crankuptheamps.client.CompositeMessageBuilder: Appends a message part to this object.
append(int, byte[], int, int) - Method in class com.crankuptheamps.client.FIXBuilder: Appends a tag and and value pair contained within a byte buffer to the FIX message.
append(int, byte[]) - Method in class com.crankuptheamps.client.FIXBuilder: Appends a tag and value pair to contained within a byte buffer to the FIX message.
append(int, String) - Method in class com.crankuptheamps.client.FIXBuilder: Appends a tag and value pair to the FIX message.
append(String, byte[], int, int) - Method in class com.crankuptheamps.client.NVFIXBuilder: Appends a tag and value pair contained within a byte buffer to the FIX message.
append(String, String) - Method in class com.crankuptheamps.client.NVFIXBuilder: Appends a tag and value pair to the FIX message.
apply(T) - Method in interface com.crankuptheamps.client.util.SerializableFunction: Invokes the function with the specified argument of type T and returns a result of type R.
array - Variable in class com.crankuptheamps.client.BlockPublishStore.ByteSequence
ArrayStoreBuffer - Class in com.crankuptheamps.client: ArrayStoreBuffer is a simple wrapper for a java array that maintains position.
ArrayStoreBuffer() - Constructor for class com.crankuptheamps.client.ArrayStoreBuffer
AuthDisabled - Static variable in class com.crankuptheamps.client.Message.Reason
authenticate(String, String) - Method in interface com.crankuptheamps.client.Authenticator: Called by AMPS.Client, just before the logon command is sent.
authenticate(String, String) - Method in class com.crankuptheamps.client.DefaultAuthenticator: Called by AMPS.Client, just before the logon command is sent.
AuthenticationException - Exception in com.crankuptheamps.client.exception: Thrown when there was an issue with authentication, caused by incorrect username or password.
AuthenticationException() - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
AuthenticationException(String) - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
AuthenticationException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
AuthenticationException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
Authenticator - Interface in com.crankuptheamps.client: Interface used to authenticate an AMPS Java Client user.
AuthFailure - Static variable in class com.crankuptheamps.client.Message.Reason

B

BadFilter - Static variable in class com.crankuptheamps.client.Message.Reason
BadFilterException - Exception in com.crankuptheamps.client.exception: Thrown when the AMPS server reports that a filter could not be successfully processed.
BadFilterException() - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
BadFilterException(String) - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
BadFilterException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
BadFilterException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
BadRegexTopic - Static variable in class com.crankuptheamps.client.Message.Reason
BadRegexTopicException - Exception in com.crankuptheamps.client.exception: Thrown when the AMPS server reports that the regex provided as the topic for a subscription or query could not be processed.
BadRegexTopicException() - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
BadRegexTopicException(String) - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
BadRegexTopicException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
BadRegexTopicException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
BLOCK_SIZE - Static variable in class com.crankuptheamps.client.MemoryPublishStore: The size of each block the store allocates.
BlockPublishStore - Class in com.crankuptheamps.client: BlockPublishStore is a base class for publish Store implementations.
BlockPublishStore(BlockPublishStore.Buffer, int, boolean) - Constructor for class com.crankuptheamps.client.BlockPublishStore
BlockPublishStore(BlockPublishStore.Buffer, int) - Constructor for class com.crankuptheamps.client.BlockPublishStore
BlockPublishStore(BlockPublishStore.Buffer) - Constructor for class com.crankuptheamps.client.BlockPublishStore
BlockPublishStore.Buffer - Interface in com.crankuptheamps.client: Interface which is used to hold the BlockPublishStore buffer data.
BlockPublishStore.ByteSequence - Class in com.crankuptheamps.client: A simple wrapper object around a byte array that allows a sub-range to be specified using its offset and length properties.
BookmarkField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of the bookmark.
BookmarkField(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.BookmarkField
BookmarkField() - Constructor for class com.crankuptheamps.client.fields.BookmarkField
BookmarkRangeField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of the bookmark.
BookmarkRangeField(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.BookmarkRangeField
BookmarkRangeField() - Constructor for class com.crankuptheamps.client.fields.BookmarkRangeField
BookmarkRingBuffer - Class in com.crankuptheamps.client: A ring buffer of bookmarks and activation status Used by all of the bookmark stores to track state of bookmarks we need to hold on to, either because they're active or because they're after an active one.
BookmarkRingBuffer() - Constructor for class com.crankuptheamps.client.BookmarkRingBuffer: Initializes the underlying array, and sets the "last discarded" value to something reasonable.
BookmarkRingBuffer.Entry - Class in com.crankuptheamps.client: Interface that represents all of the information we need about each Bookmark.
Bookmarks() - Constructor for class com.crankuptheamps.client.Client.Bookmarks
BookmarkStore - Interface in com.crankuptheamps.client: Defines the interface for bookmark stores, which are used by the Client to provide resumable subscriptions and client-side duplicate message handling.
BookmarkStoreResizeHandler - Interface in com.crankuptheamps.client: Interface used to indicate whether a BookmarkStore implementation is allowed to grow (or shrink) to the requested size.
bookmarkSubscribe(MessageHandler, String, String, CommandId, String, String, long) - Method in class com.crankuptheamps.client.Client: Places a bookmark subscription with AMPS.
BooleanField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of a boolean value.
BooleanField() - Constructor for class com.crankuptheamps.client.fields.BooleanField
broadcastConnectionStateChanged(int) - Method in class com.crankuptheamps.client.Client
buffer - Variable in class com.crankuptheamps.client.fields.Field
byteAt(int) - Method in class com.crankuptheamps.client.fields.Field: Returns the byte at Field.position plus index i.
ByteSequence() - Constructor for class com.crankuptheamps.client.BlockPublishStore.ByteSequence
ByteSequence(byte[], long, long) - Constructor for class com.crankuptheamps.client.BlockPublishStore.ByteSequence

C

c - Variable in class com.crankuptheamps.client.fields.BookmarkField
Cancel - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the cancel option, used when acknowledging (sow_delete) a leased message to return the message to the queue rather than acknowledging the message as processed.
capacity() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Size of underlying array.
CharsetName - Static variable in class com.crankuptheamps.client.FIXProtocol: The character set used to encode and decode messages sent via FIX.
checkResize() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Called to see if resize can proceed.
clear() - Method in class com.crankuptheamps.client.CompositeMessageBuilder: Clears this object.
clear() - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
clear() - Method in class com.crankuptheamps.client.FIXBuilder: Clears self.
clear() - Method in class com.crankuptheamps.client.MemorySubscriptionManager
clear() - Method in class com.crankuptheamps.client.MessageRouter: Removes all routes from self.
clear() - Method in class com.crankuptheamps.client.NVFIXBuilder: Clears the current builder, resetting it to empty.
clear() - Method in interface com.crankuptheamps.client.SubscriptionManager: Clears the subscriptions so they cannot be re-subscribed upon reconnect.
Client - Class in com.crankuptheamps.client: The base AMPS client object used in AMPS applications.
Client(String) - Constructor for class com.crankuptheamps.client.Client: Creates a client.
Client(String, int) - Constructor for class com.crankuptheamps.client.Client: Creates a client.
Client(String, Transport) - Constructor for class com.crankuptheamps.client.Client: Creates a client with a transport.
Client(String, Transport, int) - Constructor for class com.crankuptheamps.client.Client: Creates a client with a transport
Client.Bookmarks - Class in com.crankuptheamps.client: Provides constants for special bookmark values.
Client.GlobalCommandTypeHandlers - Enum in com.crankuptheamps.client: Specifies a type of message that is always sent to an associated handler when one is set.
Client.Version - Class in com.crankuptheamps.client: Class that holds supported versions of AMPS, those are: AMPS version 3, AMPS version 4 and AMPS version 5.
ClientDisconnectHandler - Interface in com.crankuptheamps.client: Called in Client when the Client unintentionally disconnects from AMPS.
ClientDisconnectHandler2 - Interface in com.crankuptheamps.client: 60East recommends using the HAClient, which includes a robust implementation of disconnect handling and reconnection, unless your application has needs that cannot be met by the HAClient behavior.
ClientVersion - Class in com.crankuptheamps.client: Used to indicate the version of this client build outside of JAR manifest files (which can be lost due to repackaging in cases such as "fat JARs").
ClientVersion() - Constructor for class com.crankuptheamps.client.ClientVersion
clone() - Method in class com.crankuptheamps.client.fields.BookmarkField: Provides a way to duplicate this object and retain its specific type (and hashcode() implementation).
clone() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField: Provides a way to duplicate this object and retain its specific type (and hashcode() implementation).
clone() - Method in class com.crankuptheamps.client.HashBox
close() - Method in class com.crankuptheamps.client.ArrayStoreBuffer
close() - Method in class com.crankuptheamps.client.BlockPublishStore
close() - Method in class com.crankuptheamps.client.Client: Disconnect from the AMPS server.
close() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Force all updates to the underlying adapter, then close it.
close() - Method in class com.crankuptheamps.client.DefaultBookmarkStore
close() - Method in class com.crankuptheamps.client.HybridPublishStore
close() - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Closes the bookmark store.
close() - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Closes down the bookmark store.
close() - Method in class com.crankuptheamps.client.MemoryStoreBuffer
close() - Method in class com.crankuptheamps.client.MessageStream: Closes this MessageStream, unsubscribing from AMPS if applicable.
close() - Method in class com.crankuptheamps.client.PublishStore: Closes the memory mapped file.
close() - Method in class com.crankuptheamps.client.RingBookmarkStore: In order to unmap the memory used to store the state, this method closes the mapped byte buffer.
close() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Close this adapter making sure all updates are at the server and close the internal client if set up to do so.
close() - Method in class com.crankuptheamps.client.TCPTransport
CodingErrorAction - Static variable in class com.crankuptheamps.client.FIXProtocol: Specifies the default action to be taken when a character cannot be encoded or decoded.
com.crankuptheamps.client - package com.crankuptheamps.client: This package contains the AMPS Java client.
com.crankuptheamps.client.exception - package com.crankuptheamps.client.exception: This package contains exceptions thrown by the AMPS Java client.
com.crankuptheamps.client.fields - package com.crankuptheamps.client.fields: This package contains helper classes for formatting and parsing messages to AMPS.
com.crankuptheamps.client.util - package com.crankuptheamps.client.util
Command - Class in com.crankuptheamps.client: Command is an encapsulation of a single AMPS command sent by the client.
Command() - Constructor for class com.crankuptheamps.client.Command: Create a new Command with no command type or arguments set.
Command(int) - Constructor for class com.crankuptheamps.client.Command: Create a Command with the Command field set.
Command(String) - Constructor for class com.crankuptheamps.client.Command: Create a Command with the Command field set.
Command() - Constructor for class com.crankuptheamps.client.Message.Command
CommandException - Exception in com.crankuptheamps.client.exception: Base class for exceptions thrown when an error occurs in an AMPS command.
CommandException() - Constructor for exception com.crankuptheamps.client.exception.CommandException
CommandException(String) - Constructor for exception com.crankuptheamps.client.exception.CommandException
CommandException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.CommandException
CommandException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.CommandException
CommandField - Class in com.crankuptheamps.client.fields: Field data for a Message which consists of a Command.
CommandField() - Constructor for class com.crankuptheamps.client.fields.CommandField
CommandId - Class in com.crankuptheamps.client: Used to give a unique identifier to a Command.
CommandId(String) - Constructor for class com.crankuptheamps.client.CommandId: Constructs a Command Id for an AMPS command, using a string as its identifier.
CommandId(byte[]) - Constructor for class com.crankuptheamps.client.CommandId: Constructs a Command Id for an AMPS command, using an array of bytes as its identifier.
CommandId(byte[], int, int) - Constructor for class com.crankuptheamps.client.CommandId: Constructs a Command Id for an AMPS command, using an array of bytes, a position number, and a length as its identifier.
compareTo(VersionInfo) - Method in class com.crankuptheamps.client.VersionInfo
completed(String, String, int) - Method in interface com.crankuptheamps.client.Authenticator: Called when a logon completes successfully.
completed(String, String, int) - Method in class com.crankuptheamps.client.DefaultAuthenticator: Called when a logon completes successfully.
Completed - Static variable in class com.crankuptheamps.client.Message.AckType
CompositeMessageBuilder - Class in com.crankuptheamps.client: Used to create payloads for AMPS composite messages, which are messages with a number of parts where each part is a complete message of a specific message type.
CompositeMessageBuilder() - Constructor for class com.crankuptheamps.client.CompositeMessageBuilder: Create a new, empty CompositeMessageBuilder.
CompositeMessageBuilder(int) - Constructor for class com.crankuptheamps.client.CompositeMessageBuilder: Create a new empty CompositeMessageBuilder.
CompositeMessageParser - Class in com.crankuptheamps.client: Used to retrieve individual message parts from AMPS composite messages, which are messages where the data contains a number of parts and each part is a complete message of a specific message type.
CompositeMessageParser() - Constructor for class com.crankuptheamps.client.CompositeMessageParser: Creates a new CompositeMessageParser, with 0 valid parts.
CompositeMessageParser(Field) - Constructor for class com.crankuptheamps.client.CompositeMessageParser: Creates a new CompositeMessageParser and parses the provided message body.
CompositeMessageParser(Message) - Constructor for class com.crankuptheamps.client.CompositeMessageParser: Creates a new CompositeMessageParser and parses a message's body.
conflate() - Method in class com.crankuptheamps.client.MessageStream: Causes messages to be conflated by SOW key.
ConflatingRecoveryPointAdapter - Class in com.crankuptheamps.client: An implementation of the RecoveryPointAdapter interface that is meant to act as a wrapper around another recovery point adapter instance, delegating periodic updates to its wrapped adapter on an asynchronous update thread (which this instance starts).
ConflatingRecoveryPointAdapter(RecoveryPointAdapter) - Constructor for class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Constructs an instance of the recovery point adapter interface that is meant to act as a wrapper around another recovery point adapter instance, delegating periodic updates to its wrapped adapter on an asynchronous update thread (which this instance starts).
ConflatingRecoveryPointAdapter(RecoveryPointAdapter, long, long, long) - Constructor for class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Constructs an instance of the recovery point adapter interface that is meant to act as a wrapper around another recovery point adapter instance, delegating periodic updates to its wrapped adapter on an asynchronous update thread (which this instance starts).
ConflatingRecoveryPointAdapter.UpdateThread - Class in com.crankuptheamps.client: Internal thread for asynchronously delegating recovery state updates to the wrapper recovery point adapter.
Conflation(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the conflation option for a command.
ConflationKey(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the conflation_key option for a command that uses the conflation option.
connect(String) - Method in class com.crankuptheamps.client.Client: Connects to the AMPS instance through the provided URI.
connect() - Method in class com.crankuptheamps.client.HAClient
connect(String) - Method in class com.crankuptheamps.client.HAClient
connect(URI) - Method in class com.crankuptheamps.client.TCPTransport
connect(URI) - Method in class com.crankuptheamps.client.TCPTransportImpl
connect(URI) - Method in interface com.crankuptheamps.client.Transport
connectAndLogon() - Method in class com.crankuptheamps.client.HAClient: Connects to the next server chosen for us by our ServerChooser.
Connected - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client connects.
ConnectionException - Exception in com.crankuptheamps.client.exception: Base class for exceptions thrown when AMPS encounters an error with a connection.
ConnectionException(String) - Constructor for exception com.crankuptheamps.client.exception.ConnectionException
ConnectionException() - Constructor for exception com.crankuptheamps.client.exception.ConnectionException
ConnectionException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.ConnectionException
ConnectionException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.ConnectionException
ConnectionInfo - Class in com.crankuptheamps.client: A Key, Value mapping for metadata about the state of an AMPS connection.
ConnectionInfo() - Constructor for class com.crankuptheamps.client.ConnectionInfo
ConnectionRefusedException - Exception in com.crankuptheamps.client.exception: Thrown when a connection could not be established.
ConnectionRefusedException() - Constructor for exception com.crankuptheamps.client.exception.ConnectionRefusedException
ConnectionRefusedException(String) - Constructor for exception com.crankuptheamps.client.exception.ConnectionRefusedException
ConnectionRefusedException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.ConnectionRefusedException
ConnectionRefusedException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.ConnectionRefusedException
connectionStateChanged(int) - Method in interface com.crankuptheamps.client.ConnectionStateListener: Called on an implementation of this interface when the connection state changes.
connectionStateChanged(int) - Method in class com.crankuptheamps.client.MessageStream: Used to indicate a if there was a change in state with connection.
ConnectionStateListener - Interface in com.crankuptheamps.client: An interface that allows an application to be notified when the client connects or disconnects to an AMPS server.
constructTransportImpl(Protocol, Properties) - Method in class com.crankuptheamps.client.TCPSTransport
constructTransportImpl(Protocol, Properties) - Method in class com.crankuptheamps.client.TCPTransport
copy() - Method in class com.crankuptheamps.client.fields.BookmarkField
copy() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
copy() - Method in class com.crankuptheamps.client.fields.Field: Constructs a new Field and sets its value to a deep copy of this instance.
copy() - Method in class com.crankuptheamps.client.FIXMessage: Copies the FIX Message into a new FIX Message.
copy() - Method in class com.crankuptheamps.client.JSONMessage: Copies the JSON Message to a new JSON Message.
copy() - Method in class com.crankuptheamps.client.Message
copy() - Method in interface com.crankuptheamps.client.RecoveryPoint: Creates and returns a deep copy of self.
copy() - Method in class com.crankuptheamps.client.XMLMessage: Method used to copy an existing XML message to a new XML message.
copyFrom(Field) - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
copyFrom(Field) - Method in class com.crankuptheamps.client.fields.Field: Sets the value of this instance to a deep copy of the value of the specified field.
createFileBacked(String, String, int, String) - Static method in class com.crankuptheamps.client.HAClient: Creates a new highly available client backed by disk.
createFileBacked(String, String, String) - Static method in class com.crankuptheamps.client.HAClient: Creates a new highly available client backed by disk.
createMemoryBacked(String) - Static method in class com.crankuptheamps.client.HAClient: Creates a new memory-backed highly-available client.
createProtocol(String, Properties) - Static method in class com.crankuptheamps.client.ProtocolFactory: Creates a protocol.
createRecoveryPoint(Field, BookmarkField) - Method in interface com.crankuptheamps.client.RecoveryPointFactory
createSocket() - Method in class com.crankuptheamps.client.TCPSTransportImpl
createSocket() - Method in class com.crankuptheamps.client.TCPTransportImpl
createTransport(Protocol) - Static method in class com.crankuptheamps.client.TCPTransport
createTransport(String, Protocol, Properties) - Static method in class com.crankuptheamps.client.TransportFactory: Creates a Transport using the parameters provided.

D

day - Variable in class com.crankuptheamps.client.AMPSTimestamp: Day part of this timestamp.
decodeAckType(byte[], int, int) - Static method in class com.crankuptheamps.client.fields.AckTypeField: Decodes the acknowledgement type given by AMPS.
decoder - Variable in class com.crankuptheamps.client.Message: Used by associated Field classes to decode byte data
DEFAULT_BACKOFF_EXPONENT - Static variable in class com.crankuptheamps.client.ExponentialDelayStrategy: The default exponent to use for calculating the next delay time.
DEFAULT_DELAY - Static variable in class com.crankuptheamps.client.ExponentialDelayStrategy: The default time (in milliseconds) to wait before reconnecting to a server for the first time after a failed connection.
DEFAULT_DELAY - Static variable in class com.crankuptheamps.client.FixedDelayStrategy: The default delay when reconnecting to a server, in milliseconds.
DEFAULT_JITTER - Static variable in class com.crankuptheamps.client.ExponentialDelayStrategy: The amount of 'jitter' to apply when calculating a delay time, measured in multiples of the initial delay.
DEFAULT_MAXIMUM_DELAY - Static variable in class com.crankuptheamps.client.ExponentialDelayStrategy: The default maximum time to wait between any reconnection attempts.
DEFAULT_MAXIMUM_RETRY_TIME - Static variable in class com.crankuptheamps.client.ExponentialDelayStrategy: The default time (in millseconds) to allow reconnect attempts to continue without a successful connection, before "giving up" and abandoning the connection attempt.
DefaultAuthenticator - Class in com.crankuptheamps.client: A default implementation of the Authenticator interface that is used for basic username/password authentication.
DefaultAuthenticator() - Constructor for class com.crankuptheamps.client.DefaultAuthenticator
DefaultBookmarkStore - Class in com.crankuptheamps.client: A no-op default implementation of the BookmarkStore interface that does nothing.
DefaultBookmarkStore() - Constructor for class com.crankuptheamps.client.DefaultBookmarkStore
DefaultDisconnectHandler - Class in com.crankuptheamps.client: A default no-op implementation of the ClientDisconnectHandler and TransportDisconnectHandler interfaces that does nothing.
DefaultMessageHandler - Class in com.crankuptheamps.client: A default no-op implementation of the MessageHandler interface that does nothing.
DefaultMessageHandler() - Constructor for class com.crankuptheamps.client.DefaultMessageHandler
DefaultServerChooser - Class in com.crankuptheamps.client: A simple ServerChooser that keeps a list of AMPS instances and Authenticators, and advances to the next one when failure occurs.
DefaultServerChooser() - Constructor for class com.crankuptheamps.client.DefaultServerChooser
DefaultSubscriptionManager - Class in com.crankuptheamps.client: A no-op implementation of the SubscriptionManager interface that does nothing.
DefaultSubscriptionManager() - Constructor for class com.crankuptheamps.client.DefaultSubscriptionManager
DefaultTransportFilter - Class in com.crankuptheamps.client: A default no-op filter from the TransportFilter class that does nothing.
DefaultTransportFilter() - Constructor for class com.crankuptheamps.client.DefaultTransportFilter
Deleted - Static variable in class com.crankuptheamps.client.Message.Reason
deliverAck(Message, int) - Method in class com.crankuptheamps.client.MessageRouter: Deliver a message that is known already to be an Ack.
deliverData(Message) - Method in class com.crankuptheamps.client.MessageRouter: Delivers a data message (not an Ack) to the registered route.
deliverData(Message, CommandId) - Method in class com.crankuptheamps.client.MessageRouter: Delivers a data message using a specific command ID from the message.
deltaPublish(byte[], int, int, byte[], int, int) - Method in class com.crankuptheamps.client.Client: Delta publish a message to an AMPS topic.
deltaPublish(String, String) - Method in class com.crankuptheamps.client.Client: Delta publish a message to an AMPS topic.
deltaPublish(byte[], int, int, byte[], int, int, int) - Method in class com.crankuptheamps.client.Client: Delta ublish a message to an AMPS topic.
deltaPublish(String, String, int) - Method in class com.crankuptheamps.client.Client: Delta publish a message to an AMPS topic.
DeltaPublish - Static variable in class com.crankuptheamps.client.Message.Command
deltaSubscribe(MessageHandler, String, String, String, long) - Method in class com.crankuptheamps.client.Client: Places a delta subscription with AMPS.
deltaSubscribe(MessageHandler, String, String, String, long, String) - Method in class com.crankuptheamps.client.Client: Places a delta subscription with AMPS.
deltaSubscribe(MessageHandler, String, String, long) - Method in class com.crankuptheamps.client.Client: Places a delta subscription with AMPS.
deltaSubscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client: Places a delta subscription with AMPS.
DeltaSubscribe - Static variable in class com.crankuptheamps.client.Message.Command
deserialize(Message) - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Deserializes a JSON string into a RecoveryPoint instance for use by SOWRecoveryPointAdapter.next() during bookmark store creation/initialization.
discard(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Discards an entry by index.
discard(Field, long) - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to mark the message specified by the subscription ID and the bookmark sequence number as discarded, indicating that the application has completed processing the message.
discard(Message) - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to mark the provided message as discarded, indicating that the application has completed processing the message.
discard(Field, long) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
discard(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
discard(Field, long) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
discard(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
discard(long) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
discard(Field, long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
discard(Message) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
discard(long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
discard(Field, long) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to mark the message specified by the Subscription Id and bookmark sequence number as discarded, indicating that the application has completed processing the message.
discard(Message) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to mark the provided message as discarded, indicating that the application has completed processing the message.
discard(long) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
discard(long) - Method in interface com.crankuptheamps.client.Subscription
discardUpTo(long) - Method in class com.crankuptheamps.client.BlockPublishStore
discardUpTo(long) - Method in class com.crankuptheamps.client.HybridPublishStore: Discards from both the disk store and memory store.
discardUpTo(long) - Method in interface com.crankuptheamps.client.Store: Discard all operations up to the index provided.
disconnect() - Method in class com.crankuptheamps.client.Client: Disconnect from the AMPS server.
disconnect() - Method in class com.crankuptheamps.client.HAClient
disconnect() - Method in class com.crankuptheamps.client.TCPTransport
disconnect() - Method in class com.crankuptheamps.client.TCPTransportImpl
disconnect() - Method in interface com.crankuptheamps.client.Transport
Disconnected - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client disconnects.
DisconnectedException - Exception in com.crankuptheamps.client.exception: Exception thrown when a connection to AMPS has been lost.
DisconnectedException() - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
DisconnectedException(String) - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
DisconnectedException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
DisconnectedException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
Duplicate - Static variable in class com.crankuptheamps.client.Message.Reason

E

encodeAckType(int) - Static method in class com.crankuptheamps.client.fields.AckTypeField: Converts the acknowlegement from an integer to a string.
encodeCommand(int) - Static method in class com.crankuptheamps.client.fields.CommandField: This method encodes the Command.
encoder - Variable in class com.crankuptheamps.client.Message: Used by associated Field classes to encode byte data
encodeReason(int) - Static method in class com.crankuptheamps.client.fields.ReasonField: Utility method that takes a reason code integer and returns the associated descriptive text.
encodeStatus(int) - Static method in class com.crankuptheamps.client.fields.StatusField: Utility method that takes a status code integer and returns the associated descriptive text.
Entry() - Constructor for class com.crankuptheamps.client.BookmarkRingBuffer.Entry
EPOCH - Static variable in class com.crankuptheamps.client.Client.Bookmarks: Start the subscription at the beginning of the journal.
EPOCH_FIELD - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
equals(Object) - Method in class com.crankuptheamps.client.CommandId: Overridden to test equality based upon object class and the CommandId value.
equals(Object) - Method in class com.crankuptheamps.client.fields.BookmarkField
equals(Object) - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
equals(Object) - Method in class com.crankuptheamps.client.fields.Field: Default implementation for Object.equals(java.lang.Object) for a Field.
equals(Object) - Method in class com.crankuptheamps.client.fields.OptionsField: Implementation for Object.equals(java.lang.Object) for an OptionsField.
equals(Object) - Method in class com.crankuptheamps.client.HashBox
equals(Object) - Method in class com.crankuptheamps.client.VersionInfo
exceptionListener - Variable in class com.crankuptheamps.client.Client
execute(Command) - Method in class com.crankuptheamps.client.Client: Execute the provided command and return messages received in response in a MessageStream.
execute(Message) - Method in interface com.crankuptheamps.client.Store.StoreReplayer: Replay the specified operation.
executeAsync(Command, MessageHandler) - Method in class com.crankuptheamps.client.Client: Execute the provided command and process responses on the client receive thread using the provided handler.
Expire - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the expire option, used when acknowledging (sow_delete) a leased message to immediately expire the message from the queue rather than acknowledging the message as processed.
Expired - Static variable in class com.crankuptheamps.client.Message.Reason
ExponentialDelayStrategy - Class in com.crankuptheamps.client: ExponentialDelayStrategy is an implementation that exponentially "backs off" when reconnecting to the same server, with a maximum number of retries before it gives up entirely.
ExponentialDelayStrategy() - Constructor for class com.crankuptheamps.client.ExponentialDelayStrategy: Constructs an ExponentialDelayStrategy, the default strategy for HAClient, using the default values for the class.
ExponentialDelayStrategy.MaximumRetryExceeded - Exception in com.crankuptheamps.client: A specialized exception type thrown by ExponentialDelayStrategy to indicate that the client should "give up" on attempting to reconnect to a server.

F

failedWrite(Message, int) - Method in interface com.crankuptheamps.client.FailedWriteHandler: The AMPS instance reports that a write has failed.
failedWrite(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int) - Method in interface com.crankuptheamps.client.FailedWriteHandlerV4: The AMPS instance reports that a write has failed.
FailedWriteHandler - Interface in com.crankuptheamps.client: An interface for receiving information on messages that you've written, but for which the server indicates were not persisted.
FailedWriteHandlerV4 - Interface in com.crankuptheamps.client: An interface for receiving information on messages that you've written, but for which the server indicates were not persisted.
Failure - Static variable in class com.crankuptheamps.client.Message.Status
Field - Class in com.crankuptheamps.client.fields: Base class for the different types of field data that make up a Message.
Field() - Constructor for class com.crankuptheamps.client.fields.Field: Default constructor.
Field(String) - Constructor for class com.crankuptheamps.client.fields.Field: Constructs an instance with the bytes of the specified string value.
Field(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.Field: Constructs an instance with the specified region of a byte buffer.
fieldSeparator - Variable in class com.crankuptheamps.client.FIXMessage
fieldSeparator - Variable in class com.crankuptheamps.client.FIXProtocol
finalize() - Method in class com.crankuptheamps.client.PublishStore: Overridden to call close() upon garbage collection.
find(BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Searches valid Entrys for the given bookmark.
find(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Finds and returns the Subscription object for the specified subscription id (subId).
find(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Finds and returns the Subscription object for the specified subscription id (subId).
find(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore: Finds and returns the Subscription object for the specified subscription id (subId).
findRoute(CommandId) - Method in class com.crankuptheamps.client.MessageRouter: Find and return a route
FIXBuilder - Class in com.crankuptheamps.client: Used to build up message strings for FIX.
FIXBuilder(int, byte) - Constructor for class com.crankuptheamps.client.FIXBuilder
FixedDelayStrategy - Class in com.crankuptheamps.client: FixedDelayStrategy is an implementation that delays for a fixed time period, as specified in the constructor, when reconnecting to the same server as we were previously connected to, or if we are invoked again for the first server we ever tried.
FixedDelayStrategy() - Constructor for class com.crankuptheamps.client.FixedDelayStrategy: Construct a FixedDelayStrategy with the default delay (200ms).
FixedDelayStrategy(int) - Constructor for class com.crankuptheamps.client.FixedDelayStrategy: Construct a FixedDelayStrategy with a specified delay.
FixedDelayStrategy(int, int) - Constructor for class com.crankuptheamps.client.FixedDelayStrategy: Construct a FixedDelayStrategy with a specified delay and maximum.
FixedDelayStrategy.MaximumRetryExceeded - Exception in com.crankuptheamps.client: A specialized exception type thrown by ExponentialDelayStrategy to indicate that the client should "give up" on attempting to reconnect to a server.
FIXMessage - Class in com.crankuptheamps.client: A message subclass used by FIXProtocolParser to aid in building Message instances parsed from the FIXProtocol.
FIXMessage(byte, byte, byte, CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.FIXMessage
FIXProtocol - Class in com.crankuptheamps.client: Implements the Protocol interface.
FIXProtocol() - Constructor for class com.crankuptheamps.client.FIXProtocol
FIXProtocol(Properties) - Constructor for class com.crankuptheamps.client.FIXProtocol
FIXProtocol(byte, byte, byte) - Constructor for class com.crankuptheamps.client.FIXProtocol
FIXProtocolParser - Class in com.crankuptheamps.client: Implements the ProtocolParser interface.
FIXProtocolParser(FIXProtocol) - Constructor for class com.crankuptheamps.client.FIXProtocolParser
FIXShredder - Class in com.crankuptheamps.client: A parser class which converts a FIX message into a Java Map.
FIXShredder(byte) - Constructor for class com.crankuptheamps.client.FIXShredder
flush() - Method in class com.crankuptheamps.client.BlockPublishStore
flush(long) - Method in class com.crankuptheamps.client.BlockPublishStore
flush() - Method in class com.crankuptheamps.client.Client: Deprecated.
As of 5.3.0.0. Use (@link #publishFlush) instead. Clear the queued messages which may be waiting in the transport. This is a no-op.
flush(long) - Method in class com.crankuptheamps.client.Client: Deprecated.
As of 5.3.0.0. Use (@link #publishFlush) instead. Clear the queued messages which may be waiting in the transport. This is a no-op.
flush() - Method in class com.crankuptheamps.client.HybridPublishStore
flush(long) - Method in class com.crankuptheamps.client.HybridPublishStore
Flush - Static variable in class com.crankuptheamps.client.Message.Command
flush() - Method in interface com.crankuptheamps.client.Store: Wait for the store to discard everything that has been stored up to the point in time when flush is called, then return.
flush(long) - Method in interface com.crankuptheamps.client.Store: Wait for the store to discard everything that has been stored up to the point in time when flush is called, then return.
flush() - Method in class com.crankuptheamps.client.TCPTransport
flush(long) - Method in class com.crankuptheamps.client.TCPTransport
flush() - Method in class com.crankuptheamps.client.TCPTransportImpl
flush(long) - Method in class com.crankuptheamps.client.TCPTransportImpl
flush() - Method in interface com.crankuptheamps.client.Transport
flush(long) - Method in interface com.crankuptheamps.client.Transport
flushAcks() - Method in class com.crankuptheamps.client.Client: Send the current set of queue acknowledgements ("sow_delete" with the message bookmark) to the AMPS server.
FullyDurable - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the fully_durable option.

G

get() - Method in class com.crankuptheamps.client.Pool: Returns an object from the pool, growing self if necessary (by initialSize).
getAckBatchSize() - Method in class com.crankuptheamps.client.Client: Returns the current ACK batch size.
getAckTimeout() - Method in class com.crankuptheamps.client.Client: Returns the current queue ack timeout in milliseconds.
getAckType() - Method in class com.crankuptheamps.client.Command: Get the ackType for this command.
getAckType() - Method in class com.crankuptheamps.client.Message: Returns the type of acknowledgement for an acknowledgement Message.
getAckTypeOutgoing() - Method in class com.crankuptheamps.client.Message: Returns the type of acknowledgement for an outgoing Message.
getAutoAck() - Method in class com.crankuptheamps.client.Client: Returns the current setting of auto-acking.
getBatchSize() - Method in class com.crankuptheamps.client.Command: Get the batchSize set on this command.
getBatchSize() - Method in class com.crankuptheamps.client.Message: Returns the BatchSize for this Message.
getBookmark() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Gets the bookmark field of the Entry.
getBookmark() - Method in class com.crankuptheamps.client.Command: Get the bookmark for this command.
getBookmark() - Method in class com.crankuptheamps.client.Message: Returns the AMPS Bookmark for this Message.
getBookmark() - Method in interface com.crankuptheamps.client.RecoveryPoint: Returns the subscription's recovery bookmark state.
getBookmarkRaw() - Method in class com.crankuptheamps.client.Message: Gets the raw value for the AMPS Bookmark.
getBookmarkSeqNo() - Method in class com.crankuptheamps.client.Message: Returns the bookmark sequence number for this Message.
getBookmarkStore() - Method in class com.crankuptheamps.client.Client: Returns the underlying bookmark store for this client.
getBuffer() - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the back buffer.
getBuffer() - Method in class com.crankuptheamps.client.Message: Gets the byte buffer used by the Message.
getByIndex(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Retrieves an Entry given an index.
getByte() - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the byte from the buffer.
getByte() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getByte() - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the byte from the buffer.
getBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the series of bytes at the current position by placing them into the provided BlockPublishStore.ByteSequence object.
getBytes(Field, int) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the series of bytes at the current position, this is done by copying them into a Field object.
getBytes(BlockPublishStore.ByteSequence) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getBytes(Field, int) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getBytes() - Method in class com.crankuptheamps.client.FIXBuilder: Returns the byte array containing the FIX message.
getBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the series of bytes at the current position by placing them into the provided BlockPublishStore.ByteSequence object.
getBytes(Field, int) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the series of bytes at the current position, this is done by copying them into a Field object.
getBytes() - Method in class com.crankuptheamps.client.NVFIXBuilder: Returns the byte array containing the NVFIX message.
getClient() - Method in class com.crankuptheamps.client.Message: Returns the client who allocated this message.
getClientName() - Method in class com.crankuptheamps.client.Message: Gets the ClientName on this Message.
getClientNameRaw() - Method in class com.crankuptheamps.client.Message: Gets the ClientName on this Message.
getClientSequenceNumber() - Method in class com.crankuptheamps.client.Command: Get the client sequence number set on this command.
getCommand() - Method in class com.crankuptheamps.client.Command: Return the command type for this command.
getCommand() - Method in class com.crankuptheamps.client.Message: Returns the Command for this Message, indicating the type of of message this is.
getCommandId() - Method in class com.crankuptheamps.client.Command
getCommandId() - Method in class com.crankuptheamps.client.Message: Gets the CommandId on this Message.
getCommandId(CommandId) - Method in class com.crankuptheamps.client.Message: Gets the CommandId on this Message by copying it into the provided CommandId object.
getCommandIdRaw() - Method in class com.crankuptheamps.client.Message: Gets the CommandId on this Message.
getConnectionInfo() - Method in class com.crankuptheamps.client.Client: Assembles a new ConnectionInfo with the state of this client and associated classes.
getConnectionInfo() - Method in class com.crankuptheamps.client.HAClient: Assembles a new ConnectionInfo with the state of this client and associated classes.
getConnectWaitDuration(String) - Method in class com.crankuptheamps.client.ExponentialDelayStrategy
getConnectWaitDuration(String) - Method in class com.crankuptheamps.client.FixedDelayStrategy: Returns the time (in milliseconds) that the client should wait before connecting to the given server URI.
getConnectWaitDuration(String) - Method in interface com.crankuptheamps.client.ReconnectDelayStrategy: Returns the time (in milliseconds) that the client should wait before connecting to the given server URI.
getConversionBufInitialSize() - Method in class com.crankuptheamps.client.fields.BookmarkField: Overrides the base classes' initial default size for the byte and char conversion buffers used by this instance.
getConversionBufInitialSize() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField: Overrides the base classes' initial default size for the byte and char conversion buffers used by this instance.
getConversionBufInitialSize() - Method in class com.crankuptheamps.client.fields.StringField: Returns the initial default size for the byte and char conversion buffers used by this instance.
getCorrelationId() - Method in class com.crankuptheamps.client.Command: Returns the correlation Id set on this command
getCorrelationId() - Method in class com.crankuptheamps.client.Message: Get the CorrelationId on this message.
getCorrelationIdRaw() - Method in class com.crankuptheamps.client.Message: Get the CorrelationId on this message.
getCurrentAuthenticator() - Method in class com.crankuptheamps.client.DefaultServerChooser: Returns the Authenticator instance associated with the current URI.
getCurrentAuthenticator() - Method in interface com.crankuptheamps.client.ServerChooser: Returns the Authenticator instance associated with the current URI.
getCurrentURI() - Method in class com.crankuptheamps.client.DefaultServerChooser: Gets the current URI.
getCurrentURI() - Method in interface com.crankuptheamps.client.ServerChooser: Returns the current URI.
getData() - Method in class com.crankuptheamps.client.Command: Get the data set on this command.
getData() - Method in class com.crankuptheamps.client.Message: Returns the payload of the Message.
getDataRaw() - Method in class com.crankuptheamps.client.Message: Returns the payload of the Message.
getDecoder() - Method in class com.crankuptheamps.client.Message: Returns the CharsetDecoder for this Message.
getDefaultConnectTimeout() - Static method in class com.crankuptheamps.client.TCPTransport: Returns the default connect timeout used for new connections.
getDefaultEnabledCipherSuites() - Static method in class com.crankuptheamps.client.TCPSTransport: Returns the cipher suites that will be enabled on SSLSockets.
getDefaultEnabledProtocols() - Static method in class com.crankuptheamps.client.TCPSTransport: Returns the protocols that will be enabled on SSLSockets.
getDefaultMaxDepth() - Method in class com.crankuptheamps.client.Client: Gets the currently set default value for the max depth of MessageStream instances created by this client.
getDefaultReadTimeout() - Static method in class com.crankuptheamps.client.TCPTransport: Returns the default read timeout used for socket reads.
getDefaultResubscriptionTimeout() - Static method in class com.crankuptheamps.client.MemorySubscriptionManager: Gets the Default Resubscription Timeout for all instances of this class in milliseconds.
getDefaultSSLContext() - Static method in class com.crankuptheamps.client.TCPSTransport: Returns the SSL context that will be used for connecting.
getDepth() - Method in class com.crankuptheamps.client.MessageStream: Gets the number of messages currently buffered by this message stream.
getDisconnectHandler() - Method in class com.crankuptheamps.client.Client: Returns the current ClientDisconnectHandler set on self.
getDuplicateMessageHandler() - Method in class com.crankuptheamps.client.Client: Returns the MessageHandler instance used for duplicate messages.
getEmptyMessageStream() - Static method in class com.crankuptheamps.client.MessageStream: Method to retrieve the empty MessageStream.
getEncoder() - Method in class com.crankuptheamps.client.Message: Returns the CharsetEncoder for this Message.
getEnd() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
getEndIndex() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Returns the index value one greater than the last valid Entry in self.
getError() - Method in class com.crankuptheamps.client.DefaultServerChooser: Provides additional details to be included in an exception thrown when the AMPS instance(s) are not available.
getError() - Method in interface com.crankuptheamps.client.ServerChooser: Provides additional detail to be included in an exception thrown when the AMPS instance(s) are not available.
getExceptionListener() - Method in class com.crankuptheamps.client.Client: Returns the ExceptionListener instance used for communicating absorbed exceptions.
getExceptionListener() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Returns the ExceptionListener instance used for communicating absorbed exceptions.
getExpiration() - Method in class com.crankuptheamps.client.Command: Get the expiration set on this command.
getExpiration() - Method in class com.crankuptheamps.client.Message: Returns the Expiration field set for this Message.
getExpirationRaw() - Method in class com.crankuptheamps.client.Message: Returns the Expiration field set for this Message.
getFailedWriteHandler() - Method in class com.crankuptheamps.client.Client: Returns the FailedWriteHandler instance used to report on failed messages that have been written.
getFilter() - Method in class com.crankuptheamps.client.Command: Get the filter for this command.
getFilter() - Method in class com.crankuptheamps.client.Message: Returns the Filter field on this Message.
getFilterRaw() - Method in class com.crankuptheamps.client.Message: Returns the Filter field on this Message.
getGroupSeqNo() - Method in class com.crankuptheamps.client.Message: Get the group sequence number.
getHeartbeatInterval() - Method in class com.crankuptheamps.client.Client: Returns the heartbeat interval used by the Client.
getHighestUnpersisted() - Method in class com.crankuptheamps.client.BlockPublishStore
getImplementationVersion() - Static method in class com.crankuptheamps.client.ClientVersion: Gets the implementation version number of this AMPS client build.
getIndex() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Gets the index of the Entry in the Entry array.
getInt() - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the integer from the buffer.
getInt(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the integer from the buffer.
getInt() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getInt(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getInt() - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the integer from the buffer.
getInt(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the integer from the buffer.
getLastDiscarded() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Returns the "last discarded" bookmark.
getLastPersisted() - Method in class com.crankuptheamps.client.BlockPublishStore
getLastPersisted() - Method in class com.crankuptheamps.client.HybridPublishStore
getLastPersisted() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getLastPersisted() - Method in interface com.crankuptheamps.client.Store: Return the last persisted index in the store.
getLeasePeriod() - Method in class com.crankuptheamps.client.Message: Gets the decoded version of the LeasePeriod for the Message.
getLeasePeriodRaw() - Method in class com.crankuptheamps.client.Message: Gets the raw verstion of the LeasePeriod filter for the Message.
getLength() - Method in class com.crankuptheamps.client.Message: Returns the Length of the Message.
getLogonCorrelationData() - Method in class com.crankuptheamps.client.Client: Gets the uninterpreted logon correlation information currently set.
getLogonOptions() - Method in class com.crankuptheamps.client.HAClient: Returns the current logon options string.
getLong() - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the long from the buffer.
getLong() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getLong() - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the long from the buffer.
getLowestUnpersisted() - Method in class com.crankuptheamps.client.BlockPublishStore
getLowestUnpersisted() - Method in class com.crankuptheamps.client.HybridPublishStore: Returns the lowest sequence number currently in the store.
getLowestUnpersisted() - Method in interface com.crankuptheamps.client.Store: Return the oldest index in the store.
getMatches() - Method in class com.crankuptheamps.client.Message: Returns the number of matches in the command this Message acknowledges.
getMaxDepth() - Method in class com.crankuptheamps.client.MessageStream: Gets the allowed maximum depth of the internal message buffer before this stream will push-back on reads from the server.
getMessageStream() - Method in class com.crankuptheamps.client.FIXProtocol
getMessageStream() - Method in class com.crankuptheamps.client.JSONProtocol
getMessageStream() - Method in class com.crankuptheamps.client.NVFIXProtocol
getMessageStream() - Method in interface com.crankuptheamps.client.Protocol: Returns a parser instance that can deserialize a byte stream into a series of messages.
getMessageStream() - Method in class com.crankuptheamps.client.XMLProtocol: Gets the message stream for the XML message.
getMessageType() - Method in class com.crankuptheamps.client.Message: Returns the MessageType on this client.
getMostRecent(Field) - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to return the correct recovery point for resubscription of the provided subID from the BookmarkStore.
getMostRecent(Field, boolean) - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to return the correct recovery point for resubscription of the provided subID from the BookmarkStore.
getMostRecent(Field) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
getMostRecent(Field, boolean) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
getMostRecent(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
getMostRecent(Field, boolean) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
getMostRecent() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getMostRecent(boolean) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getMostRecent(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
getMostRecent(Field, boolean) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
getMostRecent() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
getMostRecent(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to return to the most recent bookmark from the log that should be used for (re-)subscriptions.
getMostRecent(Field, boolean) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to return to the most recent bookmark from the log that should be used for (re-)subscriptions.
getMostRecent() - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
getMostRecent() - Method in interface com.crankuptheamps.client.Subscription
getMostRecentList(boolean) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getMostRecentList(boolean) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
getMostRecentList(boolean) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
getMostRecentList(boolean) - Method in interface com.crankuptheamps.client.Subscription
getName() - Method in class com.crankuptheamps.client.Client: Return the name of the Client.
getNameHash() - Method in class com.crankuptheamps.client.Client: Return the name hash of the Client as returned by the server at logon.
getOldestBookmarkSeq(Field) - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to retrieve the sequence number of the oldest bookmark in the store.
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
getOldestBookmarkSeq() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
getOldestBookmarkSeq() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to retrieve the sequence number for the oldest bookmark in the store.
getOldestBookmarkSeq() - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
getOldestBookmarkSeq() - Method in interface com.crankuptheamps.client.Subscription
getOldStyleVersion() - Method in class com.crankuptheamps.client.VersionInfo
getOptions() - Method in class com.crankuptheamps.client.Command: Get the options for this command.
getOptions() - Method in class com.crankuptheamps.client.Message: Returns the Options to be set on this Message.
getOptionsRaw() - Method in class com.crankuptheamps.client.Message: Returns the Options to be set on this Message.
getOrderBy() - Method in class com.crankuptheamps.client.Command: Get the orderBy clause for this command.
getOrderBy() - Method in class com.crankuptheamps.client.Message: Get the OrderBy parameter for this Message.
getOrderByRaw() - Method in class com.crankuptheamps.client.Message: Get the OrderBy parameter for this Message.
getPart(int, Field) - Method in class com.crankuptheamps.client.CompositeMessageParser: Returns a part from a composite message body.
getPassword() - Method in class com.crankuptheamps.client.Message: Returns the Password set on the Message.
getPasswordRaw() - Method in class com.crankuptheamps.client.Message: Returns the Password set on the Message.
getPosition() - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the current position in the buffer.
getPosition() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getPosition() - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the current position in the buffer.
getPublisherId() - Method in class com.crankuptheamps.client.fields.BookmarkField: Gets the publisher id for this bookmark.
getPublishStore() - Method in class com.crankuptheamps.client.Client: Returns the underlying publish store for this client.
getQueryId() - Method in class com.crankuptheamps.client.Command: Get the queryId for this command.
getQueryId() - Method in class com.crankuptheamps.client.Message: Returns the QueryId for this Message.
getQueryId(CommandId) - Method in class com.crankuptheamps.client.Message: Returns the QueryId for this Message by copying it into the provided CommandId.
getQueryIdRaw() - Method in class com.crankuptheamps.client.Message: Returns the QueryId for this Message.
getRange() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getRange() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
getRange() - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
getRange() - Method in interface com.crankuptheamps.client.Subscription
getRawBufferLength() - Method in class com.crankuptheamps.client.Message: Gets the length of the Message within the byte buffer.
getRawBufferOffset() - Method in class com.crankuptheamps.client.Message: Gets the offset into the byte buffer where this Message begins.
getReadTimeout() - Method in class com.crankuptheamps.client.Client: Returns the time (in seconds) to allow silence on the connection before assuming it is dead.
getReason() - Method in class com.crankuptheamps.client.Message: Returns the Reason value of this Message.
getReasonText() - Method in class com.crankuptheamps.client.Message: Returns the Reason value of this Message.
getReconnectDelayStrategy() - Method in class com.crankuptheamps.client.HAClient: Returns the ReconnectDelayStrategy used to control sleeping behavior before connecting to a server.
getRecordsDeleted() - Method in class com.crankuptheamps.client.Message: Returns the number of records deleted for the command that this Message was produced in response to.
getRecordsInserted() - Method in class com.crankuptheamps.client.Message: Returns the number of records inserted for the command that this Message was produced in response to.
getRecordsReturned() - Method in class com.crankuptheamps.client.Message: Returns the number of records returned for the command that this Message was produced in response to.
getRecordsUpdated() - Method in class com.crankuptheamps.client.Message: Returns the number of records updated for the command that this Message was produced in response to.
getRecoveryEntries(ArrayList<BookmarkRingBuffer.Entry>) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
getRecoveryEntries() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Deprecated.
getRecoveryTimestamp() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
getRecoveryTimestamp() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
getReleaseVersion() - Static method in class com.crankuptheamps.client.ClientVersion: Gets the release version number of this AMPS client build.
getResubscriptionTimeout() - Method in class com.crankuptheamps.client.MemorySubscriptionManager: Gets the Resubscription timeout in milliseconds .
getRetryOnDisconnect() - Method in class com.crankuptheamps.client.Client: Return whether or not messages being sent to the server will retry if the client is disconnected.
getSequence() - Method in class com.crankuptheamps.client.Message: Returns the sequence number for this Message.
getSequenceNumber() - Method in class com.crankuptheamps.client.fields.BookmarkField: Gets the sequence number for this bookmark.
getSequenceRaw() - Method in class com.crankuptheamps.client.Message: Returns the sequence number for this Message.
getServerChooser() - Method in class com.crankuptheamps.client.HAClient: Returns the current ServerChooser.
getServerVersion() - Method in class com.crankuptheamps.client.Client: Return the server version retrieved during logon.
getServerVersion() - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Called by Client when connected to an AMPS server in order to retrieve the version number of the server.
getServerVersion() - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Called by Client when connected to an AMPS server in order to retrieve the version number of the server.
getServerVersion() - Method in class com.crankuptheamps.client.RingBookmarkStore: Called internally by the Client to return the server version detected upon logon.
getServerVersionInfo() - Method in class com.crankuptheamps.client.Client: Return the server version retrieved during logon.
getSize() - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Gets the size of the back buffer.
getSize() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
getSize() - Method in class com.crankuptheamps.client.FIXBuilder: Returns the number of bytes in the byte array containing the FIX message.
getSize() - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Gets the size of the buffer.
getSize() - Method in class com.crankuptheamps.client.NVFIXBuilder: Returns the number of bytes in the byte array containing the NVFIX message.
getSOWKey() - Method in class com.crankuptheamps.client.Command: Deprecated.
Use getSowKey() instead.
getSowKey() - Method in class com.crankuptheamps.client.Command: Returns the SOW key on this command.
getSowKey() - Method in class com.crankuptheamps.client.Message: Returns the SowKey for this Message.
getSowKeyRaw() - Method in class com.crankuptheamps.client.Message: Returns the SowKey for this Message.
getSowKeys() - Method in class com.crankuptheamps.client.Command: Returns the SOW key on this command.
getSOWKeys() - Method in class com.crankuptheamps.client.Command: Deprecated.
Use getSowKeys() instead
getSowKeys() - Method in class com.crankuptheamps.client.Message: Gets the set of SowKeys this message applies to.
getSowKeysRaw() - Method in class com.crankuptheamps.client.Message: Gets the set of SowKeys this message applies to.
getStart() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
getStartIndex() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Returns the index value associated with the first valid Entry in self.
getStatus() - Method in class com.crankuptheamps.client.Message: Returns the Status of this Message.
getString(int) - Method in class com.crankuptheamps.client.CompositeMessageParser: Returns a part from a composite message body.
getString(int, Charset) - Method in class com.crankuptheamps.client.CompositeMessageParser: Returns a part from a composite message body.
getSubId() - Method in class com.crankuptheamps.client.Command: Get the subId set on this command.
getSubId() - Method in class com.crankuptheamps.client.Message: Gets the SubId of this Message.
getSubId(CommandId) - Method in class com.crankuptheamps.client.Message: Gets the SubId of this Message by copying it into the provided CommandId.
getSubId() - Method in interface com.crankuptheamps.client.RecoveryPoint: Returns the subscription id that this recovery point belongs to.
getSubIdRaw() - Method in class com.crankuptheamps.client.Message: Gets the SubId of this Message.
getSubIds() - Method in class com.crankuptheamps.client.Message: The set of SubIds for this Message.
getSubIdsRaw() - Method in class com.crankuptheamps.client.Message: The set of SubIds for this message.
getSubscription() - Method in class com.crankuptheamps.client.Message: Gets the Subscription for this Message.
getSubscriptionManager() - Method in class com.crankuptheamps.client.Client: Returns the SubscriptionManager instance used for recording active subscriptions.
getText() - Method in class com.crankuptheamps.client.fields.ReasonField: Returns the value of this reason field as a descriptive text string.
getTimeout() - Method in class com.crankuptheamps.client.Command: Get the timeout set on this command.
getTimeout() - Method in class com.crankuptheamps.client.HAClient: Returns the timeout used for logging on and resubscribing, once a connection is re-established.
getTimeout() - Method in class com.crankuptheamps.client.MessageStream: Gets the currently set timeout value for self (zero if none).
getTimestamp() - Method in class com.crankuptheamps.client.Message: Returns the timestamp for this message, an ISO-8601 formatted string.
getTimestampRaw() - Method in class com.crankuptheamps.client.Message: Returns the timestamp for this message, an ISO-8601 formatted string.
getTopic() - Method in class com.crankuptheamps.client.Command: Get the topic set on this command.
getTopic() - Method in class com.crankuptheamps.client.Message: Return the topic that the message applies to.
getTopicMatches() - Method in class com.crankuptheamps.client.Message: Returns the number of matching topics for the command that this message was produced in response to.
getTopicRaw() - Method in class com.crankuptheamps.client.Message: Return the topic that the message applies to.
getTopN() - Method in class com.crankuptheamps.client.Command: Get the topN value for this command.
getTopN() - Method in class com.crankuptheamps.client.Message: Get the TopN parameter for this message.
getTransport() - Method in class com.crankuptheamps.client.Client: Return the underlying transport.
getURI() - Method in class com.crankuptheamps.client.Client: Return the URI the Client is connected to.
getUserId() - Method in class com.crankuptheamps.client.Message: Get the UserId for this message.
getUserIdRaw() - Method in class com.crankuptheamps.client.Message: Get the UserId for this message.
getValue() - Method in class com.crankuptheamps.client.fields.AckTypeField: This method gets the value of the AckType.
getValue() - Method in class com.crankuptheamps.client.fields.BooleanField: Gets the value for the boolean field.
getValue() - Method in class com.crankuptheamps.client.fields.CommandField: This method gets the value of the Command.
getValue() - Method in class com.crankuptheamps.client.fields.IntegerField: Gets the value of this integer field as a Java 32-bit signed integer.
getValue() - Method in class com.crankuptheamps.client.fields.LongField: Gets the value of this long field as a Java 64-bit signed integer.
getValue(CharsetDecoder) - Method in class com.crankuptheamps.client.fields.OptionsField
getValue(ByteBuffer) - Method in class com.crankuptheamps.client.fields.OptionsField
getValue() - Method in class com.crankuptheamps.client.fields.ReasonField: This returns the value of this reason field as an integer reason code.
getValue() - Method in class com.crankuptheamps.client.fields.StatusField: This returns the value of this status field as an integer status code.
getValue(CharsetDecoder) - Method in class com.crankuptheamps.client.fields.StringField: Returns a string representation of the Field value, where the bytes are interpreted by using the specified decoder.
getValue(ByteBuffer) - Method in class com.crankuptheamps.client.fields.StringField: Writes the byte value of this instance into the specified byte buffer, if the value is not null.
getValue(CommandId) - Method in class com.crankuptheamps.client.fields.StringField: Writes the byte value of this instance into the specified command ID buffer object, if the value is not null.
getVersion() - Static method in class com.crankuptheamps.client.Client: Return the build number for the client that is stored in the Manifest.mf of the jar file.
getVersion() - Method in class com.crankuptheamps.client.Message: Returns the version of the AMPS server, provided in response to a logon.
getVersion() - Method in class com.crankuptheamps.client.TCPTransport
getVersion() - Method in interface com.crankuptheamps.client.Transport
getVersion() - Method in class com.crankuptheamps.client.VersionInfo
getVersionAsInt(String) - Static method in class com.crankuptheamps.client.Client: Deprecated.
getVersionAsInt() - Method in class com.crankuptheamps.client.Message: Returns the version of the AMPS server, provided in response to a logon.
getVersionRaw() - Method in class com.crankuptheamps.client.Message: Returns the version of the AMPS server, provided in response to a logon.
getVersionString() - Method in class com.crankuptheamps.client.VersionInfo
GroupBegin - Static variable in class com.crankuptheamps.client.Message.Command
GroupEnd - Static variable in class com.crankuptheamps.client.Message.Command
Grouping(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the grouping option for an aggregated subscription, which specifies how to determine which records to aggregate together.
Grouping(Iterable<String>) - Static method in class com.crankuptheamps.client.Message.Options: Formats the grouping option for an aggregated subscription, which specifies how to determine which records to aggregate together.
growFreeListIfEmpty() - Method in class com.crankuptheamps.client.BlockPublishStore

H

HAClient - Class in com.crankuptheamps.client: A highly-available AMPS Client object that automatically reconnects and re-subscribes to AMPS instances upon disconnect.
HAClient(String) - Constructor for class com.crankuptheamps.client.HAClient: Constructs a new HAClient.
HAClient.HADisconnectHandler - Class in com.crankuptheamps.client: Class used to handle dicsonnects for highly-available AMPS Clients.
HADisconnectHandler() - Constructor for class com.crankuptheamps.client.HAClient.HADisconnectHandler
handleCloseEvent(int, String, Exception) - Method in class com.crankuptheamps.client.TCPTransport
handleCloseEvent(int, String, Exception) - Method in class com.crankuptheamps.client.TCPTransportImpl
handleCloseEvent(int, String, Exception) - Method in interface com.crankuptheamps.client.Transport
handshake() - Method in class com.crankuptheamps.client.TCPSTransportImpl
handshake() - Method in class com.crankuptheamps.client.TCPTransportImpl
hasExpiration() - Method in class com.crankuptheamps.client.Command: Returns true if this command has an expiration set.
HashBox - Class in com.crankuptheamps.client: A helper class, used as a HashMap key, that can hash strings, byte array regions, or integers.
HashBox() - Constructor for class com.crankuptheamps.client.HashBox
hashCode() - Method in class com.crankuptheamps.client.CommandId: Overridden to return a hash code that is based upon CommandId value.
hashCode() - Method in class com.crankuptheamps.client.fields.BookmarkField
hashCode() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
hashCode() - Method in class com.crankuptheamps.client.fields.Field: Default implementation of Object.hashCode() for a Field.
hashCode() - Method in class com.crankuptheamps.client.fields.OptionsField: Implementation of Object.hashCode() for an OptionsField.
hashCode() - Method in class com.crankuptheamps.client.HashBox
hashCode() - Method in class com.crankuptheamps.client.VersionInfo
hasNext() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Implements Iterator.hasNext().
hasNext() - Method in class com.crankuptheamps.client.MessageStream: Implements Iterator.hasNext() for a message stream.
hasNext() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Implements Iterator.hasNext().
hasRoute(CommandId) - Method in class com.crankuptheamps.client.MessageRouter: Return whether or not a command id has a route
headerSeparator - Variable in class com.crankuptheamps.client.FIXMessage
headerSeparator - Variable in class com.crankuptheamps.client.FIXProtocol
Heartbeat - Static variable in class com.crankuptheamps.client.Message.Command
HeartbeatInitiated - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client has begun heartbeat processing with the server.
hour - Variable in class com.crankuptheamps.client.AMPSTimestamp: Hour part of this timestamp.
HybridPublishStore - Class in com.crankuptheamps.client: PublishStore that stores first in memory, and swaps excess out to disk.
HybridPublishStore(String, int) - Constructor for class com.crankuptheamps.client.HybridPublishStore

I

id - Variable in class com.crankuptheamps.client.CommandId
IMPLEMENTATION_VERSION - Static variable in class com.crankuptheamps.client.ClientVersion: The implementation version number of this AMPS client build.
incoming(ByteBuffer) - Method in class com.crankuptheamps.client.DefaultTransportFilter
incoming(ByteBuffer) - Method in interface com.crankuptheamps.client.TransportFilter: Called just after raw data is received from the AMPS instance.
incoming(ByteBuffer) - Method in class com.crankuptheamps.client.TransportTraceFilter: Method to call the print() method with the incoming prefix for printing raw data.
init(Field, LoggedBookmarkStore) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
init(Field, MemoryBookmarkStore) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
init(ByteBuffer, int) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
initSerialization() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter
instance - Static variable in class com.crankuptheamps.client.DefaultDisconnectHandler
instance - Static variable in class com.crankuptheamps.client.DefaultMessageHandler
IntegerField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of an integer value.
IntegerField() - Constructor for class com.crankuptheamps.client.fields.IntegerField
InvalidBookmark - Static variable in class com.crankuptheamps.client.Message.Reason
InvalidOrderBy - Static variable in class com.crankuptheamps.client.Message.Reason
InvalidProtocolOptionsException - Exception in com.crankuptheamps.client.exception: Throws an exception when invalid protocol options were used in the URI specification.
InvalidProtocolOptionsException() - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
InvalidProtocolOptionsException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
InvalidProtocolOptionsException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
InvalidProtocolOptionsException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
InvalidTopic - Static variable in class com.crankuptheamps.client.Message.Reason
InvalidTopicException - Exception in com.crankuptheamps.client.exception: Thrown when the AMPS server reports that the command requested is not valid for the topic specified.
InvalidTopicException() - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
InvalidTopicException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
InvalidTopicException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
InvalidTopicException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
InvalidTransportOptionsException - Exception in com.crankuptheamps.client.exception: Thrown when invalid transport options are used in the URI specification.
InvalidTransportOptionsException() - Constructor for exception com.crankuptheamps.client.exception.InvalidTransportOptionsException
InvalidTransportOptionsException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidTransportOptionsException
InvalidTransportOptionsException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidTransportOptionsException
InvalidTransportOptionsException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidTransportOptionsException
InvalidURIException - Exception in com.crankuptheamps.client.exception: Thrown when an invalid URI format is specified.
InvalidURIException() - Constructor for exception com.crankuptheamps.client.exception.InvalidURIException
InvalidURIException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidURIException
InvalidURIException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidURIException
InvalidURIException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidURIException
invoke(BookmarkStore, Field, long) - Method in interface com.crankuptheamps.client.BookmarkStoreResizeHandler: Called by the store when it wants to attempt a resize.
invoke(Client) - Method in interface com.crankuptheamps.client.ClientDisconnectHandler: When the Client unintentionally disconnects from AMPS, this method is invoked.
invoke(Client, Exception) - Method in interface com.crankuptheamps.client.ClientDisconnectHandler2: When the Client unintentionally disconnects from AMPS, this method is invoked.
invoke(Client) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
invoke(Transport, Exception) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
invoke(Message) - Method in class com.crankuptheamps.client.DefaultMessageHandler
invoke(Client) - Method in class com.crankuptheamps.client.HAClient.HADisconnectHandler
invoke(Client, Exception) - Method in class com.crankuptheamps.client.HAClient.HADisconnectHandler
invoke(Message) - Method in interface com.crankuptheamps.client.MessageHandler: Method for the AMPS client to call when a message is received.
invoke(Message) - Method in class com.crankuptheamps.client.MessageStream
invoke(Store, long) - Method in interface com.crankuptheamps.client.PublishStoreResizeHandler: Called by the Store when it wants to attempt a resize.
invoke() - Method in interface com.crankuptheamps.client.ThreadCreatedHandler
invoke(Transport, Exception) - Method in interface com.crankuptheamps.client.TransportDisconnectHandler: Called by the Transport whenever the underlying socket is disconnected.
isAckTypeNull() - Method in class com.crankuptheamps.client.Message: Checks whether the AckType field is null.
isActive() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Gets the active value of the Entry.
isBatchSizeNull() - Method in class com.crankuptheamps.client.Message: Checks whether the BatchSize field is null.
isBookmarkNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Bookmark field is null.
isClientNameNull() - Method in class com.crankuptheamps.client.Message: Checks whether the ClientName field is null.
isCommandIdNull() - Method in class com.crankuptheamps.client.Message: Checks whether the CommandId is null.
isCommandNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Command field is null.
isConflating() - Method in class com.crankuptheamps.client.MessageStream: Indicates whether this message stream is conflating messages by SOW key.
isConnected() - Method in class com.crankuptheamps.client.MessageStream: Returns true if the connection to AMPS is still active, or false if a disconnect is detected.
isCorrelationIdNull() - Method in class com.crankuptheamps.client.Message: Checks whether the CorrelationId field is null.
isDaemon() - Static method in class com.crankuptheamps.client.TCPTransport
isDataNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Data field is null.
isDiscarded(Message) - Method in interface com.crankuptheamps.client.BookmarkStore: Called for each arriving message to determine if the application has already processed and discarded this message.
isDiscarded(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
isDiscarded(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
isDiscarded(BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription: Check to see if this message is older than the most recent one seen, and if it is, then check to see if it is discarded.
isDiscarded(Message) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
isDiscarded(BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription: Check to see if this message is older than the most recent one seen, and if it is, check if it discarded.
isDiscarded(Message) - Method in class com.crankuptheamps.client.RingBookmarkStore: Called for each arriving message to determine if the application has already processed and discarded the message.
isDiscarded(BookmarkField) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
isDiscarded(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
isEmpty() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Returns if the buffer is currently empty.
isEndExclusive() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
isEndInclusive() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
isExpirationNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Expiration field is null.
isFilterNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Filter field is null.
isGroupSeqNoNull() - Method in class com.crankuptheamps.client.Message: Checks whether the GroupSeqNo field is null.
isIgnoreAutoAck() - Method in class com.crankuptheamps.client.Message: Used to check if automatic acking of this Message by the Client should be skipped.
isLeasePeriodNull() - Method in class com.crankuptheamps.client.Message: Check whether the LeasePeriod field is null.
isLengthNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Length field is null.
isMatchesNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Matches field is Null.
isMessageTypeNull() - Method in class com.crankuptheamps.client.Message: Checks whether the MessageType field is null.
isNull() - Method in class com.crankuptheamps.client.fields.Field: Indicates whether this instance's value is null.
isOptionsNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Options field is null.
isOrderByNull() - Method in class com.crankuptheamps.client.Message: Checks whether the OrderBy field is null.
isPasswordNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Password field is null.
isPersisted() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Deprecated.
isQueryIdNull() - Method in class com.crankuptheamps.client.Message: Checks whether the QueryId field is null.
isRange() - Method in class com.crankuptheamps.client.fields.BookmarkField: Indicates whether this bookmark value appears to be a range, using only a simple check for brackets or parentheses.
isReasonNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Reason is null.
isRecordsDeletedNull() - Method in class com.crankuptheamps.client.Message: Checks whether the RecordsDeleted field is null.
isRecordsInsertedNull() - Method in class com.crankuptheamps.client.Message: Checks whether the RecordsInserted field is null.
isRecordsReturnedNull() - Method in class com.crankuptheamps.client.Message: Checks whether the RecordsReturned field is null.
isRecordsUpdatedNull() - Method in class com.crankuptheamps.client.Message: Checks whether the RecordsUpdated field is null.
isSequenceNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Sequence field is null.
isSow() - Method in class com.crankuptheamps.client.Command: Returns true if this command queries a SOW.
isSowKeyNull() - Method in class com.crankuptheamps.client.Message: Checks whether the SowKey field is null.
isSowKeysNull() - Method in class com.crankuptheamps.client.Message: Checks whether the SowKeys field is null.
isStartExclusive() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
isStartInclusive() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
isSubIdNull() - Method in class com.crankuptheamps.client.Message: Checks whether the SubId field is null.
isSubIdsNull() - Method in class com.crankuptheamps.client.Message: Checks whether the SubIds field is null.
isSubscribe() - Method in class com.crankuptheamps.client.Command: Returns true if this command creates a subscription.
isTimestamp() - Method in class com.crankuptheamps.client.fields.BookmarkField: Indicates whether this bookmark value appears to be a timestamp.
isTimestampNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Timestamp field is null.
isTopicMatchesNull() - Method in class com.crankuptheamps.client.Message: Checks whether the TopicMatches field is null.
isTopicNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Topic field is null.
isTopNNull() - Method in class com.crankuptheamps.client.Message: Checks whether the TopN field is null.
isUserIdNull() - Method in class com.crankuptheamps.client.Message: Checks whether the UserId field is null.
isValid() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
isVersionNull() - Method in class com.crankuptheamps.client.Message: Checks whether the Version field is null.
iterator() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Implements Iterable.iterator() to return this instance.
iterator() - Method in class com.crankuptheamps.client.MessageStream: Implements Iterable.iterator() to return this instance.
iterator() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Implements Iterable.iterator() to return this instance.

J

JSON_END - Static variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
JSON_INIT_LEN - Static variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
JSON_LEN - Static variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
JSON_START - Static variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
JSONMessage - Class in com.crankuptheamps.client: A message subclass used by JSONProtocolParser to aid in building Message instances parsed from the JSONProtocol (i.e.
JSONMessage(CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.JSONMessage
JSONProtocol - Class in com.crankuptheamps.client: Implements the Protocol interface.
JSONProtocol() - Constructor for class com.crankuptheamps.client.JSONProtocol
JSONProtocol(Properties) - Constructor for class com.crankuptheamps.client.JSONProtocol
JSONProtocolParser - Class in com.crankuptheamps.client: Implements the ProtocolParser interface.
JSONProtocolParser(JSONProtocol) - Constructor for class com.crankuptheamps.client.JSONProtocolParser
justRecovered() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription: Call on a Subscription object just after recovery is performed to convert logged entries into recovery entries and set the publishers cache state to the earliest sequence seen for each publisher minus one.

L

LATIN1 - Static variable in class com.crankuptheamps.client.fields.AckTypeField
LATIN1 - Static variable in class com.crankuptheamps.client.fields.BooleanField
LATIN1 - Static variable in class com.crankuptheamps.client.fields.CommandField
LATIN1 - Static variable in class com.crankuptheamps.client.fields.StatusField
LATIN1 - Static variable in class com.crankuptheamps.client.fields.StringField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.AckTypeField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.BooleanField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.CommandField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.IntegerField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.LongField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.StatusField
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.StringField
len - Variable in class com.crankuptheamps.client.BlockPublishStore.ByteSequence
length - Variable in class com.crankuptheamps.client.fields.Field
Live - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the live option.
lock - Variable in class com.crankuptheamps.client.Client
log(BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Logs the bookmark by allocating an Entry, setting the Entry to active, copying the bookmark value to that entry, and returning the index of that entry.
log(Message) - Method in interface com.crankuptheamps.client.BookmarkStore: Called internally by the Client to log a bookmark to the persistent log.
log(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
log(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
log(BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
log(Message) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
log(BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
log(Message) - Method in class com.crankuptheamps.client.RingBookmarkStore: Called internally by the Client to log a bookmark to the persistent log.
log(BookmarkField) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
log(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
LoggedBookmarkStore - Class in com.crankuptheamps.client: LoggedBookmarkStore implements a sequentially written log of incoming and discarded messages.
LoggedBookmarkStore(String) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore: Same as calling LoggedBookmarkStore(path, 1, false).
LoggedBookmarkStore(String, int) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore: Same as calling LoggedBookmarkStore(path, targetNumberOfSubscriptions, false).
LoggedBookmarkStore(String, int, boolean) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore: A file-backed bookmark store implementation that fully supports discarding messages in an order different from the order they arrived (i.e.
LoggedBookmarkStore(String, int, boolean, RecoveryPointAdapter) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore: A file-backed bookmark store implementation that fully supports discarding messages in an order different from the order they arrived (i.e.
LoggedBookmarkStore(String, int, boolean, RecoveryPointAdapter, RecoveryPointFactory) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore: A file-backed bookmark store implementation that fully supports discarding messages in an order different from the order they arrived (i.e.
LoggedBookmarkStore.Subscription - Class in com.crankuptheamps.client: The Subscription object is used to represent internal bookmark state for the messages received and discarded on a specific subscription within the bookmark store.
LoggedOn - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client completes logon.
logon(long) - Method in class com.crankuptheamps.client.Client: Logs into AMPS with the parameters provided in the connect method and the logon correlation id, if any, that is set.
logon(long, String) - Method in class com.crankuptheamps.client.Client: Logs into AMPS with the parameters provided in the connect method and the logon correlation id, if any, that is set.
logon(String) - Method in class com.crankuptheamps.client.Client: Logs into AMPS with the parameters provided in the connect method and the logon correlation id, if any, that is set.
logon(long, Authenticator) - Method in class com.crankuptheamps.client.Client: Logs into AMPS with the parameters provided in the connect method and the logon correlation id, if any, that is set.
logon(long, Authenticator, String) - Method in class com.crankuptheamps.client.Client: Logs into AMPS with the parameters provided in the connect method and the logon correlation id, if any, that is set.
logon() - Method in class com.crankuptheamps.client.Client: Logs into AMPS with the parameters provided in the connect method.
logon(long) - Method in class com.crankuptheamps.client.HAClient
logon(String) - Method in class com.crankuptheamps.client.HAClient
logon(long, String) - Method in class com.crankuptheamps.client.HAClient
logon(long, Authenticator) - Method in class com.crankuptheamps.client.HAClient
logon(long, Authenticator, String) - Method in class com.crankuptheamps.client.HAClient
logon() - Method in class com.crankuptheamps.client.HAClient
Logon - Static variable in class com.crankuptheamps.client.Message.Command
LongField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of a long value.
LongField() - Constructor for class com.crankuptheamps.client.fields.LongField

M

Match - Static variable in class com.crankuptheamps.client.Message.Reason
MAX_BOOKMARK_LENGTH - Static variable in class com.crankuptheamps.client.fields.BookmarkField
MAX_TIMESTAMP_LENGTH - Static variable in class com.crankuptheamps.client.fields.BookmarkField
MaxBacklog(int) - Static method in class com.crankuptheamps.client.Message.Options: Formats the max_backlog option for a command, used when subscribing to a queue.
maxDepth(int) - Method in class com.crankuptheamps.client.MessageStream: Sets the maximum number of messages that will be buffered in memory by this stream before taking measures to slow reads.
MaximumRetryExceeded() - Constructor for exception com.crankuptheamps.client.ExponentialDelayStrategy.MaximumRetryExceeded
MaximumRetryExceeded() - Constructor for exception com.crankuptheamps.client.FixedDelayStrategy.MaximumRetryExceeded
MemoryBookmarkStore - Class in com.crankuptheamps.client: Implements a bookmark store useful for handling server failover scenarios, but without a backing store to recover from subscriber failure.
MemoryBookmarkStore() - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore
MemoryBookmarkStore(int) - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore
MemoryBookmarkStore(int, RecoveryPointAdapter) - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore: Initialize self with a target number of subscriptions to pool and the specified recovery point adapter.
MemoryBookmarkStore(int, RecoveryPointAdapter, RecoveryPointFactory) - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore: Initialize self with a target number of subscriptions to pool and the specified recovery point adapter.
MemoryBookmarkStore.Subscription - Class in com.crankuptheamps.client: The Subscription object is used to represent internal bookmark state for the messages received and discarded on a specific subscription within the bookmark store.
MemoryPublishStore - Class in com.crankuptheamps.client: An in-memory publish store, used to provide republish capability when a server fails over.
MemoryPublishStore(int) - Constructor for class com.crankuptheamps.client.MemoryPublishStore: Construct an in-memory publish store with the specified number of blocks as the initial capacity.
MemoryStoreBuffer - Class in com.crankuptheamps.client: MemoryStoreBuffer is a wrapper for a java array that maintains position.
MemoryStoreBuffer() - Constructor for class com.crankuptheamps.client.MemoryStoreBuffer
MemorySubscriptionManager - Class in com.crankuptheamps.client: An in-memory implementation of SubscriptionManager.
MemorySubscriptionManager() - Constructor for class com.crankuptheamps.client.MemorySubscriptionManager
Message - Class in com.crankuptheamps.client: All communication with AMPS occurs through passing Messages.
Message(CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.Message
Message.AckType - Class in com.crankuptheamps.client: Container class of maskable ints that represent the available types of Message acknowledgement.
Message.Command - Class in com.crankuptheamps.client: Tells AMPS how to interpret a message.
Message.Options - Class in com.crankuptheamps.client: Represents the possible values for message options in an AMPS command.
Message.Reason - Class in com.crankuptheamps.client: Container class of ints that represent the possible values for Message reason.
Message.SerializationResult - Enum in com.crankuptheamps.client: Returned by calls to Message.serialize(ByteBuffer)
Message.Status - Class in com.crankuptheamps.client: Container class of ints that represent the possible values for Message status.
MessageHandler - Interface in com.crankuptheamps.client: Interface for all classes that handle AMPS messages.
MessageRouter - Class in com.crankuptheamps.client: MessageRouter is used to register and manage a list of handler objects for messages, as well as routing messages to those handlers as messages arrive.
MessageRouter() - Constructor for class com.crankuptheamps.client.MessageRouter
messageSeparator - Variable in class com.crankuptheamps.client.FIXMessage
messageSeparator - Variable in class com.crankuptheamps.client.FIXProtocol
MessageStream - Class in com.crankuptheamps.client: MessageStream provides an iteration abstraction over the results of an AMPS command such as a subscribe, a SOW query, or SOW delete.
MessageStream(Client) - Constructor for class com.crankuptheamps.client.MessageStream: Constructs an instance of message stream with the given client.
METADATA_LAST_DISCARDED_LOCATION - Static variable in class com.crankuptheamps.client.BlockPublishStore
METADATA_VERSION_LOCATION - Static variable in class com.crankuptheamps.client.BlockPublishStore
MIN_MULTI_BOOKMARK_VERSION - Static variable in class com.crankuptheamps.client.Client
MIN_PERSISTED_BOOKMARK_VERSION - Static variable in class com.crankuptheamps.client.Client
MIN_TIMESTAMP_LENGTH - Static variable in class com.crankuptheamps.client.fields.BookmarkField
minute - Variable in class com.crankuptheamps.client.AMPSTimestamp: Minute part of this timestamp.
month - Variable in class com.crankuptheamps.client.AMPSTimestamp: Month part of this timestamp.
MOST_RECENT - Static variable in class com.crankuptheamps.client.Client.Bookmarks: Start the subscription at the first undiscarded message in the bookmark store, or at the end of the bookmark store if all messages have been discarded.

N

NameInUse - Static variable in class com.crankuptheamps.client.Message.Reason
NameInUseException - Exception in com.crankuptheamps.client.exception: Thrown when an error occurs with the name of a client.
NameInUseException() - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
NameInUseException(String) - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
NameInUseException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
NameInUseException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
nano - Variable in class com.crankuptheamps.client.AMPSTimestamp: Nanos part of this timestamp.
needsSequenceNumber() - Method in class com.crankuptheamps.client.Command: Returns true if this command can be associated with a client sequence number.
next() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Implements Iterator.next() for a message stream.
next() - Method in class com.crankuptheamps.client.DefaultServerChooser: Advances to the next URI in the list of URIs.
next() - Method in class com.crankuptheamps.client.MessageStream: Implements Iterator.next() for a message stream.
next() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Implements Iterator.next() for a message stream.
nextIdentifier() - Static method in class com.crankuptheamps.client.CommandId: Returns the next Id for the current command.
NoDataCommands - Static variable in class com.crankuptheamps.client.Message.Command
NoEmpties - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the no_empties option.
None - Static variable in class com.crankuptheamps.client.Message.AckType
None - Static variable in class com.crankuptheamps.client.Message.Options
None - Static variable in class com.crankuptheamps.client.Message.Reason
None - Static variable in class com.crankuptheamps.client.Message.Status
NoSowKey - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the no_sow_key option.
NotEntitled - Static variable in class com.crankuptheamps.client.Message.Reason
NotEntitledException - Exception in com.crankuptheamps.client.exception: Thrown by AMPS Java Client when a user doesn't have permission to logon or use a specific topic or command.
NotEntitledException() - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
NotEntitledException(String) - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
NotEntitledException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
NotEntitledException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
NoTopic - Static variable in class com.crankuptheamps.client.Message.Reason
NOW - Static variable in class com.crankuptheamps.client.Client.Bookmarks: Start the subscription at the point in time when AMPS processes the subscription.
NVFIXBuilder - Class in com.crankuptheamps.client: Used to build up message strings for NVFIX.
NVFIXBuilder(int, byte) - Constructor for class com.crankuptheamps.client.NVFIXBuilder
NVFIXMessage - Class in com.crankuptheamps.client: A message subclass used by NVFIXProtocolParser to aid in building Message instances parsed from the NVFIXProtocol.
NVFIXMessage(byte, byte, byte, CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.NVFIXMessage
NVFIXProtocol - Class in com.crankuptheamps.client: Implements the Protocol interface.
NVFIXProtocol() - Constructor for class com.crankuptheamps.client.NVFIXProtocol
NVFIXProtocol(Properties) - Constructor for class com.crankuptheamps.client.NVFIXProtocol
NVFIXProtocol(byte, byte, byte) - Constructor for class com.crankuptheamps.client.NVFIXProtocol
NVFIXProtocolParser - Class in com.crankuptheamps.client: Implements the ProtocolParser interface and extends FIXProtocolParser class.
NVFIXProtocolParser(NVFIXProtocol) - Constructor for class com.crankuptheamps.client.NVFIXProtocolParser
NVFIXShredder - Class in com.crankuptheamps.client: A parser class that converts a NVFIX message into a Java Map.
NVFIXShredder(byte) - Constructor for class com.crankuptheamps.client.NVFIXShredder

O

offset - Variable in class com.crankuptheamps.client.BlockPublishStore.ByteSequence
OOF - Static variable in class com.crankuptheamps.client.Message.Command
OOF - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the oof (out of focus) option.
Options() - Constructor for class com.crankuptheamps.client.Message.Options
OptionsField - Class in com.crankuptheamps.client.fields: Field data for a Message which consists of options.
OptionsField(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.OptionsField
OptionsField(String) - Constructor for class com.crankuptheamps.client.fields.OptionsField
OptionsField() - Constructor for class com.crankuptheamps.client.fields.OptionsField
Other - Static variable in class com.crankuptheamps.client.Message.Reason
outgoing(ByteBuffer) - Method in class com.crankuptheamps.client.DefaultTransportFilter
outgoing(ByteBuffer) - Method in interface com.crankuptheamps.client.TransportFilter: Called when (typically just before) raw data is sent to the AMPS instance.
outgoing(ByteBuffer) - Method in class com.crankuptheamps.client.TransportTraceFilter: Method to call the print() method with the outgoing prefix for printing raw data.

P

parse(String, AMPSTimestamp) - Static method in class com.crankuptheamps.client.AMPSTimestamp: Parse an AMPS timestamp from a string.
parse(byte[], int, int, AMPSTimestamp) - Static method in class com.crankuptheamps.client.AMPSTimestamp: Parse an AMPS timestamp from a byte array.
parse(Message) - Method in class com.crankuptheamps.client.CompositeMessageParser: Parses a composite message.
parse(Field) - Method in class com.crankuptheamps.client.CompositeMessageParser: Parses a composite message's body.
Parsed - Static variable in class com.crankuptheamps.client.Message.AckType
Pause - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the pause option.
persisted(BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Deprecated.
persisted(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Deprecated.
persisted(Field, BookmarkField) - Method in interface com.crankuptheamps.client.BookmarkStore: Called internally by the Client to record the last persisted message in the transaction log of the connected AMPS server to all of its sync replication destinations.
persisted(Field, long) - Method in interface com.crankuptheamps.client.BookmarkStore: Deprecated.
use BookmarkStore.persisted(Field, BookmarkField) instead.
persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
persisted(Field, long) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
persisted(Field, long) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Deprecated.
use LoggedBookmarkStore.persisted(Field, BookmarkField) instead.
persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
persisted(Field, long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Deprecated.
use MemoryBookmarkStore.persisted(Field, BookmarkField) instead.
persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
Persisted - Static variable in class com.crankuptheamps.client.Message.AckType
persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.RingBookmarkStore: Called internally by the Client to mark the message as safely persisted by AMPS to all of its sync replication destinations.
persisted(Field, long) - Method in class com.crankuptheamps.client.RingBookmarkStore: Deprecated.
use RingBookmarkStore.persisted(Field, BookmarkField) instead.
Pool<T> - Class in com.crankuptheamps.client: A simple generic instance pool for objects that take a while to construct.
Pool(Class<T>, int) - Constructor for class com.crankuptheamps.client.Pool: Constructs a pool with the given size
position - Variable in class com.crankuptheamps.client.fields.Field
preInvoke(int) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
preInvoke(int) - Method in interface com.crankuptheamps.client.TransportDisconnectHandler: Called before invoke by the transport with a monotonically increasing "connection version" integer that is incremented upon each reconnect.
prepare(Client) - Method in class com.crankuptheamps.client.Command: Binds self to a given client, preparing a message from that client to be sent.
print(String, ByteBuffer) - Method in class com.crankuptheamps.client.TransportTraceFilter: Function to print the raw data.
process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.FIXProtocolParser
process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.JSONProtocolParser
process(ByteBuffer, int, MessageHandler) - Method in interface com.crankuptheamps.client.ProtocolParser: Processes a region of a byte buffer into messages of a specific protocol and then invokes the specified message handler for each message parsed from the bytes.
process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.XMLProtocolParser
Processed - Static variable in class com.crankuptheamps.client.Message.AckType
Projection(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the projection option for an aggregated subscription, which specifies the fields produced by the aggregation.
Projection(Iterable<String>) - Static method in class com.crankuptheamps.client.Message.Options: Formats the projection option for an aggregated subscription, which specifies the fields produced by the aggregation.
Protocol - Interface in com.crankuptheamps.client: Interface representing an AMPS wire protocol.
ProtocolException - Exception in com.crankuptheamps.client.exception: Thrown when an error occurs with a Protocol specified by the user.
ProtocolException() - Constructor for exception com.crankuptheamps.client.exception.ProtocolException
ProtocolException(String) - Constructor for exception com.crankuptheamps.client.exception.ProtocolException
ProtocolException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.ProtocolException
ProtocolException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.ProtocolException
ProtocolFactory - Class in com.crankuptheamps.client: Class which creates Protocols as well as registering and unregistering them from a Java Map.
ProtocolFactory() - Constructor for class com.crankuptheamps.client.ProtocolFactory
ProtocolNotFoundException - Exception in com.crankuptheamps.client.exception: Thrown when a protocol type could not be found.
ProtocolNotFoundException() - Constructor for exception com.crankuptheamps.client.exception.ProtocolNotFoundException
ProtocolNotFoundException(String) - Constructor for exception com.crankuptheamps.client.exception.ProtocolNotFoundException
ProtocolNotFoundException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.ProtocolNotFoundException
ProtocolNotFoundException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.ProtocolNotFoundException
ProtocolParser - Interface in com.crankuptheamps.client: Interface that parses an AMPS wire transport protocol.
prune() - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Remove outdated entries in the bookmark store.
prune(String) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Remove outdated entries in the bookmark store.
publish(byte[], int, int, byte[], int, int) - Method in class com.crankuptheamps.client.Client: Publish a message to an AMPS topic.
publish(String, String) - Method in class com.crankuptheamps.client.Client: Publish a message to an AMPS topic.
publish(byte[], int, int, byte[], int, int, int) - Method in class com.crankuptheamps.client.Client: Publish a message to an AMPS topic.
publish(String, String, int) - Method in class com.crankuptheamps.client.Client: Publish a message to an AMPS topic.
Publish - Static variable in class com.crankuptheamps.client.Message.Command
publishFlush() - Method in class com.crankuptheamps.client.Client: Ensures that AMPS messages are sent and have been processed by the AMPS server.
publishFlush(long) - Method in class com.crankuptheamps.client.Client: Ensures that AMPS messages are sent and have been processed by the AMPS server.
PublishReplayed - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client completes replay of messages saved in its publish store after logon.
PublishStore - Class in com.crankuptheamps.client: PublishStore is a memory-mapped file-backed store for storing outgoing messages.
PublishStore(String) - Constructor for class com.crankuptheamps.client.PublishStore: Creates a new PublishStore with the given path.
PublishStore(String, int) - Constructor for class com.crankuptheamps.client.PublishStore: Creates a new PublishStore with the given path.
PublishStoreResizeHandler - Interface in com.crankuptheamps.client: Interface used to indicate whether a Store implementation is allowed to grow (or shrink) to the requested size.
purge() - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to purge the contents of this store.
purge(Field) - Method in interface com.crankuptheamps.client.BookmarkStore: Call this when you want to purge the contents of this store for a given subscription ID.
purge() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Remove all recovery point information from self and adapter.
purge(Field) - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Remove all recovery point information for subId from self and adapter.
purge() - Method in class com.crankuptheamps.client.DefaultBookmarkStore
purge(Field) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
purge() - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Remove all entries in the bookmark store, completely clearing all record of messages received and discarded.
purge(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Remove all entries in the bookmark store for a subId.
purge() - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Remove all entries in the bookmark store, completely clearing all record of messages received and discarded.
purge(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
purge(Field) - Method in interface com.crankuptheamps.client.RecoveryPointAdapter: This method is called by the associated bookmark store's purge(subId) method (with the bookmark store lock held) with the expectation that the adapter will delete any recover point data stored for the specified subscription id.
purge() - Method in interface com.crankuptheamps.client.RecoveryPointAdapter: This method is called by the associated bookmark store's purge() method (with the bookmark store lock held) with the expectation that the adapter will delete all recover point data stored for all subscriptions known to this adapter.
purge() - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to purge the contents of this store.
purge(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to purge the contents of this store for a given Subscription Id.
purge() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Purge all recovery information stored in the SOW.
purge(Field) - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Purge all recovery information stored in the SOW.
putByte(byte) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Writes the byte into the buffer.
putByte(byte) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putByte(byte) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes the byte in the buffer.
putBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Writes a series of bytes at the current position, taken from the specified BlockPublishStore.ByteSequence.
putBytes(byte[], long, long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Writes a series of bytes at the current position, taken from a byte array.
putBytes(BlockPublishStore.ByteSequence) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putBytes(byte[], long, long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes a series of bytes at the current positon, taken from the specified BlockPublishStore.ByteSequence.
putBytes(byte[], long, long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes a series of bytes at the current position, taken from a byte array.
putInt(int) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Writes the integer into the buffer.
putInt(long, int) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Puts the integer into the buffer.
putInt(int) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putInt(long, int) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putInt(int) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes the integer into the buffer.
putInt(long, int) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes the integer into the buffer.
putLong(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Writes the long into the buffer.
putLong(long, long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Writes the long into the buffer.
putLong(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putLong(long, long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
putLong(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes the long to the buffer.
putLong(long, long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Writes the long to the buffer.

R

Rate(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the rate option for a command, used to slow down the rate of a bookmark replay.
RateMaxGap(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the rate_max_gap option for a command, which can be used when a bookmark replay specifies a relative rate.
readQueueSize() - Method in class com.crankuptheamps.client.TCPTransport
readQueueSize() - Method in class com.crankuptheamps.client.TCPTransportImpl
readQueueSize() - Method in interface com.crankuptheamps.client.Transport
Reason() - Constructor for class com.crankuptheamps.client.Message.Reason
ReasonField - Class in com.crankuptheamps.client.fields: Field data for a Message consisting of a reason.
ReasonField() - Constructor for class com.crankuptheamps.client.fields.ReasonField
Received - Static variable in class com.crankuptheamps.client.Message.AckType
ReconnectDelayStrategy - Interface in com.crankuptheamps.client: ReconnectDelayStrategy implementations are called by HAClient to determine how long to wait between attempts to connect or reconnect to a server.
recover() - Method in class com.crankuptheamps.client.BlockPublishStore
RecoveryPoint - Interface in com.crankuptheamps.client: Interface used by RecoveryPointAdapter's to represent a bookmark subscription's recovery state, to allow that subscription to be resumed in a reasonable place when the subscriber application exits and restarts.
RecoveryPointAdapter - Interface in com.crankuptheamps.client: An instance of this interface that can optionally be provided to MemoryBookmarkStore when it's constructed to persist recovery bookmark state for each bookmark replay subscription.
RecoveryPointFactory - Interface in com.crankuptheamps.client
register(String, String) - Static method in class com.crankuptheamps.client.ProtocolFactory: Method to register the name of the message and the message type.
register(String, String) - Static method in class com.crankuptheamps.client.TransportFactory: Registers a new Transport and URI prefix with the AMPS Client.
RELEASE_VERSION - Static variable in class com.crankuptheamps.client.ClientVersion: The release version number of this AMPS client build.
relog(long, BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Deprecated.
remove() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Operation not supported.
remove() - Method in class com.crankuptheamps.client.MessageStream: Operation not supported.
remove() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Operation not supported.
removeConnectionStateListener(ConnectionStateListener) - Method in class com.crankuptheamps.client.Client: Removes a ConnectionStateListener from being invoked when this client connects or disconnects.
removeMessageHandler(CommandId) - Method in class com.crankuptheamps.client.Client: Remove a MessageHandler for a given CommandId from self.
removeRoute(CommandId) - Method in class com.crankuptheamps.client.MessageRouter: Remove a route from self.
Replace - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the replace option.
replaceStart(Field) - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
replaceStart(Field, boolean) - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
replay(Store.StoreReplayer) - Method in class com.crankuptheamps.client.BlockPublishStore
replay(Store.StoreReplayer) - Method in class com.crankuptheamps.client.HybridPublishStore
replay(Store.StoreReplayer) - Method in interface com.crankuptheamps.client.Store: Replay all operations in the store using the provided StoreReplayer.
replaySingle(Store.StoreReplayer, long) - Method in class com.crankuptheamps.client.BlockPublishStore
replaySingle(Store.StoreReplayer, long) - Method in class com.crankuptheamps.client.HybridPublishStore
replaySingle(Store.StoreReplayer, long) - Method in interface com.crankuptheamps.client.Store: Replay the operation at the specified index.
reportFailure(Exception, ConnectionInfo) - Method in class com.crankuptheamps.client.DefaultServerChooser: Called by HAClient when an error occurs connecting to the current URI, and/or when an error occurs logging on.
reportFailure(Exception, ConnectionInfo) - Method in interface com.crankuptheamps.client.ServerChooser: Called by the HAClient when an error occurs connecting to the current URI, and/or when an error occurs logging on.
reportSuccess(ConnectionInfo) - Method in class com.crankuptheamps.client.DefaultServerChooser: Report success is not used in this implementation.
reportSuccess(ConnectionInfo) - Method in interface com.crankuptheamps.client.ServerChooser: Called by the HAClient when successfully connected and logged on to the current instance.
reset() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Resets this bookmark ring buffer for reuse by clearing out its state.
reset(int) - Method in class com.crankuptheamps.client.Command: Resets this command with a new Command type and re-initializes all other fields.
reset(String) - Method in class com.crankuptheamps.client.Command: Resets this command with a new Command type and re-initializes all other fields.
reset() - Method in class com.crankuptheamps.client.ExponentialDelayStrategy
reset() - Method in class com.crankuptheamps.client.fields.Field: Resets the value of this instance to null.
reset() - Method in class com.crankuptheamps.client.FixedDelayStrategy: Resets the state of this delay.
reset() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription: Reset the state of this subscription object such that it can be returned to the pool for reuse.
reset() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription: Reset the state of this subscription object such that it can be returned to the pool for reuse.
reset() - Method in class com.crankuptheamps.client.Message: Resets all Field members to null.
reset() - Method in interface com.crankuptheamps.client.ReconnectDelayStrategy: Reset the state of this reconnect delay.
reset() - Static method in class com.crankuptheamps.client.TransportFactory: Resets self to the default state, unregistering any Transports registered at runtime.
resubscribe(Client) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
resubscribe(Client) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
resubscribe(Client) - Method in interface com.crankuptheamps.client.SubscriptionManager: Resubscribes to a subscription.
Resubscribed - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client has completed resubscribe from the subscription manager.
Resume - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the resume option.
retry(String, String) - Method in interface com.crankuptheamps.client.Authenticator: Called when a logon "ack" is received with a status of "retry".
retry(String, String) - Method in class com.crankuptheamps.client.DefaultAuthenticator: Called when a logon "ack" is received with a status of "retry".
Retry - Static variable in class com.crankuptheamps.client.Message.Status
RetryOperationException - Exception in com.crankuptheamps.client.exception: Thrown when an operation needs to be reattempted.
RetryOperationException() - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
RetryOperationException(String) - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
RetryOperationException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
RetryOperationException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
returnToPool(T) - Method in class com.crankuptheamps.client.Pool: Return an object to the pool.
RingBookmarkStore - Class in com.crankuptheamps.client: RingBookmarkStore is an implementation of BookmarkStore that stores state on disk and in memory.
RingBookmarkStore(String) - Constructor for class com.crankuptheamps.client.RingBookmarkStore
RingBookmarkStore(String, int) - Constructor for class com.crankuptheamps.client.RingBookmarkStore
RingBookmarkStore.Subscription - Class in com.crankuptheamps.client: The Subscription object is used to represent internal bookmark state for the messages received and discarded on a specific subscription within the bookmark store.
run() - Method in interface com.crankuptheamps.client.AMPSRunnable: Implement this to perform the work of your idle transport task.
run() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter.UpdateThread: Entry point for the runnable.
runQuery() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Set up the MessageStream for recovery.
runUpdateAll() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter

S

second - Variable in class com.crankuptheamps.client.AMPSTimestamp: Seconds part of this timestamp.
Select(String) - Static method in class com.crankuptheamps.client.Message.Options: Formats the select option for a subscription or SOW query, which specifies the fields produced in the delivered messages.
Select(Iterable<String>) - Static method in class com.crankuptheamps.client.Message.Options: Formats the select option for a subscription or SOW query, which specifies the fields produced in the delivered messages.
send(Message) - Method in class com.crankuptheamps.client.Client: Send a Message to AMPS via the Transport used in the Client.
send(MessageHandler, Message, long) - Method in class com.crankuptheamps.client.Client: Send a Message to AMPS and register the messageHandler for any messages resulting from the command execution.
send(Message) - Method in class com.crankuptheamps.client.TCPTransport
send(ByteBuffer) - Method in class com.crankuptheamps.client.TCPTransportImpl
send(Message) - Method in interface com.crankuptheamps.client.Transport
SendKeys - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the send_keys option.
sendWithoutRetry(Message) - Method in class com.crankuptheamps.client.TCPTransport
sendWithoutRetry(Message) - Method in interface com.crankuptheamps.client.Transport
SEPARATOR_CHAR - Static variable in class com.crankuptheamps.client.fields.BookmarkField: The character used to separate components of a bookmark, and to separate bookmarks from each other in a list.
SerializableFunction<T,R> - Interface in com.crankuptheamps.client.util: This generic utility interface has been added to the AMPS client to better support interoperability with other AMPS components and third-party software.
serialize(ByteBuffer) - Method in class com.crankuptheamps.client.FIXMessage
serialize(ByteBuffer) - Method in class com.crankuptheamps.client.JSONMessage
serialize(ByteBuffer) - Method in class com.crankuptheamps.client.Message: Serializes this message into the provided byte buffer at its current position.
serialize(RecoveryPoint) - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Serializes a RecoveryPoint to JSON in the internal buffer for publishing to a JSON SOW topic.
serialize(ByteBuffer) - Method in class com.crankuptheamps.client.XMLMessage: Serializes the XML message properties.
ServerChooser - Interface in com.crankuptheamps.client: Interface for choosing amongst multiple instances for both initial connection and reconnection.
set(byte[], int, int) - Method in class com.crankuptheamps.client.CommandId: Sets the CommandId for the AMPS command.
set(byte[], int, int) - Method in class com.crankuptheamps.client.fields.Field: Sets the value of this instance with the specified region of a byte buffer.
set(byte[]) - Method in class com.crankuptheamps.client.fields.Field: Sets the value of this instance with the specified buffer.
set(String) - Method in class com.crankuptheamps.client.HashBox
set(byte[], int, int) - Method in class com.crankuptheamps.client.HashBox
set(int) - Method in class com.crankuptheamps.client.HashBox
setAckBatchSize(int) - Method in class com.crankuptheamps.client.Client: Sets the current ACK batch size.
setAcksOnly(CommandId, int) - Method in class com.crankuptheamps.client.MessageStream: Changes the current state of the message stream to MessageStream.STATE_AcksOnly.
setAckTimeout(long) - Method in class com.crankuptheamps.client.Client: Sets the ack timeout -- the maximum time to let a success ack be cached before sending.
setAckType(int) - Method in class com.crankuptheamps.client.Command: Set the ackType for this command.
setAckType(int) - Method in class com.crankuptheamps.client.Message: Sets the type of acknowledgement for an acknowledgement Message.
setAckType(String) - Method in class com.crankuptheamps.client.Message: Sets the type of acknowledgement for an acknowledgement Message.
setActive(boolean) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Sets the active value of the Entry.
setAutoAck(boolean) - Method in class com.crankuptheamps.client.Client: Enables or disables auto-acking.
setBackoffExponent(double) - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: Sets the exponent to use for calculating the next delay time.
setBatchSize(int) - Method in class com.crankuptheamps.client.Command: Set the batchSize for this command.
setBatchSize(int) - Method in class com.crankuptheamps.client.Message: Sets the BatchSize for this Message.
setBookmark(Field) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Sets the bookmark field of the Entry.
setBookmark(String) - Method in class com.crankuptheamps.client.Command: Set the bookmark for this command.
setBookmark(String) - Method in class com.crankuptheamps.client.Message: Sets the value for the AMPS Bookmark.
setBookmark(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the value for the AMPS Bookmark.
setBookmarkSeqNo(long) - Method in class com.crankuptheamps.client.Message: Sets the bookmark sequence number for this Message.
setBookmarkStore(BookmarkStore) - Method in class com.crankuptheamps.client.Client: Sets the underlying bookmark store, which is used to track which messages the client has received and which messages have been processed by the program.
setBuffer(byte[]) - Method in class com.crankuptheamps.client.Message: Sets the byte buffer used for this Message.
setClientName(String) - Method in class com.crankuptheamps.client.Message: Sets the name of the Client sending the Message.
setClientName(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the name of the Client sending the Message.
setClientSequenceNumber(long) - Method in class com.crankuptheamps.client.Command: Sets the client sequence number for this command.
setCommand(int) - Method in class com.crankuptheamps.client.Command: Set the command type for this command.
setCommand(int) - Method in class com.crankuptheamps.client.Message: Sets the Command for this Message, indicating the type of of Message this is.
setCommand(String) - Method in class com.crankuptheamps.client.Message: Sets the Command for this Message, indicating the type of of Message this is.
setCommandId(CommandId) - Method in class com.crankuptheamps.client.Command: Set the commandId for this command.
setCommandId(String) - Method in class com.crankuptheamps.client.Message: Sets the CommandId on this Message.
setCommandId(CommandId) - Method in class com.crankuptheamps.client.Message: Sets the CommandId on this Message.
setCommandId(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the CommandId on this Message.
setConnectTimeout(int) - Method in class com.crankuptheamps.client.TCPTransportImpl
setCorrelationId(String) - Method in class com.crankuptheamps.client.Command: Sets the correlation Id for this command.
setCorrelationId(String) - Method in class com.crankuptheamps.client.Message: Set the CorrelationId on this message.
setDaemon(boolean) - Static method in class com.crankuptheamps.client.TCPTransport
setData(String) - Method in class com.crankuptheamps.client.Command: Set the data for this command.
setData(byte[], int, int) - Method in class com.crankuptheamps.client.Command: Set the data for this command.
setData(CompositeMessageBuilder) - Method in class com.crankuptheamps.client.Command: Set the data for this command.
setData(String) - Method in class com.crankuptheamps.client.Message: Sets the payload of the Message.
setData(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the payload of the Message.
setDefaultConnectTimeout(int) - Static method in class com.crankuptheamps.client.TCPTransport: Returns the default connect timeout used for new connections.
setDefaultEnabledCipherSuites(String[]) - Static method in class com.crankuptheamps.client.TCPSTransport: Sets the cipher suites that will be enabled on SSLSockets.
setDefaultEnabledProtocols(String[]) - Static method in class com.crankuptheamps.client.TCPSTransport: Sets the protocols that will be enabled on SSLSockets.
setDefaultMaxDepth(int) - Method in class com.crankuptheamps.client.Client: Sets the default value used for the max depth of MessageStream instances created by this client.
setDefaultReadTimeout(int) - Static method in class com.crankuptheamps.client.TCPTransport: Sets the default read timeout used for socket reads.
setDefaultResubscriptionTimeout(long) - Static method in class com.crankuptheamps.client.MemorySubscriptionManager: Sets the Default Resubscription Timeout for all instances of this class in milliseconds.
setDefaultSSLContext(SSLContext) - Static method in class com.crankuptheamps.client.TCPSTransport: Sets the default SSL Context used for new connections.
setDisconnectHandler(ClientDisconnectHandler) - Method in class com.crankuptheamps.client.Client: Sets the ClientDisconnectHandler.
setDisconnectHandler(TransportDisconnectHandler) - Method in class com.crankuptheamps.client.TCPTransport
setDisconnectHandler(TransportDisconnectHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
setDisconnectHandler(TransportDisconnectHandler) - Method in interface com.crankuptheamps.client.Transport
setDuplicateMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client: Sets the MessageHandler instance used for duplicate messages.
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.Client: Sets the ExceptionListener instance used for communicating absorbed exceptions.
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Sets the ExceptionListener instance used for communicating absorbed exceptions.
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Sets the ExceptionListener instance used for communicating absorbed exceptions.
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.TCPTransport
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.TCPTransportImpl
setExceptionListener(ExceptionListener) - Method in interface com.crankuptheamps.client.Transport
setExpiration(int) - Method in class com.crankuptheamps.client.Command: Set the expiration for this command.
setExpiration(int) - Method in class com.crankuptheamps.client.Message: Sets the Expiration field for this Message.
setFailedWriteHandler(FailedWriteHandlerV4) - Method in class com.crankuptheamps.client.Client: Sets the FailedWriteHandler instance used to report on failed messages that have been written.
setFailedWriteHandler(FailedWriteHandler) - Method in class com.crankuptheamps.client.Client: Sets the FailedWriteHandler instance used to report on failed messages that have been written.
setField(Field) - Method in class com.crankuptheamps.client.CompositeMessageBuilder: Sets a Field with the contents of this object.
setFilter(String) - Method in class com.crankuptheamps.client.Command: Set the filter for this command.
setFilter(String) - Method in class com.crankuptheamps.client.Message: Sets the Filter field on this Message.
setFilter(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the Filter field on this Message.
setGlobalCommandTypeMessageHandler(String, MessageHandler) - Method in class com.crankuptheamps.client.Client: Sets the MessageHandler instance used for all messages of the given command type.
setGlobalCommandTypeMessageHandler(int, MessageHandler) - Method in class com.crankuptheamps.client.Client: Sets the MessageHandler instance used for all messages of the given command type.
setGlobalCommandTypeMessageHandler(Client.GlobalCommandTypeHandlers, MessageHandler) - Method in class com.crankuptheamps.client.Client: Sets the MessageHandler instance used for all messages of the given command type.
setGroupSeqNo(long) - Method in class com.crankuptheamps.client.Message: Set the group sequence number.
setHeartbeat(int, int) - Method in class com.crankuptheamps.client.Client: Requests a server heartbeat, and configures the client to close the connection if a heartbeat (or other activity) is not seen on the connection.
setHeartbeat(int) - Method in class com.crankuptheamps.client.Client: Requests a server heartbeat, and configures the client to close the connection if a heartbeat (or other activity) is not seen on the connection after two heartbeat intervals.
setIdleRunnable(AMPSRunnable) - Method in class com.crankuptheamps.client.TCPTransport
setIdleRunnable(AMPSRunnable) - Method in class com.crankuptheamps.client.TCPTransportImpl
setIdleRunnable(AMPSRunnable) - Method in interface com.crankuptheamps.client.Transport: Sets a AMPSRunnable that is invoked during idle-time processing for this connection.
setIgnoreAutoAck() - Method in class com.crankuptheamps.client.Message: Used to disable automatic acking of this Message by the Client after the MessageHandler completes.
setIndex(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Sets the index of the Entry in the Entry array.
setInitialDelay(int) - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: Sets the time (in milliseconds) to wait before reconnecting to a server for the first time after a failed connection.
setJitter(double) - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: Sets the jitter factor used to add randomness to the delay time.
setLastChanceMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client: Sets the MessageHandler instance used when no other handler matches.
setLastPersisted(long) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription: Deprecated.
use LoggedBookmarkStore.Subscription.setLastPersisted(BookmarkField) instead.
setLastPersisted(BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
setLastPersisted(long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription: Deprecated.
use MemoryBookmarkStore.Subscription.setLastPersisted(BookmarkField) instead.
setLastPersisted(BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
setLastPersisted(long) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription: Deprecated.
setLastPersisted(BookmarkField) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
setLastPersisted(long) - Method in interface com.crankuptheamps.client.Subscription: Deprecated.
setLastPersisted(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
setLength(int) - Method in class com.crankuptheamps.client.Message: Sets the Length of the Message.
setLogonCorrelationData(String) - Method in class com.crankuptheamps.client.Client: Sets the uninterpreted logon correlation information a client sends at logon to aid in searching server log files for specific clients.
setLogonOptions(String) - Method in class com.crankuptheamps.client.HAClient: Sets a logon options string for self.
setLowWatermark(int) - Method in class com.crankuptheamps.client.HybridPublishStore: Sets the low watermark; once we start swapping out to disk, we keep going until the number of entries in memory is lower than this.
setMatches(long) - Method in class com.crankuptheamps.client.Message: Sets the matches field on this Message.
setMaximumDelay(int) - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: Sets the maximum time to wait between any reconnection attempts.
setMaximumRetryTime(int) - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: Sets the time (in millseconds) to allow reconnect attempts to continue without a successful connection, before "giving up" and abandoning the connection attempt.
setMessage(Message) - Method in class com.crankuptheamps.client.BlockPublishStore
setMessage(Message) - Method in class com.crankuptheamps.client.HybridPublishStore
setMessage(Message) - Method in interface com.crankuptheamps.client.Store: Provide the Store with a preallocated Message for use in replay.
setMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.TCPTransport
setMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
setMessageHandler(MessageHandler) - Method in interface com.crankuptheamps.client.Transport
setMessageType(String) - Method in class com.crankuptheamps.client.Message: Sets the MessageType on this client.
setOptions(String) - Method in class com.crankuptheamps.client.Command: Set the options for this command.
setOptions(String) - Method in class com.crankuptheamps.client.Message: Sets the Options for the Message.
setOrderBy(String) - Method in class com.crankuptheamps.client.Command: Set the orderBy clause for this command.
setOrderBy(String) - Method in class com.crankuptheamps.client.Message: Set the OrderBy parameter for this Message.
setOrderBy(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Set the OrderBy parameter for this Message.
setPassword(String) - Method in class com.crankuptheamps.client.Message: Set the Password on the Message.
setPassword(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Set the Password on the Message.
setPersisted(boolean) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Deprecated.
setPosition(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Sets the current position in the buffer.
setPosition(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
setPosition(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Sets the new current position in the buffer.
setPublishersToDiscarded(List<BookmarkRingBuffer.Entry>, Map<Long, Long>) - Static method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
setPublishStore(Store) - Method in class com.crankuptheamps.client.Client: Sets the underlying publish store, which is used to store published messages until the AMPS instance has acknowledged those messages.
setQueryId(CommandId) - Method in class com.crankuptheamps.client.Command: Set the queryId for this command.
setQueryId(String) - Method in class com.crankuptheamps.client.Message: Sets the QueryId field for this Message.
setQueryId(CommandId) - Method in class com.crankuptheamps.client.Message: Sets the QueryId field for this Message by copying it from a CommandId object.
setQueryId(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the QueryId for this Message.
setQueryId(CommandId) - Method in class com.crankuptheamps.client.MessageStream: When this message stream is the result of a SOW command, this gets called with the query ID of the command.
setRawBufferLength(int) - Method in class com.crankuptheamps.client.Message: Sets the length of the Message within the byte buffer.
setRawBufferOffset(int) - Method in class com.crankuptheamps.client.Message: Sets the Offset into the byte buffer where this Message begins.
setReadTimeout(int) - Method in class com.crankuptheamps.client.TCPTransport
setReadTimeout(int) - Method in class com.crankuptheamps.client.TCPTransportImpl
setReadTimeout(int) - Method in interface com.crankuptheamps.client.Transport
setReason(int) - Method in class com.crankuptheamps.client.Message: Sets the Reason value of this Message.
setReconnectDelay(int) - Method in class com.crankuptheamps.client.HAClient: Sets the time delay between reconnect events.
setReconnectDelayStrategy(ReconnectDelayStrategy) - Method in class com.crankuptheamps.client.HAClient: Sets the ReconnectDelayStrategy used to control sleeping behavior before connecting to a server.
setRecordsDeleted(long) - Method in class com.crankuptheamps.client.Message: Sets the records deleted header field.
setRecordsInserted(long) - Method in class com.crankuptheamps.client.Message: Returns the number of records inserted for the command that this Message was produced in response to.
setRecordsReturned(long) - Method in class com.crankuptheamps.client.Message: Sets the records returned header field.
setRecordsUpdated(long) - Method in class com.crankuptheamps.client.Message: Sets the records updated header field.
setRecovery() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Deprecated.
setRecoveryPointFactory(RecoveryPointFactory) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Change the RecoveryPointFactory used by this store for its adapter.
setRecoveryPointFactory(RecoveryPointFactory) - Method in class com.crankuptheamps.client.MemoryBookmarkStore: Change the RecoveryPointFactory used by this store for its adapter.
setRecoveryTimestamp(String) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
setRecoveryTimestamp(String) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
setResizeHandler(PublishStoreResizeHandler) - Method in class com.crankuptheamps.client.BlockPublishStore
setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Call this when you want to set a resize handler that is invoked when a store needs a resize.
setResizeHandler(BookmarkStoreResizeHandler) - Method in interface com.crankuptheamps.client.BookmarkStore: Called this when you want to set a resize handler that is invoked when the store needs to resize.
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
setResizeHandler(PublishStoreResizeHandler) - Method in class com.crankuptheamps.client.HybridPublishStore
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.RingBookmarkStore: Call this when you want to set a resize handler that is invoked when the store needs to resize.
setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
setResizeHandler(PublishStoreResizeHandler) - Method in interface com.crankuptheamps.client.Store: Set the resize handler for the publish store.
setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in interface com.crankuptheamps.client.Subscription
setResubscriptionTimeout(long) - Method in class com.crankuptheamps.client.MemorySubscriptionManager: Sets the Resubscription timeout in milliseconds.
setRetryOnDisconnect(boolean) - Method in class com.crankuptheamps.client.Client: Set whether or not messages being sent to the server should retry if the client is disconnected.
setRunning() - Method in class com.crankuptheamps.client.MessageStream: Changes the current state of the message stream to MessageStream.STATE_Reading.
setSequence(long) - Method in class com.crankuptheamps.client.Message: Sets the sequence number for this Message.
setServerChooser(ServerChooser) - Method in class com.crankuptheamps.client.HAClient: Sets a ServerChooser for self.
setServerVersion(int) - Method in interface com.crankuptheamps.client.BookmarkStore: Called internally by the Client when connected to an AMPS server to indicate what version the server is.
setServerVersion(int) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
setServerVersion(int) - Method in class com.crankuptheamps.client.LoggedBookmarkStore: Used to change the version of the AMPS server that this bookmark store's client has connected to.
setServerVersion(int) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
setServerVersion(int) - Method in class com.crankuptheamps.client.RingBookmarkStore: Called internally by the Client when connected to an AMPS server to indicate what version the server is.
setSize(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Sets the size of the back buffer.
setSize(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
setSize(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Sets the size of the buffer.
setSOWKey(String) - Method in class com.crankuptheamps.client.Command: Deprecated.
Use setSowKey() instead.
setSowKey(String) - Method in class com.crankuptheamps.client.Command: The SowKey for a command is used to publish to a SOW topic with explicit keys set by the user rather than AMPS.
setSowKey(String) - Method in class com.crankuptheamps.client.Message: Sets the SowKey for this Message.
setSowKey(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the SowKey for this Message.
setSowKeys(String) - Method in class com.crankuptheamps.client.Command: The SowKeys for a command are a comma-separated list of the keys that AMPS assigns to SOW messages.
setSOWKeys(String) - Method in class com.crankuptheamps.client.Command: Deprecated.
Use setSowKeys() instead.
setSowKeys(String) - Method in class com.crankuptheamps.client.Message: Sets the set of SowKeys this message applies to, as a comma-delimited list of identifiers.
setSowKeys(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the set of SowKeys this message applies to, as a comma-delimited list of identifiers.
setSOWOnly() - Method in class com.crankuptheamps.client.MessageStream: Changes the current state of the message stream to MessageStream.STATE_SOWOnly.
setStatsOnly() - Method in class com.crankuptheamps.client.MessageStream: Changes the current state of the message stream to MessageStream.STATE_StatsOnly.
setStatus(int) - Method in class com.crankuptheamps.client.Message: Sets the Status of this Message.
setSubId(Field) - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Sets the Subscription Identifier for the bookmark.
setSubId(CommandId) - Method in class com.crankuptheamps.client.Command: Set the subId for this command.
setSubId(String) - Method in class com.crankuptheamps.client.Command: Set the subId for this command.
setSubId(String) - Method in class com.crankuptheamps.client.Message: Sets the SubId of this Message.
setSubId(CommandId) - Method in class com.crankuptheamps.client.Message: Sets the SubId of this Message by copying it from a CommandId object.
setSubId(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the SubId of this Message.
setSubIds(String) - Method in class com.crankuptheamps.client.Message: The set of SubIds for this message.
setSubIds(byte[], int, int) - Method in class com.crankuptheamps.client.Message: The set of SubIds for this message.
setSubscription(Subscription) - Method in class com.crankuptheamps.client.Message: Sets the Subscription for this Message.
setSubscription(CommandId) - Method in class com.crankuptheamps.client.MessageStream: When this message stream is the result of a subscription command, this gets called with the subscription ID.
setSubscriptionManager(SubscriptionManager) - Method in class com.crankuptheamps.client.Client: Sets the SubscriptionManager instance used for recording active subscriptions.
setThreadCreatedHandler(ThreadCreatedHandler) - Method in class com.crankuptheamps.client.Client: Set a handler that is invoked immediately by any thread created by the transport.
setThreadCreatedHandler(ThreadCreatedHandler) - Method in class com.crankuptheamps.client.TCPTransport
setThreadCreatedHandler(ThreadCreatedHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
setThreadCreatedHandler(ThreadCreatedHandler) - Method in interface com.crankuptheamps.client.Transport
setTimeout(long) - Method in class com.crankuptheamps.client.Command: Set the timeout for this command (in milliseconds).
setTimeout(int) - Method in class com.crankuptheamps.client.HAClient: Sets the timeout used for logging on and resubscribing, once a connection is re-established.
setTimestamp(String) - Method in class com.crankuptheamps.client.Message: Sets the Timestamp for this Message.
setTimestamp(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the timestamp for this message.
setTopic(String) - Method in class com.crankuptheamps.client.Command: Set the topic for this command.
setTopic(byte[], int, int) - Method in class com.crankuptheamps.client.Command: Set the topic for this command from raw bytes.
setTopic(String) - Method in class com.crankuptheamps.client.Message: Set the topic that the message applies to.
setTopic(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Set the topic that the message applies to.
setTopicMatches(long) - Method in class com.crankuptheamps.client.Message: Sets the topic matches field on this message.
setTopN(int) - Method in class com.crankuptheamps.client.Command: Set the topN value for this command.
setTopN(long) - Method in class com.crankuptheamps.client.Message: Set the TopN parameter for this message.
setTransportFilter(TransportFilter) - Method in class com.crankuptheamps.client.Client: Set a filter that is used by the Client's transport for all incoming and outgoing messages.
setTransportFilter(TransportFilter) - Method in class com.crankuptheamps.client.TCPTransport
setTransportFilter(TransportFilter) - Method in class com.crankuptheamps.client.TCPTransportImpl
setTransportFilter(TransportFilter) - Method in interface com.crankuptheamps.client.Transport: Sets a TransportFilter that filters raw bytes before send and after receive.
setUnhandledMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client: Deprecated.
Use Client.setLastChanceMessageHandler(com.crankuptheamps.client.MessageHandler) instead.
setUserId(String) - Method in class com.crankuptheamps.client.Message: Set the UserId for this message.
setUserId(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Set the UserId for this message.
setValue(int) - Method in class com.crankuptheamps.client.fields.AckTypeField: This method sets the value of the AckType to an integer according to the action that has been performed on the AckType.
setValue(boolean) - Method in class com.crankuptheamps.client.fields.BooleanField: Sets the value of the boolean field.
setValue(int) - Method in class com.crankuptheamps.client.fields.CommandField: This method sets the value of the Command.
setValue(int) - Method in class com.crankuptheamps.client.fields.IntegerField: Sets the value of this integer field using the specified Java 32-bit signed intger.
setValue(long) - Method in class com.crankuptheamps.client.fields.LongField: Sets the value of this long field using the specified Java 64-bit signed integer.
setValue(byte[], int, int) - Method in class com.crankuptheamps.client.fields.OptionsField
setValue(String, CharsetEncoder) - Method in class com.crankuptheamps.client.fields.OptionsField
setValue(int) - Method in class com.crankuptheamps.client.fields.ReasonField: Sets the value of this reason field using the specified reason code integer.
setValue(int) - Method in class com.crankuptheamps.client.fields.StatusField: Sets the value of this status field using the specified status code integer.
setValue(byte[], int, int) - Method in class com.crankuptheamps.client.fields.StringField: Sets the value of this instance with the specified region of a byte buffer.
setValue(CommandId) - Method in class com.crankuptheamps.client.fields.StringField: Sets the value of this instance with the specified buffer from the command ID object.
setValue(String, CharsetEncoder) - Method in class com.crankuptheamps.client.fields.StringField: Sets the value of this instance from the specified string.
setVersion(String) - Method in class com.crankuptheamps.client.Message: Sets the version field of this message.
setVersion(byte[], int, int) - Method in class com.crankuptheamps.client.Message: Sets the version field of this message.
setVersionString(String) - Method in class com.crankuptheamps.client.VersionInfo
Shutdown - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant passed when the client disconnects and won't reconnect.
SkipN(int) - Static method in class com.crankuptheamps.client.Message.Options: Formats the skip_n option for a sow or sow_and_subscribe command.
socket() - Method in class com.crankuptheamps.client.TCPTransport
socket() - Method in class com.crankuptheamps.client.TCPTransportImpl
sow(String, String) - Method in class com.crankuptheamps.client.Client: Synchronously execute a SOW query.
sow(String) - Method in class com.crankuptheamps.client.Client: Synchronously execute a SOW query.
sow(MessageHandler, String, String, String, String, int, int, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query.
sow(MessageHandler, String, String, int, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query.
sow(MessageHandler, String, String, int, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query.
sow(MessageHandler, String, int, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query.
sow(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query.
SOW - Static variable in class com.crankuptheamps.client.Message.Command
sowAndDeltaSubscribe(MessageHandler, String, String, String, int, int, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, String, int, boolean, boolean, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, String, int, boolean, boolean, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, String, int, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, int, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a delta subscription.
SOWAndDeltaSubscribe - Static variable in class com.crankuptheamps.client.Message.Command
sowAndSubscribe(String, String) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(String) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, String, String, int, int, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, int, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, int, boolean, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, int, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, int, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW query and places a subscription.
SOWAndSubscribe - Static variable in class com.crankuptheamps.client.Message.Command
sowDelete(MessageHandler, String, String, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW delete with filter.
sowDelete(MessageHandler, String, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW delete with filter.
sowDelete(String, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW delete with filter.
SOWDelete - Static variable in class com.crankuptheamps.client.Message.Command
SOWDeleteByBookmark - Static variable in interface com.crankuptheamps.client.Store
SOWDeleteByBookmarkCancel - Static variable in interface com.crankuptheamps.client.Store
sowDeleteByData(MessageHandler, String, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW delete by data.
SOWDeleteByData - Static variable in interface com.crankuptheamps.client.Store
SOWDeleteByFilter - Static variable in interface com.crankuptheamps.client.Store
sowDeleteByKeys(MessageHandler, String, String, long) - Method in class com.crankuptheamps.client.Client: Executes a SOW delete using the SowKey assigned by AMPS to specify the messages to delete.
SOWDeleteByKeys - Static variable in interface com.crankuptheamps.client.Store
SOWRecoveryPointAdapter - Class in com.crankuptheamps.client: An implementation of the recovery point adapter interface that uses an AMPS SOW topic as an external store to persist recovery point state for bookmark replay subscriptions.
SOWRecoveryPointAdapter(Client, String, boolean, boolean, boolean) - Constructor for class com.crankuptheamps.client.SOWRecoveryPointAdapter: A recovery point adapter implementation that uses an AMPS SOW topic as an external store to persist recovery point state for bookmark replay subscriptions.
SOWRecoveryPointAdapter(Client, String, boolean, boolean, boolean, long, String, String, String, String) - Constructor for class com.crankuptheamps.client.SOWRecoveryPointAdapter: A recovery point adapter implementation that uses an AMPS SOW topic as an external store to persist recovery point state for bookmark replay subscriptions.
startTimer() - Method in class com.crankuptheamps.client.Client: Deprecated.
No longer supported by the AMPS server. Sends a start timer command to AMPS, which can be later stopped with a stop timer command.
StartTimer - Static variable in class com.crankuptheamps.client.Message.Command
Stats - Static variable in class com.crankuptheamps.client.Message.AckType
Status() - Constructor for class com.crankuptheamps.client.Message.Status
StatusField - Class in com.crankuptheamps.client.fields: Field data for a Message which consists of a status.
StatusField() - Constructor for class com.crankuptheamps.client.fields.StatusField
stopTimer(MessageHandler) - Method in class com.crankuptheamps.client.Client: Deprecated.
No longer supported by the AMPS server. Sends a stop timer command to AMPS
StopTimer - Static variable in class com.crankuptheamps.client.Message.Command
store(Message) - Method in class com.crankuptheamps.client.BlockPublishStore
store(Message, boolean) - Method in class com.crankuptheamps.client.BlockPublishStore
store(Message) - Method in class com.crankuptheamps.client.HybridPublishStore
Store - Interface in com.crankuptheamps.client: Represents a message store.
store(Message) - Method in interface com.crankuptheamps.client.Store: Store the provided message.
Store.StoreReplayer - Interface in com.crankuptheamps.client: Replay the messages saved in a store.
StoreException - Exception in com.crankuptheamps.client.exception: Exception thrown when a publish store (PublishStore) or bookmark store (BookmarkStore) experiences some internal error (such as lack of resources or permissions), or is in an improper state for the requested operation.
StoreException() - Constructor for exception com.crankuptheamps.client.exception.StoreException
StoreException(String) - Constructor for exception com.crankuptheamps.client.exception.StoreException
StoreException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.StoreException
StoreException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.StoreException
StreamException - Exception in com.crankuptheamps.client.exception: Thrown when AMPS sends an incorrectly formatted message stream.
StreamException() - Constructor for exception com.crankuptheamps.client.exception.StreamException
StreamException(String) - Constructor for exception com.crankuptheamps.client.exception.StreamException
StreamException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.StreamException
StreamException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.StreamException
StringField - Class in com.crankuptheamps.client.fields: Field data for a Message which consists of a string.
StringField(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.StringField
StringField() - Constructor for class com.crankuptheamps.client.fields.StringField: Default constructor.
StringField(String) - Constructor for class com.crankuptheamps.client.fields.StringField
SUBID_LEN - Static variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
SubidInUse - Static variable in class com.crankuptheamps.client.Message.Reason
SubidInUseException - Exception in com.crankuptheamps.client.exception: Thrown when the specified subscription ID is already in use for this client.
SubidInUseException() - Constructor for exception com.crankuptheamps.client.exception.SubidInUseException
SubidInUseException(String) - Constructor for exception com.crankuptheamps.client.exception.SubidInUseException
SubidInUseException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.SubidInUseException
SubidInUseException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.SubidInUseException
subscribe(MessageHandler, String, String, long) - Method in class com.crankuptheamps.client.Client: Places a subscription with AMPS.
subscribe(MessageHandler, String, String, String, long) - Method in class com.crankuptheamps.client.Client: Places a subscription with AMPS.
subscribe(MessageHandler, String, String, String, long, String) - Method in class com.crankuptheamps.client.Client: Places a subscription with AMPS.
subscribe(String) - Method in class com.crankuptheamps.client.Client: Places a subscription with AMPS.
subscribe(String, String) - Method in class com.crankuptheamps.client.Client: Places a subscription with AMPS.
subscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client: Places a subscription with AMPS.
subscribe(MessageHandler, Message) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
subscribe(MessageHandler, Message) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
Subscribe - Static variable in class com.crankuptheamps.client.Message.Command
subscribe(MessageHandler, Message) - Method in interface com.crankuptheamps.client.SubscriptionManager: Creates a subscription.
Subscription() - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
Subscription(Field) - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
Subscription() - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
Subscription() - Constructor for class com.crankuptheamps.client.RingBookmarkStore.Subscription
Subscription - Interface in com.crankuptheamps.client: Interface that represents a single subscription within a bookmark store implementation.
SubscriptionAlreadyExists - Static variable in class com.crankuptheamps.client.Message.Reason
SubscriptionAlreadyExistsException - Exception in com.crankuptheamps.client.exception: Thrown when a client attempts to register a subscription that already exists.
SubscriptionAlreadyExistsException() - Constructor for exception com.crankuptheamps.client.exception.SubscriptionAlreadyExistsException
SubscriptionAlreadyExistsException(String) - Constructor for exception com.crankuptheamps.client.exception.SubscriptionAlreadyExistsException
SubscriptionAlreadyExistsException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.SubscriptionAlreadyExistsException
SubscriptionAlreadyExistsException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.SubscriptionAlreadyExistsException
SubscriptionManager - Interface in com.crankuptheamps.client: Interface used to manage all subscriptions in AMPS.
Success - Static variable in class com.crankuptheamps.client.Message.Status
sync() - Method in class com.crankuptheamps.client.PublishStore: Forces any in memory changes to be written to persistant storage.

T

TCPSTransport - Class in com.crankuptheamps.client: Implements an AMPS transport over SSL.
TCPSTransport(Protocol, Properties) - Constructor for class com.crankuptheamps.client.TCPSTransport
TCPSTransport(Protocol) - Constructor for class com.crankuptheamps.client.TCPSTransport
TCPSTransportImpl - Class in com.crankuptheamps.client: The SSL Socket implementation of TCPSTransport.
TCPSTransportImpl(Protocol, Properties, TransportFilter) - Constructor for class com.crankuptheamps.client.TCPSTransportImpl
TCPTransport - Class in com.crankuptheamps.client: Implements an AMPS transport over standard TCP/IP.
TCPTransport(Protocol, Properties) - Constructor for class com.crankuptheamps.client.TCPTransport
TCPTransport(Protocol) - Constructor for class com.crankuptheamps.client.TCPTransport
TCPTransportImpl - Class in com.crankuptheamps.client: Socket implementation for TCPTransport.
TCPTransportImpl(Protocol, Properties, TransportFilter) - Constructor for class com.crankuptheamps.client.TCPTransportImpl
ThreadCreatedHandler - Interface in com.crankuptheamps.client
TimedOutException - Exception in com.crankuptheamps.client.exception: Thrown when an operation times out before it can be completed.
TimedOutException() - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
TimedOutException(String) - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
TimedOutException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
TimedOutException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
timeout(int) - Method in class com.crankuptheamps.client.MessageStream: Sets a timeout on self.
Timestamp - Static variable in class com.crankuptheamps.client.Message.Options: Constant string for the timestamp option.
toMap(String) - Method in class com.crankuptheamps.client.FIXShredder: Method used to map the FIX message into the Java Map.
toNVMap(String) - Method in class com.crankuptheamps.client.NVFIXShredder
TopN(int) - Static method in class com.crankuptheamps.client.Message.Options: Formats the top_n option for a command.
toString() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry: Converts the Entry to a string.
toString() - Method in class com.crankuptheamps.client.BookmarkRingBuffer: Returns a debugging string representing ring buffer state.
toString() - Method in class com.crankuptheamps.client.CommandId: Overridden to return the CommandId value as a string where each byte is interpreted as an ISO-8859-1 character.
toString() - Method in class com.crankuptheamps.client.fields.Field: Converts the value to a string representation where each byte is interpreted as a Java character.
toString() - Method in class com.crankuptheamps.client.Message: Return the message as a string.
Transport - Interface in com.crankuptheamps.client: Interface that is used to manage and configure connections to AMPS.
TransportDisconnectHandler - Interface in com.crankuptheamps.client: This class is used internally.
TransportException - Exception in com.crankuptheamps.client.exception: Thrown when an error occurs with a Transport in AMPS.
TransportException() - Constructor for exception com.crankuptheamps.client.exception.TransportException
TransportException(String) - Constructor for exception com.crankuptheamps.client.exception.TransportException
TransportException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportException
TransportException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportException
TransportFactory - Class in com.crankuptheamps.client: Factory class that allows you to register and unregister handler classes for various connection URI prefixes.
TransportFactory() - Constructor for class com.crankuptheamps.client.TransportFactory
TransportFilter - Interface in com.crankuptheamps.client: Interface used to filter raw incoming and outgoing data on a Transport.
TransportTraceFilter - Class in com.crankuptheamps.client: An implementation of TransportFilter for tracing message bytes to an OutputStream such as System.err.
TransportTraceFilter(OutputStream) - Constructor for class com.crankuptheamps.client.TransportTraceFilter: Construct a TransportTraceFilter to trace messages on stream_.
TransportTypeException - Exception in com.crankuptheamps.client.exception: Thrown when an invalid transport type is specified.
TransportTypeException() - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
TransportTypeException(String) - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
TransportTypeException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
TransportTypeException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
truncateOnClose(boolean) - Method in class com.crankuptheamps.client.PublishStore: Tells the PublishStore to truncate the file to its original size if there are no saved Messages when it is closed.

U

UNKNOWN - Static variable in interface com.crankuptheamps.client.ConnectionStateListener: Constant representing an unknown state.
Unknown - Static variable in class com.crankuptheamps.client.Message.Command
UnknownException - Exception in com.crankuptheamps.client.exception: Thrown when AMPS reports an error of an unknown type, for example, when running an older version of the AMPS Java client against a more recent version of AMPS.
UnknownException() - Constructor for exception com.crankuptheamps.client.exception.UnknownException
UnknownException(String) - Constructor for exception com.crankuptheamps.client.exception.UnknownException
UnknownException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.UnknownException
UnknownException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.UnknownException
unpersistedCount() - Method in class com.crankuptheamps.client.BlockPublishStore
unpersistedCount() - Method in class com.crankuptheamps.client.HybridPublishStore
unpersistedCount() - Method in interface com.crankuptheamps.client.Store: Return the number of operations in the store.
unregister(String) - Static method in class com.crankuptheamps.client.ProtocolFactory: Method to unregister a message.
unregister(String) - Static method in class com.crankuptheamps.client.TransportFactory: Unregisters a Transport from the AMPS client.
UNSET_INDEX - Static variable in class com.crankuptheamps.client.BookmarkRingBuffer
unsetExpiration() - Method in class com.crankuptheamps.client.Command: Clears any expiration value set on self.
unsubscribe(CommandId) - Method in class com.crankuptheamps.client.Client: Remove a subscription from AMPS.
unsubscribe() - Method in class com.crankuptheamps.client.Client: Remove all of the client's subscriptions from AMPS.
unsubscribe(CommandId) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
unsubscribe(CommandId) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
Unsubscribe - Static variable in class com.crankuptheamps.client.Message.Command
unsubscribe(CommandId) - Method in interface com.crankuptheamps.client.SubscriptionManager: Unsubscribes from a subscription.
unsubscribeAll() - Method in class com.crankuptheamps.client.MessageRouter: Removes all routes for subscriptions.
update(RecoveryPoint) - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Confalte an update to the newest recovery point.
update(RecoveryPoint) - Method in interface com.crankuptheamps.client.RecoveryPointAdapter: This method should be implemented to write the passed in recovery point to the external store for the specified subscription.
update(RecoveryPoint) - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Sends an update to the underlying SOW.
updateAll() - Method in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Force all held updates to be flushed to the underlying adapter.
UpdateThread(String) - Constructor for class com.crankuptheamps.client.ConflatingRecoveryPointAdapter.UpdateThread
URIProperties - Class in com.crankuptheamps.client: Provides a Properties-sytle interface to the parameters in a Uniform Resource Identifier (URI).
URIProperties(URI) - Constructor for class com.crankuptheamps.client.URIProperties

V

valueOf(String) - Static method in enum com.crankuptheamps.client.Client.GlobalCommandTypeHandlers: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.crankuptheamps.client.Message.SerializationResult: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.crankuptheamps.client.Client.GlobalCommandTypeHandlers: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.crankuptheamps.client.Message.SerializationResult: Returns an array containing the constants of this enum type, in the order they are declared.
Version() - Constructor for class com.crankuptheamps.client.Client.Version
VersionInfo - Class in com.crankuptheamps.client: A representation of an AMPS version that can be compared.
VersionInfo() - Constructor for class com.crankuptheamps.client.VersionInfo
VersionInfo(String) - Constructor for class com.crankuptheamps.client.VersionInfo

W

writeQueueSize() - Method in class com.crankuptheamps.client.TCPTransport
writeQueueSize() - Method in class com.crankuptheamps.client.TCPTransportImpl
writeQueueSize() - Method in interface com.crankuptheamps.client.Transport

X

XMLMessage - Class in com.crankuptheamps.client: A message subclass used by XMLProtocolParser to aid in building Message instances parsed from the XMLProtocol.
XMLMessage(CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.XMLMessage
XMLProtocol - Class in com.crankuptheamps.client: Implements the Protocol interface.
XMLProtocol() - Constructor for class com.crankuptheamps.client.XMLProtocol
XMLProtocol(Properties) - Constructor for class com.crankuptheamps.client.XMLProtocol
XMLProtocolParser - Class in com.crankuptheamps.client: Implements the ProtocolParser interface.
XMLProtocolParser(XMLProtocol) - Constructor for class com.crankuptheamps.client.XMLProtocolParser

Y

year - Variable in class com.crankuptheamps.client.AMPSTimestamp: Year part of this timestamp.

Z

zero(long, int) - Method in class com.crankuptheamps.client.ArrayStoreBuffer: Sets the buffer, offset, and length to 0.
zero(long, int) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
zero(long, int) - Method in class com.crankuptheamps.client.MemoryStoreBuffer: Sets the offset and length of the buffer to 0.

_

_ack(byte[], int, int, byte[], int, int, byte[], int, int) - Method in class com.crankuptheamps.client.Client
_ack(Field, Field) - Method in class com.crankuptheamps.client.Client: Used internally for autoacking and by Message.
_ack(Field, Field, Field) - Method in class com.crankuptheamps.client.Client: Used internally for autoacking and by Message.
_AckType - Variable in class com.crankuptheamps.client.Message
_adapter - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: The wrapped recovery point adapter instance we delegate to.
_adapter - Variable in class com.crankuptheamps.client.MemoryBookmarkStore: Optional recovery point adapter used to persist bookmark replay recovery state for each subscription.
_backoffExponent - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_BatchSize - Variable in class com.crankuptheamps.client.Message
_Bookmark - Variable in class com.crankuptheamps.client.Message
_bookmarkField - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_bookmarkPattern - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Regular expression pattern to pull the bookmark string from subscription state saved in the AMPS SOW.
_buffer - Variable in class com.crankuptheamps.client.BlockPublishStore
_buffer - Variable in class com.crankuptheamps.client.MemoryStoreBuffer
_bytes - Variable in class com.crankuptheamps.client.CompositeMessageBuilder
_cap - Variable in class com.crankuptheamps.client.HybridPublishStore
_client - Variable in class com.crankuptheamps.client.Message
_client - Variable in class com.crankuptheamps.client.MessageStream
_client - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_ClientName - Variable in class com.crankuptheamps.client.Message
_clientNameField - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_closeClient - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_closed - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Indicates whether this bookmark store has been closed.
_cmd - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_Command - Variable in class com.crankuptheamps.client.Message
_CommandId - Variable in class com.crankuptheamps.client.Message
_commandId - Variable in class com.crankuptheamps.client.MessageStream
_copyTo(Message) - Method in class com.crankuptheamps.client.Message: Overwrites destination data with this Message.
_CorrelationId - Variable in class com.crankuptheamps.client.Message
_counts - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: A concurrent hash map of subscription id's (known to this adapter) mapped to Long's that count how many updates have occurred for that subscription.
_current - Variable in class com.crankuptheamps.client.MessageStream
_current - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_currentDelay - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_currentDurationAndIncrease() - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: Returns the _currentDelay, and also expands _currentDelay based on the configured exponent and maximum.
_Data - Variable in class com.crankuptheamps.client.Message
_delay - Variable in class com.crankuptheamps.client.FixedDelayStrategy
_exceptionListener - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: The exception listener for this client and both underlying HAClient instances.
_exceptionListener - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_Expiration - Variable in class com.crankuptheamps.client.Message
_factory - Variable in class com.crankuptheamps.client.MemoryBookmarkStore
_fields - Variable in class com.crankuptheamps.client.Message: Need to visit every Field? Use this!
_fileStore - Variable in class com.crankuptheamps.client.HybridPublishStore
_Filter - Variable in class com.crankuptheamps.client.Message
_filter - Variable in class com.crankuptheamps.client.TCPTransportImpl
_firstUri - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_firstUri - Variable in class com.crankuptheamps.client.FixedDelayStrategy
_GroupSeqNo - Variable in class com.crankuptheamps.client.Message
_idleRunnable - Variable in class com.crankuptheamps.client.TCPTransportImpl
_impl - Variable in class com.crankuptheamps.client.TCPTransport
_initialDelay - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_initStr - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_inputStream - Variable in class com.crankuptheamps.client.TCPTransportImpl
_jitter - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_lastUri - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_lastUri - Variable in class com.crankuptheamps.client.FixedDelayStrategy
_lastValue - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter: A concurrent hash map of subscription id's (known to this store) mapped to the subscription's most-recent-for-recovery value that was last persisted to the SOW.
_latestUpdates - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: A concurrent hash map of subscription id's mapped to the RecoveryPoint received from the most recent update.
_LeasePeriod - Variable in class com.crankuptheamps.client.Message
_Length - Variable in class com.crankuptheamps.client.Message
_lock - Variable in class com.crankuptheamps.client.TCPTransportImpl
_lowWatermark - Variable in class com.crankuptheamps.client.HybridPublishStore
_Matches - Variable in class com.crankuptheamps.client.Message
_maxDepth - Variable in class com.crankuptheamps.client.MessageStream
_maximum - Variable in class com.crankuptheamps.client.FixedDelayStrategy
_maximumDelay - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_maximumRetryTime - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_memoryStore - Variable in class com.crankuptheamps.client.HybridPublishStore
_MessageType - Variable in class com.crankuptheamps.client.Message
_Options - Variable in class com.crankuptheamps.client.Message
_OrderBy - Variable in class com.crankuptheamps.client.Message
_outputStream - Variable in class com.crankuptheamps.client.TCPTransportImpl
_Password - Variable in class com.crankuptheamps.client.Message
_path - Variable in class com.crankuptheamps.client.HybridPublishStore
_position - Variable in class com.crankuptheamps.client.CompositeMessageBuilder
_previousBookmark - Variable in class com.crankuptheamps.client.MessageStream
_previousTopic - Variable in class com.crankuptheamps.client.MessageStream
_purge() - Method in class com.crankuptheamps.client.LoggedBookmarkStore
_purge(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
_q - Variable in class com.crankuptheamps.client.MessageStream
_QueryId - Variable in class com.crankuptheamps.client.Message
_queryId - Variable in class com.crankuptheamps.client.MessageStream
_Reason - Variable in class com.crankuptheamps.client.Message
_RecordsDeleted - Variable in class com.crankuptheamps.client.Message
_RecordsInserted - Variable in class com.crankuptheamps.client.Message
_RecordsReturned - Variable in class com.crankuptheamps.client.Message
_RecordsUpdated - Variable in class com.crankuptheamps.client.Message
_recovering - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_recoveryTimestamp - Variable in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription: The last-modified timestamp of the backing bookmark log file, just before recovery is initiated.
_recoveryTimestamp - Variable in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription: The last-modified timestamp, if any, from a RecoveryPointAdapter before recovery is initiated.
_requestedAcks - Variable in class com.crankuptheamps.client.MessageStream
_resizeHandler - Variable in class com.crankuptheamps.client.BlockPublishStore
_Sequence - Variable in class com.crankuptheamps.client.Message
_serializeField - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_serializeStart - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_socket - Variable in class com.crankuptheamps.client.TCPTransportImpl
_SowKey - Variable in class com.crankuptheamps.client.Message
_sowKeyLock - Variable in class com.crankuptheamps.client.MessageStream
_sowKeyMap - Variable in class com.crankuptheamps.client.MessageStream
_SowKeys - Variable in class com.crankuptheamps.client.Message
_start - Variable in class com.crankuptheamps.client.FixedDelayStrategy
_startTime - Variable in class com.crankuptheamps.client.ExponentialDelayStrategy
_state - Variable in class com.crankuptheamps.client.MessageStream
_Status - Variable in class com.crankuptheamps.client.Message
_store - Variable in class com.crankuptheamps.client.MemoryStoreBuffer
_stream - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_SubId - Variable in class com.crankuptheamps.client.Message
_subIdField - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_subIdPattern - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter: Regular expression pattern to pull the subscription id from subscription state saved in the AMPS SOW.
_SubIds - Variable in class com.crankuptheamps.client.Message
_thread - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: The background worker thread that persists subscription discard state to the SOW.
_throwIfMaximumExceeded() - Method in class com.crankuptheamps.client.ExponentialDelayStrategy: An internal function used to check if the configured retry has been exceeded, and if so, throw MaximumRetryExceeded to cause the calling HAClient to give up on reconnecting to a server.
_throwNotListen - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_timedOut - Variable in class com.crankuptheamps.client.MessageStream
_timeout - Variable in class com.crankuptheamps.client.MessageStream
_timeoutMillis - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: The threshold used to determine if a subscription is due for an update operation, based upon whether this many milliseconds have elapsed since the last update operation.
_timeoutMillis - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_timers - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: A concurrent hash map of subscription id's (known to this adapter) mapped to Long's that represent the timestamp of when the subscription's state was last written to the adapter.
_Timestamp - Variable in class com.crankuptheamps.client.Message
_Topic - Variable in class com.crankuptheamps.client.Message
_topic - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_TopicMatches - Variable in class com.crankuptheamps.client.Message
_TopN - Variable in class com.crankuptheamps.client.Message
_trackedName - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_updateAll - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: Indicates whether all updates should be flushed regardless.
_updateIntervalMillis - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: The threshold for idle time between updates when timers should be checked again.
_updates - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter.UpdateThread
_updateThreshold - Variable in class com.crankuptheamps.client.ConflatingRecoveryPointAdapter: The threshold used to determine if a subscription is due for an update operation, based upon whether the subscription's update count exceeds this threshold since the last update operation.
_UserId - Variable in class com.crankuptheamps.client.Message
_useTimestamp - Variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
_Version - Variable in class com.crankuptheamps.client.Message

A B C D E F G H I J L M N O P R S T U V W X Y Z _