- 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 check if resizing of the BookmarkRingBuffer is possible.
- clear() - Method in class com.crankuptheamps.client.CompositeMessageBuilder
-
Clears this object.
- clear() - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
-
Clears all subscriptions.
- clear() - Method in class com.crankuptheamps.client.FIXBuilder
-
Clears self.
- clear() - Method in class com.crankuptheamps.client.MemorySubscriptionManager
-
Clears all subscriptions.
- clear() - Method in class com.crankuptheamps.client.MessageRouter
-
Removes all routes from self (MessageRouter).
- 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.
- clearHttpPreflightHeaders() - Method in class com.crankuptheamps.client.Client
-
Clear the list of HTTP preflight headers.
- Client - Class in com.crankuptheamps.client
-
The base AMPS client object used for AMPS applications that do not need a
resilient connection to AMPS.
- Client() - Constructor for class com.crankuptheamps.client.Client
-
Default constructor that creates a client without a name.
- 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.ClientHandler - Class in com.crankuptheamps.client
-
- 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
-
Closes the 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
-
Closes both the memory store and the file store.
- 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
-
Closes the transport, disconnecting it from the server.
- 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
-
This package contains utility classes and functions that support various
aspects of the AMPS Java client.
- 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(String) - Constructor for class com.crankuptheamps.client.Command
-
Create a new `Command` object with the specified command code.
- Command(int) - Constructor for class com.crankuptheamps.client.Command
-
- 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 CommandId 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
-
Connects to the specified URI using the underlying implementation.
- connect(URI) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Connects the transport to the specified URI.
- connect(URI) - Method in interface com.crankuptheamps.client.Transport
-
Connect to an AMPS server.
- connectAndLogon() - Method in class com.crankuptheamps.client.HAClient
-
- 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 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 state changes.
- connectSocket(URI, URIProperties) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
- constructTransportImpl(Protocol, Properties) - Method in class com.crankuptheamps.client.TCPSTransport
-
- constructTransportImpl(Protocol, Properties) - Method in class com.crankuptheamps.client.TCPTransport
-
Constructs a new TCPTransport instance with the specified protocol and properties.
- copy() - Method in class com.crankuptheamps.client.fields.BookmarkField
-
Override base class's copy() method appropriately, so we don't inadvertently mix
BookmarkFields and Fields up -- they have different hashCode implementations.
- copy() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
-
Override base class's copy() method appropriately, so we don't inadvertently mix
BookmarkRangeFields and Fields up -- they have different hashCode implementations.
- 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
-
Provides a way to make this object a duplicate of f if f
represents a valid bookmark range.
- 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
-
Creates a new instance of `RecoveryPoint` with the given subscription ID
and bookmark.
- createSocket() - Method in class com.crankuptheamps.client.TCPSTransportImpl
-
Creates a new SSLSocket for secure communication.
- createSocket() - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Creates a socket using the default socket factory.
- createStream(URI) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
- createTransport(Protocol) - Static method in class com.crankuptheamps.client.TCPTransport
-
- createTransport(Protocol, TCPTransportImpl) - Static method in class com.crankuptheamps.client.TCPTransport
-
- createTransport(Protocol, TCPTransportImpl) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
- createTransport(String, Protocol, Properties) - Static method in class com.crankuptheamps.client.TransportFactory
-
Creates a
Transport using the parameters provided.
- 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
-
- 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
-
- 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
-
Retrieves the command type associated with this `Command` object.
- 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
-
Gets the automatically generated command ID associated with this 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 at the point in time this is called.
- 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
-
Gets the connection wait duration based on the provided URI.
- 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
-
Gets the correlation Id set with 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 exception com.crankuptheamps.client.exception.PublishFilterException
-
- 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
-
- getDuplicateMessageHandler() - Method in class com.crankuptheamps.client.Client
-
- 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
-
Gets the end bookmark of the range.
- 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.
- getErrorOnPublishGap() - Method in class com.crankuptheamps.client.BlockPublishStore
-
Get whether the Store will throw a PublishGapException from discardUpTo if the
sequence number being discarded is less then the current last persisted.
- getErrorOnPublishGap() - Method in class com.crankuptheamps.client.HybridPublishStore
-
Get whether the Store will throw a PublishGapException from discardUpTo if the
sequence number being discarded is less then the current last persisted.
- getErrorOnPublishGap() - Method in interface com.crankuptheamps.client.Store
-
Get whether the Store will throw a PublishGapException from discardUpTo if the
sequence number being discarded is less then the current last persisted.
- 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.
- getFailedResubscribeHandler() - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
-
Gets the failed resubscribe handler.
- getFailedResubscribeHandler() - Method in class com.crankuptheamps.client.MemorySubscriptionManager
-
Gets the FailedResubscribeHandler.
- getFailedResubscribeHandler() - Method in interface com.crankuptheamps.client.SubscriptionManager
-
Gets the FailedResubscribeHandler.
- 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 exception com.crankuptheamps.client.exception.PublishFilterException
-
- 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
-
When executing a SOW query and AMPS returns a batch of query results,
this sequence number is set on each message within the result batch
to indicate it's postion within the batch.
- getHeartbeatInterval() - Method in class com.crankuptheamps.client.Client
-
Returns the heartbeat interval used by the Client.
- getHighestUnpersisted() - Method in class com.crankuptheamps.client.BlockPublishStore
-
Gets the highest unpersisted sequence number.
- getHttpPreflightHeaders() - Method in class com.crankuptheamps.client.Client
-
Return the list of HTTP preflight headers.
- getIdleRunnable() - Method in class com.crankuptheamps.client.TCPTransport
-
Gets the transport's currently registered idle task, or null
if there is none.
- getIdleRunnable() - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Gets the transport impl's currently registered idle task, or null
if there is none.
- getIdleRunnable() - Method in interface com.crankuptheamps.client.Transport
-
Gets the
AMPSRunnable that is invoked during idle-time
processing for this connection.
- 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
-
Gets the last persisted sequence number.
- getLastPersisted() - Method in class com.crankuptheamps.client.HybridPublishStore
-
Gets the last persisted sequence number from the file store.
- getLastPersisted() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Retrieves the last persisted bookmark
- 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 version 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
-
Gets the lowest unpersisted sequence number.
- 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.
- getMessage() - Method in class com.crankuptheamps.client.MemorySubscriptionManager
-
Gets the message associated with this instance.
- getMessageStream() - Method in class com.crankuptheamps.client.FIXProtocol
-
Ges a new ProtocalParser instancc= for parsing messages.
- getMessageStream() - Method in class com.crankuptheamps.client.JSONProtocol
-
Gets the message stream for JSON protocol.
- getMessageStream() - Method in class com.crankuptheamps.client.NVFIXProtocol
-
Gets the message stream for NVFIX protocol.
- 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 field on this message.
- getMostRecent(Field) - Method in interface com.crankuptheamps.client.BookmarkStore
-
You can 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
-
You can 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
-
Retrieves the most recent bookmark associated with a subscription identified
by the given subId.
- getMostRecent(Field, boolean) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
-
Retrieves the most recent bookmark associated with a subscription identified
by the given subId.
- getMostRecent() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Retrieves the most recent bookmark.
- getMostRecent(boolean) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Retrieves the most recent bookmark with an option to update recovery status.
- getMostRecent(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Get the most recent bookmark for a specific subscription.
- getMostRecent(Field, boolean) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Get the most recent bookmark for a specific subscription.
- getMostRecent() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Get the most recent bookmark.
- 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 based on the provided subscription
ID.
- 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 based on the provided subscription
ID.
- 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
-
You can 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
-
Retrieves the oldest bookmark sequence number associated with a subscription.
- getOldestBookmarkSeq() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Retrieves the sequence number of the oldest bookmark in the subscription's
bookmark ring buffer.
- getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Get the oldest bookmark sequence number for a specific subscription.
- getOldestBookmarkSeq() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Get the oldest bookmark sequence number.
- 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
-
Retrieve the query identifier associated with the 'Command' object.
- 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
-
Retrieves the current bookmark range.
- getRange() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Gets the range of bookmarks stored in this bookmark store.
- 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
-
- 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
-
Gets a list of recovery entries from the BookmarkRingBuffer.
- getRecoveryEntries() - Method in class com.crankuptheamps.client.BookmarkRingBuffer
-
Deprecated.
- getRecoveryTimestamp() - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Get the recovery timestamp associated with this message.
- getRecoveryTimestamp() - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Get the last-modified timestamp used for recovery.
- 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
-
- 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
-
- getSowKey() - Method in class com.crankuptheamps.client.Command
-
Retrieves the State of the World (SOW) key associated with this instance.
- 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 keys on this command.
- getSOWKeys() - Method in class com.crankuptheamps.client.Command
-
- 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
-
Gets the start bookmark of the range.
- 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
-
- getText() - Method in class com.crankuptheamps.client.fields.ReasonField
-
Returns the value of this reason field as a descriptive text string.
- getThreadCreatedHandler() - Method in class com.crankuptheamps.client.Client
-
Get the handler that is invoked immediately by any thread created by
the transport.
- getTimeout() - Method in class com.crankuptheamps.client.Command
-
Gets 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.
- getTransportDisconnectHandler() - Method in class com.crankuptheamps.client.Client
-
- getTransportFilter() - Method in class com.crankuptheamps.client.Client
-
Get the filter that is used by the Client's transport for all incoming
and outgoing messages.
- getTransportMessageHandler() - Method in class com.crankuptheamps.client.Client
-
- 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
-
Retrieves the value of this OptionsField as a string using the specified
charset decoder.
- getValue(ByteBuffer) - Method in class com.crankuptheamps.client.fields.OptionsField
-
Retrieves the value of this OptionsField as a byte buffer.
- 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
-
Returns the version of the transport.
- 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
-
Ensures that the free list is not empty by potentially growing it.
- 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
-
Initializes the subscription with the given subscription ID and the parent
LoggedBookmarkStore.
- init(Field, MemoryBookmarkStore) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Initialize the Subscription with a new subscription ID and assign a reference
to the parent bookmark store.
- init(ByteBuffer, int) - Method in class com.crankuptheamps.client.RingBookmarkStore.Subscription
-
- initFromClient(Client) - Method in class com.crankuptheamps.client.TCPTransport
-
- initFromClient(Client) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
- initFromClient(Client) - Method in interface com.crankuptheamps.client.Transport
-
Called by Client before calling connect to give Transport access to any
information in the Client needed by the Transport such as message handler,
exceptionListener, etc.
- initSerialization() - Method in class com.crankuptheamps.client.SOWRecoveryPointAdapter
-
Initializes the serialization buffer and an initial string for serialization
purposes.
- instance - Static variable in class com.crankuptheamps.client.DefaultDisconnectHandler
-
Singleton instance of DefaultDisconnectHandler.
- instance - Static variable in class com.crankuptheamps.client.DefaultMessageHandler
-
Singleton instance of 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
-
Represents an issue with a bookmark, which is a saved message positions.
- InvalidBookmarkException - Exception in com.crankuptheamps.client.exception
-
Thrown when the AMPS server reports that a filter could not be
successfully processed.
- InvalidBookmarkException() - Constructor for exception com.crankuptheamps.client.exception.InvalidBookmarkException
-
- InvalidBookmarkException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidBookmarkException
-
- InvalidBookmarkException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidBookmarkException
-
- InvalidBookmarkException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidBookmarkException
-
- InvalidMessageType - Static variable in class com.crankuptheamps.client.Message.Reason
-
Signifies an issue with the message type.
- InvalidMessageTypeException - Exception in com.crankuptheamps.client.exception
-
Thrown when the AMPS server reports that a command uses an invalid
message type, or the message type was left unspecified for a
connection using the 'amps' protocol.
- InvalidMessageTypeException() - Constructor for exception com.crankuptheamps.client.exception.InvalidMessageTypeException
-
- InvalidMessageTypeException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidMessageTypeException
-
- InvalidMessageTypeException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidMessageTypeException
-
- InvalidMessageTypeException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidMessageTypeException
-
- InvalidOptions - Static variable in class com.crankuptheamps.client.Message.Reason
-
Indicates issues with provided options.
- InvalidOptionsException - Exception in com.crankuptheamps.client.exception
-
Thrown when the AMPS server reports that a filter could not be
successfully processed.
- InvalidOptionsException() - Constructor for exception com.crankuptheamps.client.exception.InvalidOptionsException
-
- InvalidOptionsException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidOptionsException
-
- InvalidOptionsException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidOptionsException
-
- InvalidOptionsException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidOptionsException
-
- InvalidOrderBy - Static variable in class com.crankuptheamps.client.Message.Reason
-
Occurs when there is an issue with the specified ordering of messages.
- InvalidOrderByException - Exception in com.crankuptheamps.client.exception
-
Thrown when the AMPS server reports that a filter could not be
successfully processed.
- InvalidOrderByException() - Constructor for exception com.crankuptheamps.client.exception.InvalidOrderByException
-
- InvalidOrderByException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidOrderByException
-
- InvalidOrderByException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidOrderByException
-
- InvalidOrderByException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidOrderByException
-
- 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
-
- InvalidSubId - Static variable in class com.crankuptheamps.client.Message.Reason
-
Occurs when an invalid subscription ID is provided.
- InvalidSubIdException - Exception in com.crankuptheamps.client.exception
-
Thrown when the AMPS server reports that a filter could not be
successfully processed.
- InvalidSubIdException() - Constructor for exception com.crankuptheamps.client.exception.InvalidSubIdException
-
- InvalidSubIdException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidSubIdException
-
- InvalidSubIdException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidSubIdException
-
- InvalidSubIdException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidSubIdException
-
- InvalidTopic - Static variable in class com.crankuptheamps.client.Message.Reason
-
Indicates an issue when the AMPS server reports that the command requested is
not valid for the topic specified.
- 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
-
- InvalidTopicOrFilter - Static variable in class com.crankuptheamps.client.Message.Reason
-
Indicates an issue with both the topic and the filter.
- 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(Message) - Method in class com.crankuptheamps.client.Client.ClientHandler
-
The MessageHandler implementation
- invoke(Transport, Exception) - Method in class com.crankuptheamps.client.Client.ClientHandler
-
The TransportDisconnectHandler implementation
- 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
-
Invokes the disconnection handler for the client.
- invoke(Transport, Exception) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
-
Invokes the disconnection handler for the transport.
- invoke(Message) - Method in class com.crankuptheamps.client.DefaultMessageHandler
-
Invokes the message handler.
- 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.
- isBookmarkList() - Method in class com.crankuptheamps.client.fields.BookmarkField
-
- 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
-
Checks if daemon threads are being used by default.
- 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 internally by the AMPS Client.
- isDiscarded(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
-
- isDiscarded(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
-
This method is called internally by the client to determine whether a
message's bookmark received from the amps server has already been discarded
OR already been delivered to the subscriber during this run.
- 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
-
Check if a message is discarded based on its bookmark.
- 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
-
Checks if the bookmark range ends exclusively (exclusive range).
- isEndInclusive() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
-
Checks if the bookmark range ends inclusively (inclusive range).
- 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
-
Checks if the current command represents a State of the World (SOW)
operation.
- 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
-
Checks if the bookmark range starts exclusively (exclusive range).
- isStartInclusive() - Method in class com.crankuptheamps.client.fields.BookmarkRangeField
-
Checks if the bookmark range starts inclusively (inclusive range).
- 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
-
Checks if the current command represents 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
-
Checks if the bookmark range is valid.
- 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.
- 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.
- parseBookmarkList() - Method in class com.crankuptheamps.client.fields.BookmarkField
-
Parses the bookmark list.
- Parsed - Static variable in class com.crankuptheamps.client.Message.AckType
-
- ParseError - Static variable in class com.crankuptheamps.client.Message.Reason
-
Signifies an error in parsing data.
- 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 AMPS 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
-
- 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
-
- persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
-
This method is called by the client and it is used to process persisted
acknowledgements that track a safe recovery point in the txlog.
- persisted(Field, long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
- persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Persist a bookmark for a subscription.
- 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
-
- 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.Client.ClientHandler
-
- preInvoke(int) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
-
Pre-invocation setup for the disconnection handler.
- 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
-
Processes the byte stream using the FIX protocal and invokes
the provided message handler.
- process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.JSONProtocolParser
-
Processes the incoming byte buffer containing JSON messages.
- 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
-
- PublishFilterException - Exception in com.crankuptheamps.client.exception
-
Thrown when the AMPS server reports that a filter could not be
successfully processed.
- PublishFilterException() - Constructor for exception com.crankuptheamps.client.exception.PublishFilterException
-
- PublishFilterException(String, String) - Constructor for exception com.crankuptheamps.client.exception.PublishFilterException
-
- PublishFilterException(String, String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.PublishFilterException
-
- PublishFilterException(String) - Constructor for exception com.crankuptheamps.client.exception.PublishFilterException
-
- PublishFilterException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.PublishFilterException
-
- PublishFilterException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.PublishFilterException
-
- PublishFilterNoMatch - Static variable in class com.crankuptheamps.client.Message.Reason
-
This might never be used.
- publishFlush() - Method in class com.crankuptheamps.client.Client
-
Ensures that AMPS messages are sent and have been processed by the
AMPS server.
- publishFlush(String) - 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.
- publishFlush(String, long) - Method in class com.crankuptheamps.client.Client
-
Ensures that AMPS messages are sent and have been processed by the
AMPS server.
- PublishGapException - Exception in com.crankuptheamps.client.exception
-
Exception thrown when a publish store (
Store)
is asked to discardUpTo a sequence that is below any in the Store.
- PublishGapException() - Constructor for exception com.crankuptheamps.client.exception.PublishGapException
-
- PublishGapException(String) - Constructor for exception com.crankuptheamps.client.exception.PublishGapException
-
- PublishGapException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.PublishGapException
-
- PublishGapException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.PublishGapException
-
- 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
-
You can call this when you want to purge the contents of this store.
- purge(Field) - Method in interface com.crankuptheamps.client.BookmarkStore
-
You can 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
-
This method is responsible for removing or purging all recovery point
information from the instance(self) and from the wrapped 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
-
Removes all entries in the bookmark store associated with a specific
subscription ID (subId_).
- purge() - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Remove all entries in the bookmark store, completely clearing all records of
messages received and discarded.
- purge(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Remove entries for a specific subscription ID, clearing its records of
messages received and discarded.
- 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
-
- 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
-
- 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.
- 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(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
-
Sends the specified message.
- send(ByteBuffer) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sends data through the socket.
- 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
-
Sends a message without retrying, handling the serialization process.
- 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
-
Serializes the JSON message.
- 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
-
- 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
-
This field is only used internally by bookmark store implementations
to cache a tracking index for undiscarded messages, so they can be
looked up quickly when discarded for a bookmark subscription.
- 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' object.
- 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
-
Sets a unique command identifier 'CommandId' for this `Command` object.
- 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.
- setCommandId(CommandId) - Method in class com.crankuptheamps.client.MessageStream
-
When this message stream is the result of a form of subscribe command, this
gets called with the command ID of the command.
- setConnectTimeout(int) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the connect timeout for the TCP transport.
- 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
-
Sets whether daemon threads should be used by default.
- 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 raw 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
-
- setDisconnectHandler(TransportDisconnectHandler) - Method in class com.crankuptheamps.client.TCPTransport
-
Sets the handler for disconnect events.
- setDisconnectHandler(TransportDisconnectHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the disconnect handler for the transport.
- setDisconnectHandler(TransportDisconnectHandler) - Method in interface com.crankuptheamps.client.Transport
-
- setDuplicateMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client
-
- setErrorOnPublishGap(boolean) - Method in class com.crankuptheamps.client.BlockPublishStore
-
Set whether the Store should throw a PublishGapException from discardUpTo if the
sequence number being discarded is less then the current last persisted.
- setErrorOnPublishGap(boolean) - Method in class com.crankuptheamps.client.HybridPublishStore
-
Set whether the Store should throw a PublishGapException from discardUpTo if the
sequence number being discarded is less then the current last persisted.
- setErrorOnPublishGap(boolean) - Method in interface com.crankuptheamps.client.Store
-
Set whether the Store should throw a PublishGapException from discardUpTo if the
sequence number being discarded is less then the current last persisted.
- 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
-
Sets the listener for exception events.
- setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the exception listener for the transport.
- 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.
- setFailedResubscribeHandler(FailedResubscribeHandler) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
-
Sets the failed resubscribe handler.
- setFailedResubscribeHandler(FailedResubscribeHandler) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
-
Sets the FailedResubscribeHandler.
- setFailedResubscribeHandler(FailedResubscribeHandler) - Method in interface com.crankuptheamps.client.SubscriptionManager
-
Sets the FailedResubscribeHandler.
- 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
-
When executing a SOW query and AMPS returns a batch of query results,
this sequence number is set on each message within the result batch
to indicate it's postion within the batch.
- 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.
- setHttpPreflightHeaders(List<String>) - Method in class com.crankuptheamps.client.Client
-
Set the list of HTTP preflight headers replacing any previously set.
- setIdleRunnable(AMPSRunnable) - Method in class com.crankuptheamps.client.TCPTransport
-
Sets the idle runnable for the transport.
- 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
-
- setLastPersisted(long) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
- setLastPersisted(BookmarkField) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Sets the last persisted bookmark using a provided BookmarkField object.
- setLastPersisted(long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
- setLastPersisted(BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Set the last persisted bookmark.
- 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 milliseconds) 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
-
Sets the message to be stored.
- setMessage(Message) - Method in class com.crankuptheamps.client.HybridPublishStore
-
Sets a message in both the memory store and the disk store.
- 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
-
Sets the message handler for this transport.
- setMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the message handler for the transport.
- setMessageHandler(MessageHandler) - Method in interface com.crankuptheamps.client.Transport
-
- setMessageType(String) - Method in class com.crankuptheamps.client.Message
-
sets the MessageType field on this message.
- setName(String) - Method in class com.crankuptheamps.client.Client
-
This method MUST be called to assign a unique client name before
connecting to an AMPS server when the client was constructed using
the default constructor.
- 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
-
Update the provided publishers map with the highest sequence number
that has been discarded for each publisher based on the given list of
active bookmark entries.
- 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 a custom 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 form of SOW command, this gets
called with the query ID of the command.
- setRawBufferLength(int) - Method in class com.crankuptheamps.client.Message
-
Set 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
-
Sets the read timeout for the transport.
- setReadTimeout(int) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the read timeout for the TCP transport.
- 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
-
- 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 adaptor.
- setRecoveryTimestamp(String) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Sets the recovery timestamp associated with this message.
- setRecoveryTimestamp(String) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
The last-modified timestamp, if any, from a RecoveryPointAdapter
before recovery is initiated.
- setResizeHandler(PublishStoreResizeHandler) - Method in class com.crankuptheamps.client.BlockPublishStore
-
Sets a resize handler for the publish store.
- 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
-
You can call 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
-
Sets a resize handler for both the file store and the memory store.
- setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
-
Sets a handler for bookmark store resize events.
- setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.LoggedBookmarkStore.Subscription
-
Sets the resize handler for the bookmark store.
- setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
-
Set the resize handler for this bookmark store and all associated
subscriptions.
- setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Set a resize handler for the bookmark store.
- 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
-
- 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
-
- setServerVersion(int) - Method in interface com.crankuptheamps.client.BookmarkStore
-
Called internally by the AMPS 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
-
Set the version of the AMPS server.
- 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
-
- setSowKey(String) - Method in class com.crankuptheamps.client.Command
-
The SowKey for a command is only used to publish to a SOW topic and if
the user wants to restrict the command to a set of messages identified
by key, SowKeys is used instead.
- 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
-
Sets the SowKeys for this command.
- setSOWKeys(String) - Method in class com.crankuptheamps.client.Command
-
- 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
-
- setStatsOnly() - Method in class com.crankuptheamps.client.MessageStream
-
- 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
-
Sets the subId for this command using a string representation.
- 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
-
- 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
-
Sets the handler for newly created threads.
- setThreadCreatedHandler(ThreadCreatedHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the thread created handler for the transport.
- 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, offset, and length.
- 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
-
Sets the top_n header 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
-
Sets the transport filter.
- setTransportFilter(TransportFilter) - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Sets the transport filter for the transport.
- 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
-
- 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 integer.
- 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
-
Sets the value of this OptionsField using the specified byte array,
offset, and length.
- setValue(String, CharsetEncoder) - Method in class com.crankuptheamps.client.fields.OptionsField
-
Sets the value of this OptionsField using the specified string
value and charset encoder.
- 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
-
Returns the underlying socket of the transport.
- socket() - Method in class com.crankuptheamps.client.TCPTransportImpl
-
Retrieves the underlying socket.
- 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
-
- SowCanceled - Static variable in class com.crankuptheamps.client.Message.Reason
-
Occurs when a SOW query is canceled.
- 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
-
- SowDeleteInvalid - Static variable in class com.crankuptheamps.client.Message.Reason
-
Represents an attempt to delete invalid state of the world.
- SOWRecoveryPointAdapter - Class in com.crankuptheamps.client
-
An implementation of the recovery point adapter interface that uses an
AMPS SOW (State of the World) 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.
- SowStoreFailed - Static variable in class com.crankuptheamps.client.Message.Reason
-
Occurs when there is a failure in storing messages.
- startTimer() - Method in class com.crankuptheamps.client.Client
-
- 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
-
- StopTimer - Static variable in class com.crankuptheamps.client.Message.Command
-
- store(Message) - Method in class com.crankuptheamps.client.BlockPublishStore
-
Stores a message in the BlockPublishStore.
- store(Message, boolean) - Method in class com.crankuptheamps.client.BlockPublishStore
-
Protected utility method for storing messages in the BlockPublishStore.
- store(Message) - Method in class com.crankuptheamps.client.HybridPublishStore
-
Stores a message in the hybrid store, swapping to disk if memory usage
exceeds capacity.
- 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
-
Initializes a new instance of the StringField class with the
specified buffer, position, and length.
- StringField() - Constructor for class com.crankuptheamps.client.fields.StringField
-
Default constructor.
- StringField(String) - Constructor for class com.crankuptheamps.client.fields.StringField
-
Initializes a new instance of the StringField class with the specified
string value.
- SUBID_LEN - Static variable in class com.crankuptheamps.client.SOWRecoveryPointAdapter
-
- SubidInUse - Static variable in class com.crankuptheamps.client.Message.Reason
-
When the specified subscription ID is already in use for this client.
- 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
-
Subscribes to a message handler with a message.
- subscribe(MessageHandler, Message) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
-
Subscribes to messages with the specified message handler and message.
- 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
-
Constructor that creates a Subscription object with the provided subscription
ID and initializes its state.
- Subscription() - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore.Subscription
-
Default constructor that creates a Subscription object and initializes its
state.
- 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
-
Occurs when a client attempts to register a subscription that already exists.
- 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 persistent storage.