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

A

Ack - Static variable in class com.crankuptheamps.client.Message.Command
 
AckTypeField - Class in com.crankuptheamps.client.fields
 
AckTypeField() - Constructor for class com.crankuptheamps.client.fields.AckTypeField
 
add(String) - Method in class com.crankuptheamps.client.DefaultServerChooser
Adds a URI to self.
addAckType(int) - Method in class com.crankuptheamps.client.Command
Adds an additional ackType to the ackTypes already set for this Command.
addConnectionStateListener(ConnectionStateListener) - Method in class com.crankuptheamps.client.Client
Adds a ConnectionStateListener instance that will be invoked when this client connects or disconnects.
addExample(String) - Method in class com.crankuptheamps.spark.SparkCommand
 
addExtra(String) - Method in class com.crankuptheamps.spark.SparkCommand
 
addOption(CommandOption) - Method in class com.crankuptheamps.spark.SparkCommand
 
addRoute(CommandId, MessageHandler, int, int, boolean) - Method in class com.crankuptheamps.client.MessageRouter
Adds a route to self.
addSynonym(String, String) - Method in class com.crankuptheamps.spark.SparkCommand
 
allocateMessage() - Method in class com.crankuptheamps.client.Client
Creates a new Message appropriate for this client.
allocateMessage() - Method in class com.crankuptheamps.client.FIXProtocol
 
allocateMessage() - Method in class com.crankuptheamps.client.JSONProtocol
 
allocateMessage() - Method in class com.crankuptheamps.client.NVFIXProtocol
 
allocateMessage() - Method in interface com.crankuptheamps.client.Protocol
 
allocateMessage() - Method in class com.crankuptheamps.client.TCPTransport
 
allocateMessage() - Method in interface com.crankuptheamps.client.Transport
 
allocateMessage() - Method in class com.crankuptheamps.client.XMLProtocol
 
AlreadyConnectedException - Exception in com.crankuptheamps.client.exception
 
AlreadyConnectedException() - Constructor for exception com.crankuptheamps.client.exception.AlreadyConnectedException
 
AlreadyConnectedException(String) - Constructor for exception com.crankuptheamps.client.exception.AlreadyConnectedException
 
AlreadyConnectedException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.AlreadyConnectedException
 
AMPS_1 - Static variable in class com.crankuptheamps.client.Client.Version
 
AMPS_2 - Static variable in class com.crankuptheamps.client.Client.Version
 
AMPS_3 - Static variable in class com.crankuptheamps.client.Client.Version
 
AMPSException - Exception in com.crankuptheamps.client.exception
 
AMPSException() - Constructor for exception com.crankuptheamps.client.exception.AMPSException
 
AMPSException(String) - Constructor for exception com.crankuptheamps.client.exception.AMPSException
 
AMPSException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.AMPSException
 
AMPSException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.AMPSException
 
append(int, byte[], int, int) - Method in class com.crankuptheamps.client.FIXBuilder
Appends a tag and and value pair contained within a byte buffer to the FIX message.
append(int, String) - Method in class com.crankuptheamps.client.FIXBuilder
Appends a tag and value pair to the FIX message.
append(String, byte[], int, int) - Method in class com.crankuptheamps.client.NVFIXBuilder
Appends a tag and value pair contained within a byte buffer to the FIX message.
append(String, String) - Method in class com.crankuptheamps.client.NVFIXBuilder
Appends a tag and value pair to the FIX message.
array - Variable in class com.crankuptheamps.client.BlockPublishStore.ByteSequence
 
ArrayStoreBuffer - Class in com.crankuptheamps.client
ArrayStoreBuffer is a simple wrapper for a java array that maintains position.
ArrayStoreBuffer() - Constructor for class com.crankuptheamps.client.ArrayStoreBuffer
 
AuthDisabled - Static variable in class com.crankuptheamps.client.Message.Reason
 
authenticate(String, String) - Method in interface com.crankuptheamps.client.Authenticator
Called by AMPS.Client, just before the logon command is sent.
authenticate(String, String) - Method in class com.crankuptheamps.client.DefaultAuthenticator
Called by AMPS.Client, just before the logon command is sent.
AuthenticationException - Exception in com.crankuptheamps.client.exception
 
AuthenticationException() - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
 
AuthenticationException(String) - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
 
AuthenticationException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
 
AuthenticationException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.AuthenticationException
 
Authenticator - Interface in com.crankuptheamps.client
 
AuthenticatorFactory - Interface in com.crankuptheamps.spark
For command line custom authenticator support in spark.
AuthFailure - Static variable in class com.crankuptheamps.client.Message.Reason
 

B

BadFilter - Static variable in class com.crankuptheamps.client.Message.Reason
 
BadFilterException - Exception in com.crankuptheamps.client.exception
 
BadFilterException() - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
 
BadFilterException(String) - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
 
BadFilterException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
 
BadFilterException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadFilterException
 
BadRegexTopic - Static variable in class com.crankuptheamps.client.Message.Reason
 
BadRegexTopicException - Exception in com.crankuptheamps.client.exception
 
BadRegexTopicException() - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
 
BadRegexTopicException(String) - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
 
BadRegexTopicException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
 
BadRegexTopicException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.BadRegexTopicException
 
badUsage(String) - Method in class com.crankuptheamps.spark.SparkCommand
 
BlockPublishStore - Class in com.crankuptheamps.client
 
BlockPublishStore(BlockPublishStore.Buffer, int, boolean) - Constructor for class com.crankuptheamps.client.BlockPublishStore
 
BlockPublishStore(BlockPublishStore.Buffer, int) - Constructor for class com.crankuptheamps.client.BlockPublishStore
 
BlockPublishStore(BlockPublishStore.Buffer) - Constructor for class com.crankuptheamps.client.BlockPublishStore
 
BlockPublishStore.Buffer - Interface in com.crankuptheamps.client
 
BlockPublishStore.ByteSequence - Class in com.crankuptheamps.client
 
BlockPublishStore.ByteSequence() - Constructor for class com.crankuptheamps.client.BlockPublishStore.ByteSequence
 
BlockPublishStore.ByteSequence(byte[], long, long) - Constructor for class com.crankuptheamps.client.BlockPublishStore.ByteSequence
 
bookmarkDeltaSubscribe(MessageHandler, String, String, CommandId, String, String, long) - Method in class com.crankuptheamps.client.Client
Places a bookmark delta subscription with AMPS.
BookmarkField - Class in com.crankuptheamps.client.fields
 
BookmarkField(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.BookmarkField
 
BookmarkField() - Constructor for class com.crankuptheamps.client.fields.BookmarkField
 
BookmarkRingBuffer - Class in com.crankuptheamps.client
A ring buffer of bookmarks and activation status Used by all of the bookmark stores to track state of bookmarks we need to hold on to, either because they're active or because they're after an active one.
BookmarkRingBuffer() - Constructor for class com.crankuptheamps.client.BookmarkRingBuffer
Initializes the underlying array, and sets the "last discarded" value to something reasonable.
BookmarkRingBuffer.Entry - Class in com.crankuptheamps.client
Represents a single entry in an array of bookmarks
BookmarkRingBuffer.Entry() - Constructor for class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
BookmarkStore - Interface in com.crankuptheamps.client
 
BookmarkStoreResizeHandler - Interface in com.crankuptheamps.client
 
bookmarkSubscribe(MessageHandler, String, String, CommandId, String, String, long) - Method in class com.crankuptheamps.client.Client
Places a bookmark subscription with AMPS.
BooleanField - Class in com.crankuptheamps.client.fields
 
BooleanField() - Constructor for class com.crankuptheamps.client.fields.BooleanField
 
broadcastConnectionStateChanged(int) - Method in class com.crankuptheamps.client.Client
 
buffer - Variable in class com.crankuptheamps.client.fields.Field
 
byteAt(int) - Method in class com.crankuptheamps.client.fields.Field
 

C

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.
clear() - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
 
clear() - Method in class com.crankuptheamps.client.FIXBuilder
Clears self.
clear() - Method in class com.crankuptheamps.client.MemorySubscriptionManager
 
clear() - Method in class com.crankuptheamps.client.MessageRouter
Removes all routes from self.
clear() - Method in class com.crankuptheamps.client.NVFIXBuilder
Clears the current builder, resetting it to empty.
clear() - Method in interface com.crankuptheamps.client.SubscriptionManager
 
Client - Class in com.crankuptheamps.client
The base AMPS client object used in AMPS applications.
Client(String) - Constructor for class com.crankuptheamps.client.Client
Creates a client.
Client(String, int) - Constructor for class com.crankuptheamps.client.Client
Creates a client.
Client(String, Transport) - Constructor for class com.crankuptheamps.client.Client
Creates a client with a transport.
Client(String, Transport, int) - Constructor for class com.crankuptheamps.client.Client
Creates a client with a transport
Client.Bookmarks - Class in com.crankuptheamps.client
Functions that take a bookmark (String) such as Client.bookmarkSubscribe(com.crankuptheamps.client.MessageHandler, java.lang.String, java.lang.String, com.crankuptheamps.client.CommandId, java.lang.String, java.lang.String, long) can be passed a literal bookmark ID, or one of these special values.
Client.Bookmarks() - Constructor for class com.crankuptheamps.client.Client.Bookmarks
 
Client.Version - Class in com.crankuptheamps.client
 
Client.Version() - Constructor for class com.crankuptheamps.client.Client.Version
 
ClientDisconnectHandler - Interface in com.crankuptheamps.client
 
ClientDisconnectHandler2 - Interface in com.crankuptheamps.client
 
clone() - Method in class com.crankuptheamps.client.fields.BookmarkField
Provides a way to duplicate this object and retain its specific type (and hashcode() implementation).
close() - Method in class com.crankuptheamps.client.Client
Disconnect from the AMPS server.
close() - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
close() - Method in class com.crankuptheamps.client.MessageStream
Closes this MessageStream, unsubscribing from AMPS if applicable.
close() - Method in class com.crankuptheamps.client.PublishStore
 
close() - Method in class com.crankuptheamps.client.TCPTransport
 
close() - Method in interface com.crankuptheamps.client.Transport
 
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.spark - package com.crankuptheamps.spark
This package contains spark, a command line tool for working with AMPS.
Command - Class in com.crankuptheamps.client
Command is an encapsulation of a single AMPS command sent by the client.
Command() - Constructor for class com.crankuptheamps.client.Command
Create a new Command with no command type or arguments set.
Command(int) - Constructor for class com.crankuptheamps.client.Command
Create a Command with the Command field set.
Command(String) - Constructor for class com.crankuptheamps.client.Command
Create a Command with the Command field set.
CommandException - Exception in com.crankuptheamps.client.exception
 
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
 
CommandField() - Constructor for class com.crankuptheamps.client.fields.CommandField
 
CommandId - Class in com.crankuptheamps.client
 
CommandId(String) - Constructor for class com.crankuptheamps.client.CommandId
 
CommandOption - Class in com.crankuptheamps.spark
 
CommandOption(String, String, boolean) - Constructor for class com.crankuptheamps.spark.CommandOption
 
CommandOption(String, String, String) - Constructor for class com.crankuptheamps.spark.CommandOption
 
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
 
connect(String) - Method in class com.crankuptheamps.client.Client
Connects to the AMPS instance through the provided URI.
connect(String) - Method in class com.crankuptheamps.client.HAClient
 
connect(URI) - Method in class com.crankuptheamps.client.TCPTransport
 
connect(URI) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
connect(URI) - Method in interface com.crankuptheamps.client.Transport
 
connectAndLogon() - Method in class com.crankuptheamps.client.HAClient
Connects to the next server chosen for us by our ServerChooser.
Connected - Static variable in interface com.crankuptheamps.client.ConnectionStateListener
Constant passed when the client connects.
ConnectionException - Exception in com.crankuptheamps.client.exception
 
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
 
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
 
ConnectionStateListener - Interface in com.crankuptheamps.client
An interface that allows an application to be notified when the client connects or disconnects to an AMPS server.
constructTransportImpl(Protocol, Properties) - Method in class com.crankuptheamps.client.TCPTransport
 
copy() - Method in class com.crankuptheamps.client.fields.BookmarkField
 
copy() - Method in class com.crankuptheamps.client.fields.Field
 
copy() - Method in class com.crankuptheamps.client.FIXMessage
 
copy() - Method in class com.crankuptheamps.client.JSONMessage
 
copy() - Method in class com.crankuptheamps.client.Message
 
copy() - Method in class com.crankuptheamps.client.XMLMessage
 
copyFrom(Field) - Method in class com.crankuptheamps.client.fields.Field
 
createAuthenticator(String) - Method in interface com.crankuptheamps.spark.AuthenticatorFactory
Create an Authenticator object to use for logging on.
createAuthenticator(String) - Method in class com.crankuptheamps.spark.DefaultAuthenticatorFactory
 
createAuthenticator(String) - Method in class com.crankuptheamps.spark.SparkCommand
 
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
 
createSocket() - Method in class com.crankuptheamps.client.TCPTransportImpl
 
createTransport(Protocol) - Static method in class com.crankuptheamps.client.TCPTransport
 
createTransport(String, Protocol, Properties) - Static method in class com.crankuptheamps.client.TransportFactory
 

D

decoder - Variable in class com.crankuptheamps.client.Message
 
DefaultAuthenticator - Class in com.crankuptheamps.client
 
DefaultAuthenticator() - Constructor for class com.crankuptheamps.client.DefaultAuthenticator
 
DefaultAuthenticatorFactory - Class in com.crankuptheamps.spark
 
DefaultAuthenticatorFactory() - Constructor for class com.crankuptheamps.spark.DefaultAuthenticatorFactory
 
DefaultBookmarkStore - Class in com.crankuptheamps.client
 
DefaultBookmarkStore() - Constructor for class com.crankuptheamps.client.DefaultBookmarkStore
 
DefaultDisconnectHandler - Class in com.crankuptheamps.client
 
DefaultMessageHandler - Class in com.crankuptheamps.client
 
DefaultMessageHandler() - Constructor for class com.crankuptheamps.client.DefaultMessageHandler
 
DefaultServerChooser - Class in com.crankuptheamps.client
A simple ServerChooser that keeps a list of AMPS instances and Authenticators, and advances to the next one when failure occurs.
DefaultServerChooser() - Constructor for class com.crankuptheamps.client.DefaultServerChooser
 
DefaultSubscriptionManager - Class in com.crankuptheamps.client
 
DefaultSubscriptionManager() - Constructor for class com.crankuptheamps.client.DefaultSubscriptionManager
 
DefaultTransportFilter - Class in com.crankuptheamps.client
The DefaultTransportFilter is a no-op Filter.
DefaultTransportFilter() - Constructor for class com.crankuptheamps.client.DefaultTransportFilter
 
deleteByData(Client, String, String, String, int) - Method in class com.crankuptheamps.spark.SOWDeleteCommand
 
deleteByFilter(Client, String, String, int) - Method in class com.crankuptheamps.spark.SOWDeleteCommand
 
Deleted - Static variable in class com.crankuptheamps.client.Message.Reason
 
deliverAck(Message, int) - Method in class com.crankuptheamps.client.MessageRouter
Deliver a message that is known already to be an Ack.
deliverData(Message) - Method in class com.crankuptheamps.client.MessageRouter
Delivers a data message (not an Ack) to the registered route.
deliverData(Message, CommandId) - Method in class com.crankuptheamps.client.MessageRouter
Delivers a data message using a specific command ID from the message.
deltaPublish(byte[], int, int, byte[], int, int) - Method in class com.crankuptheamps.client.Client
Delta publish a message to an AMPS topic.
deltaPublish(String, String) - Method in class com.crankuptheamps.client.Client
Delta publish a message to an AMPS topic.
deltaPublish(byte[], int, int, byte[], int, int, int) - Method in class com.crankuptheamps.client.Client
Delta publish a message to an AMPS topic.
deltaPublish(String, String, int) - Method in class com.crankuptheamps.client.Client
Delta publish a message to an AMPS topic.
DeltaPublish - Static variable in class com.crankuptheamps.client.Message.Command
 
deltaSubscribe(MessageHandler, String, String, String, long) - Method in class com.crankuptheamps.client.Client
Places a delta subscription with AMPS.
deltaSubscribe(MessageHandler, String, String, String, long, String) - Method in class com.crankuptheamps.client.Client
Places a delta subscription with AMPS.
deltaSubscribe(MessageHandler, String, String, long) - Method in class com.crankuptheamps.client.Client
Places a delta subscription with AMPS.
deltaSubscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client
Places a delta subscription with AMPS.
DeltaSubscribe - Static variable in class com.crankuptheamps.client.Message.Command
 
discard(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Discards an entry by index.
discard(Field, long) - Method in interface com.crankuptheamps.client.BookmarkStore
Log a discard-bookmark entry to the persistent log based on a bookmark sequence number.
discard(Message) - Method in interface com.crankuptheamps.client.BookmarkStore
Log a discard-bookmark entry to the persistent log based on a Message.
discard(Field, long) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
discard(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
discard(Field, long) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
discard(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
discard(Field, long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
discard(Message) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
discard(Field, long) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
discard(Message) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
discard(long) - Method in interface com.crankuptheamps.client.Subscription
 
discardUpTo(long) - Method in class com.crankuptheamps.client.BlockPublishStore
 
discardUpTo(long) - Method in class com.crankuptheamps.client.HybridPublishStore
 
discardUpTo(long) - Method in interface com.crankuptheamps.client.Store
Discard all operations up to the index provided.
disconnect() - Method in class com.crankuptheamps.client.Client
Disconnect from the AMPS server.
disconnect() - Method in class com.crankuptheamps.client.HAClient
 
disconnect() - Method in class com.crankuptheamps.client.TCPTransport
 
disconnect() - Method in class com.crankuptheamps.client.TCPTransportImpl
 
disconnect() - Method in interface com.crankuptheamps.client.Transport
 
Disconnected - Static variable in interface com.crankuptheamps.client.ConnectionStateListener
Constant passed when the client disconnects.
DisconnectedException - Exception in com.crankuptheamps.client.exception
 
DisconnectedException() - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
 
DisconnectedException(String) - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
 
DisconnectedException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
 
DisconnectedException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.DisconnectedException
 
dumpArgs() - Method in class com.crankuptheamps.spark.SparkCommand
 
Duplicate - Static variable in class com.crankuptheamps.client.Message.Reason
 

E

encodeAckType(int) - Static method in class com.crankuptheamps.client.fields.AckTypeField
 
encodeCommand(int) - Static method in class com.crankuptheamps.client.fields.CommandField
 
encoder - Variable in class com.crankuptheamps.client.Message
 
encodeReason(int) - Static method in class com.crankuptheamps.client.fields.ReasonField
 
encodeStatus(int) - Static method in class com.crankuptheamps.client.fields.StatusField
 
EPOCH - Static variable in class com.crankuptheamps.client.Client.Bookmarks
Start the subscription at the beginning of the journal.
equals(Object) - Method in class com.crankuptheamps.client.CommandId
 
equals(Object) - Method in class com.crankuptheamps.client.fields.Field
 
examples - Variable in class com.crankuptheamps.spark.SparkCommand
 
exceptionListener - Variable in class com.crankuptheamps.client.Client
 
execute(Command) - Method in class com.crankuptheamps.client.Client
Execute the provided command and return messages received in response in a MessageStream.
execute(long, int, byte[], long, long, byte[], long, long, byte[], long, long) - Method in interface com.crankuptheamps.client.Store.StoreReplayer
Replay the specified operation.
execute(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int) - Method in interface com.crankuptheamps.client.Store.StoreReplayer
Replay the specified operation.
execute(long, int, byte[], long, long, byte[], long, long, int, CommandId) - Method in interface com.crankuptheamps.client.Store.StoreReplayer
Replay the specified operation.
executeAsync(Command, MessageHandler) - Method in class com.crankuptheamps.client.Client
Execute the provided command on a background thread and provide messages received in response to the handler provided.
Expired - Static variable in class com.crankuptheamps.client.Message.Reason
 
extras - Variable in class com.crankuptheamps.spark.SparkCommand
 

F

failedWrite(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int) - Method in interface com.crankuptheamps.client.FailedWriteHandler
The AMPS instance reports that a write has failed.
FailedWriteHandler - Interface in com.crankuptheamps.client
An interface for receiving information on messages that you've written, but for which the server indicates were not persisted.
Failure - Static variable in class com.crankuptheamps.client.Message.Status
 
Field - Class in com.crankuptheamps.client.fields
 
Field() - Constructor for class com.crankuptheamps.client.fields.Field
 
Field(String) - Constructor for class com.crankuptheamps.client.fields.Field
 
Field(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.Field
 
fieldSeparator - Variable in class com.crankuptheamps.client.FIXMessage
 
fieldSeparator - Variable in class com.crankuptheamps.client.FIXProtocol
 
finalize() - Method in class com.crankuptheamps.client.PublishStore
 
find(BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Searches valid Entrys for the given bookmark
findRoute(CommandId) - Method in class com.crankuptheamps.client.MessageRouter
Find and return a route
FIXBuilder - Class in com.crankuptheamps.client
 
FIXBuilder(int, byte) - Constructor for class com.crankuptheamps.client.FIXBuilder
 
FIXMessage - Class in com.crankuptheamps.client
 
FIXMessage(byte, byte, byte, CharsetEncoder, CharsetDecoder, boolean) - Constructor for class com.crankuptheamps.client.FIXMessage
 
FIXProtocol - Class in com.crankuptheamps.client
 
FIXProtocol() - Constructor for class com.crankuptheamps.client.FIXProtocol
 
FIXProtocol(Properties) - Constructor for class com.crankuptheamps.client.FIXProtocol
 
FIXProtocol(byte, byte, byte) - Constructor for class com.crankuptheamps.client.FIXProtocol
 
FIXProtocolParser - Class in com.crankuptheamps.client
 
FIXProtocolParser(FIXProtocol) - Constructor for class com.crankuptheamps.client.FIXProtocolParser
 
FIXShredder - Class in com.crankuptheamps.client
 
FIXShredder(byte) - Constructor for class com.crankuptheamps.client.FIXShredder
 
flush() - Method in class com.crankuptheamps.client.BlockPublishStore
 
flush(long) - Method in class com.crankuptheamps.client.BlockPublishStore
 
flush() - Method in class com.crankuptheamps.client.Client
Clear the queued messages which may be waiting in the transport
flush(long) - Method in class com.crankuptheamps.client.Client
Clear the queued messages which may be waiting in the transport
flush() - Method in class com.crankuptheamps.client.HybridPublishStore
 
flush(long) - Method in class com.crankuptheamps.client.HybridPublishStore
 
Flush - Static variable in class com.crankuptheamps.client.Message.Command
 
flush() - Method in interface com.crankuptheamps.client.Store
Wait for the store to discard everything that has been stored up to the point in time when flush is called, then return.
flush(long) - Method in interface com.crankuptheamps.client.Store
Wait for the store to discard everything that has been stored up to the point in time when flush is called, then return.
flush() - Method in class com.crankuptheamps.client.TCPTransport
 
flush(long) - Method in class com.crankuptheamps.client.TCPTransport
 
flush() - Method in class com.crankuptheamps.client.TCPTransportImpl
 
flush(long) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
flush() - Method in interface com.crankuptheamps.client.Transport
 
flush(long) - Method in interface com.crankuptheamps.client.Transport
 
Functor - Class in com.crankuptheamps.client
 

G

get() - Method in class com.crankuptheamps.client.Pool
Returns an object from the pool, growing self if necessary (by initialSize).
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.
getBatchSize() - Method in class com.crankuptheamps.client.Command
Get the batchSize for this command.
getBatchSize() - Method in class com.crankuptheamps.client.Message
Returns the batch size for this message.
getBookmark() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.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.
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
 
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
 
getByte() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
getByte() - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
getBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
getBytes(BlockPublishStore.ByteSequence) - 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() - Method in class com.crankuptheamps.client.NVFIXBuilder
 
getClientName() - Method in class com.crankuptheamps.client.Message
Gets the client name on this message.
getClientNameRaw() - Method in class com.crankuptheamps.client.Message
Gets the client name on this message.
getClientSequenceNumber() - Method in class com.crankuptheamps.client.Command
Get the client sequence number for this command.
getCommand() - Method in class com.crankuptheamps.client.Command
Return the command type for this command.
getCommand() - Method in class com.crankuptheamps.client.Message
Returns the command for this message, indicating the type of of message this is.
getCommandId() - Method in class com.crankuptheamps.client.Command
 
getCommandId() - Method in class com.crankuptheamps.client.Message
Gets the CommandId on this message.
getCommandId(CommandId) - Method in class com.crankuptheamps.client.Message
Gets the CommandId on this message by copying it into the provided CommandId object.
getCommandIdRaw() - Method in class com.crankuptheamps.client.Message
Gets the CommandId on this message.
getConnectionInfo() - Method in class com.crankuptheamps.client.Client
Assembles a new ConnectionInfo with the state of this client and associated classes.
getConnectionInfo() - Method in class com.crankuptheamps.client.HAClient
Assembles a new ConnectionInfo with the state of this client and associated classes.
getCorrelationId() - Method in class com.crankuptheamps.client.Command
Returns the correlation Id for 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
 
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
 
getCurrentURI() - Method in interface com.crankuptheamps.client.ServerChooser
Returns the current URI.
getData() - Method in class com.crankuptheamps.client.Command
Get the data for this command.
getData() - Method in class com.crankuptheamps.client.Message
Returns the payload of the message.
getDataRaw() - Method in class com.crankuptheamps.client.Message
Returns the payload of the message.
getDefaultValue() - Method in class com.crankuptheamps.spark.CommandOption
 
getDescription() - Method in class com.crankuptheamps.spark.CommandOption
 
getDisconnectHandler() - Method in class com.crankuptheamps.client.Client
Returns the current ClientDisconnectHandler set on self.
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
 
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.
getExpiration() - Method in class com.crankuptheamps.client.Command
Get the expiration from this command.
getExpiration() - Method in class com.crankuptheamps.client.Message
Returns the expiration set for this message.
getFilter() - Method in class com.crankuptheamps.client.Command
Get the filter for this command.
getFilter() - Method in class com.crankuptheamps.client.Message
 
getFilterRaw() - Method in class com.crankuptheamps.client.Message
Returns the filter on this message.
getGroupSeqNo() - Method in class com.crankuptheamps.client.Message
Get the group sequence number.
getIndex() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
getInt() - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
getInt() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
getInt() - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
getLastDiscarded() - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Returns the "last discarded" bookmark.
getLength() - Method in class com.crankuptheamps.client.Message
Returns the length of the message.
getLong() - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
getLong() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
getLong() - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
getLowestUnpersisted() - Method in class com.crankuptheamps.client.BlockPublishStore
 
getLowestUnpersisted() - Method in class com.crankuptheamps.client.HybridPublishStore
 
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.
getMaxMessages() - Method in class com.crankuptheamps.client.Message
Deprecated. This header is no longer used by AMPS.
getMessageId() - Method in class com.crankuptheamps.client.Message
Deprecated. This header is no longer used by AMPS.
getMessageIdRaw() - Method in class com.crankuptheamps.client.Message
Deprecated. This header is no longer used by AMPS.
getMessageStream() - Method in class com.crankuptheamps.client.FIXProtocol
 
getMessageStream() - Method in class com.crankuptheamps.client.JSONProtocol
 
getMessageStream() - Method in class com.crankuptheamps.client.NVFIXProtocol
 
getMessageStream() - Method in interface com.crankuptheamps.client.Protocol
 
getMessageStream() - Method in class com.crankuptheamps.client.XMLProtocol
 
getMostRecent(Field) - Method in interface com.crankuptheamps.client.BookmarkStore
Returns the most recent bookmark from the log that ought to be used for (re-)subscriptions.
getMostRecent(Field) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
getMostRecent(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
getMostRecent(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
getMostRecent(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
getMostRecent() - Method in interface com.crankuptheamps.client.Subscription
 
getMostRecentList() - Method in interface com.crankuptheamps.client.Subscription
 
getName() - Method in class com.crankuptheamps.client.Client
Return the name of the Client.
getName() - Method in class com.crankuptheamps.spark.CommandOption
 
getName() - Method in class com.crankuptheamps.spark.SparkCommand
 
getOldestBookmarkSeq(Field) - Method in interface com.crankuptheamps.client.BookmarkStore
Called to retrieve the sequence number of the oldest bookmark in the store.
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
getOldestBookmarkSeq(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
getOldestBookmarkSeq() - Method in interface com.crankuptheamps.client.Subscription
 
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 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.
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
 
getPosition() - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
getPosition() - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
getPublisherId() - Method in class com.crankuptheamps.client.fields.BookmarkField
 
getPublishStore() - Method in class com.crankuptheamps.client.Client
Returns the underlying publish store for this client.
getQueryId() - Method in class com.crankuptheamps.client.Command
Get the queryId for this command.
getQueryId() - Method in class com.crankuptheamps.client.Message
Returns the QueryId for this message.
getQueryId(CommandId) - Method in class com.crankuptheamps.client.Message
Returns the QueryId for this message by copying it into the provided CommandId.
getQueryIdRaw() - Method in class com.crankuptheamps.client.Message
Returns the QueryId for this message.
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.
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.
getReconnectDelay() - Method in class com.crankuptheamps.client.HAClient
Returns the time delay between reconnect events.
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.
getSendEmpties() - Method in class com.crankuptheamps.client.Message
Gets the value of the send empties header.
getSendMatchingIds() - Method in class com.crankuptheamps.client.Message
Gets the value of the send keys header.
getSendOOF() - Method in class com.crankuptheamps.client.Message
Gets the value of the send OOF header.
getSequence() - Method in class com.crankuptheamps.client.Message
Returns the sequence number for this message.
getSequenceNumber() - Method in class com.crankuptheamps.client.fields.BookmarkField
 
getSequenceRaw() - Method in class com.crankuptheamps.client.Message
Returns the sequence number for this message.
getServerChooser() - Method in class com.crankuptheamps.client.HAClient
Returns the current ServerChooser.
getServerVersion() - Method in class com.crankuptheamps.client.Client
Return the server version retrieved during logon.
getSize() - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
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
 
getSize() - Method in class com.crankuptheamps.client.NVFIXBuilder
 
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.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.
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.
getSubId() - Method in class com.crankuptheamps.client.Command
Get the subId for 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.
getSubIdRaw() - Method in class com.crankuptheamps.client.Message
Gets the SubId of this message.
getSubIds() - Method in class com.crankuptheamps.client.Message
The set of SubIds for this message.
getSubIdsRaw() - Method in class com.crankuptheamps.client.Message
The set of SubIds for this message.
getSubscription() - Method in class com.crankuptheamps.client.Message
Gets the subscription for this message.
getSubscriptionManager() - Method in class com.crankuptheamps.client.Client
Returns the SubscriptionManager instance used for recording active subscriptions.
getText() - Method in class com.crankuptheamps.client.fields.ReasonField
 
getTimeout() - Method in class com.crankuptheamps.client.Command
Get the timeout for 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.
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 for this command.
getTopic() - Method in class com.crankuptheamps.client.Message
Return the topic that the message applies to.
getTopicMatches() - Method in class com.crankuptheamps.client.Message
Returns the number of matching topics for the command that this message was produced in response to.
getTopicRaw() - Method in class com.crankuptheamps.client.Message
Return the topic that the message applies to.
getTopN() - Method in class com.crankuptheamps.client.Command
Get the topN value for this command.
getTopN() - Method in class com.crankuptheamps.client.Message
Get the TopN parameter for this message.
getTransport() - Method in class com.crankuptheamps.client.Client
Return the underlying transport.
getURI() - Method in class com.crankuptheamps.client.Client
Return the URI the Client is connected to.
getUserId() - Method in class com.crankuptheamps.client.Message
Get the UserId for this message.
getUserIdRaw() - Method in class com.crankuptheamps.client.Message
Get the UserId for this message.
getValue() - Method in class com.crankuptheamps.client.fields.AckTypeField
 
getValue() - Method in class com.crankuptheamps.client.fields.BooleanField
 
getValue() - Method in class com.crankuptheamps.client.fields.CommandField
 
getValue() - Method in class com.crankuptheamps.client.fields.IntegerField
 
getValue() - Method in class com.crankuptheamps.client.fields.LongField
 
getValue() - Method in class com.crankuptheamps.client.fields.ReasonField
 
getValue() - Method in class com.crankuptheamps.client.fields.StatusField
 
getValue(CharsetDecoder) - Method in class com.crankuptheamps.client.fields.StringField
 
getValue(ByteBuffer) - Method in class com.crankuptheamps.client.fields.StringField
 
getValue(CommandId) - Method in class com.crankuptheamps.client.fields.StringField
 
getValue() - Method in class com.crankuptheamps.spark.CommandOption
 
getVersion() - Method in class com.crankuptheamps.client.Client
Return the build number for the client that is stored in the Manifes.mf of the jar file.
getVersion() - Method in class com.crankuptheamps.client.Message
Returns the version of the AMPS server, provided in response to a logon.
getVersion() - Method in class com.crankuptheamps.client.TCPTransport
 
getVersion() - Method in interface com.crankuptheamps.client.Transport
 
getVersionAsInt(String) - Static method in class com.crankuptheamps.client.Client
Return the numeric value for the given version string with the pattern: Major.Minor.Maintenance.Hotfix The version uses 2 digits each for major minor maintenance and hotfix i.e., 3.8.1.5 will return 3080105 Version strings passed in can be shortened to not include all levels so 3.8 will return 3080000.
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.
GroupBegin - Static variable in class com.crankuptheamps.client.Message.Command
 
GroupEnd - Static variable in class com.crankuptheamps.client.Message.Command
 
growFreeListIfEmpty() - Method in class com.crankuptheamps.client.BlockPublishStore
 

H

HAClient - Class in com.crankuptheamps.client
A highly-available AMPS Client object that automatically reconnects and re-subscribes to AMPS instances upon disconnect.
HAClient(String) - Constructor for class com.crankuptheamps.client.HAClient
Constructs a new HAClient.
HAClient.HADisconnectHandler - Class in com.crankuptheamps.client
 
HAClient.HADisconnectHandler() - Constructor for class com.crankuptheamps.client.HAClient.HADisconnectHandler
 
handleCloseEvent(int, String, Exception) - Method in class com.crankuptheamps.client.TCPTransport
 
handleCloseEvent(int, String, Exception) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
handleCloseEvent(int, String, Exception) - Method in interface com.crankuptheamps.client.Transport
 
HAS_EXTENDED_METADATA - Static variable in class com.crankuptheamps.client.BlockPublishStore
 
hasExpiration() - Method in class com.crankuptheamps.client.Command
Returns true if this command has an expiration set.
hashCode() - Method in class com.crankuptheamps.client.CommandId
 
hashCode() - Method in class com.crankuptheamps.client.fields.BookmarkField
 
hashCode() - Method in class com.crankuptheamps.client.fields.Field
 
hasNext() - Method in class com.crankuptheamps.client.MessageStream
 
hasValue() - Method in class com.crankuptheamps.spark.CommandOption
 
headerSeparator - Variable in class com.crankuptheamps.client.FIXMessage
 
headerSeparator - Variable in class com.crankuptheamps.client.FIXProtocol
 
Heartbeat - Static variable in class com.crankuptheamps.client.Message.Command
 
help() - Method in class com.crankuptheamps.spark.SparkCommand
 
HelpCommand - Class in com.crankuptheamps.spark
 
HelpCommand(String, TreeMap<String, SparkCommand>) - Constructor for class com.crankuptheamps.spark.HelpCommand
 
HybridPublishStore - Class in com.crankuptheamps.client
PublishStore that stores first in memory, and swaps excess out to disk.
HybridPublishStore(String, int) - Constructor for class com.crankuptheamps.client.HybridPublishStore
 

I

id - Variable in class com.crankuptheamps.client.CommandId
 
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
 
instance - Static variable in class com.crankuptheamps.client.DefaultDisconnectHandler
 
instance - Static variable in class com.crankuptheamps.client.DefaultMessageHandler
 
IntegerField - Class in com.crankuptheamps.client.fields
 
IntegerField() - Constructor for class com.crankuptheamps.client.fields.IntegerField
 
InvalidBookmark - Static variable in class com.crankuptheamps.client.Message.Reason
 
InvalidOrderBy - Static variable in class com.crankuptheamps.client.Message.Reason
 
InvalidProtocolOptionsException - Exception in com.crankuptheamps.client.exception
 
InvalidProtocolOptionsException() - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
 
InvalidProtocolOptionsException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
 
InvalidProtocolOptionsException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
 
InvalidProtocolOptionsException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidProtocolOptionsException
 
InvalidTopic - Static variable in class com.crankuptheamps.client.Message.Reason
 
InvalidTopicException - Exception in com.crankuptheamps.client.exception
 
InvalidTopicException() - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
 
InvalidTopicException(String) - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
 
InvalidTopicException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
 
InvalidTopicException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.InvalidTopicException
 
InvalidTransportOptionsException - Exception in com.crankuptheamps.client.exception
 
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
 
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
 
invoke(Client) - Method in interface com.crankuptheamps.client.ClientDisconnectHandler
 
invoke(Client, Exception) - Method in interface com.crankuptheamps.client.ClientDisconnectHandler2
 
invoke(Client) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
 
invoke(Transport, Exception) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
 
invoke(Message) - Method in class com.crankuptheamps.client.DefaultMessageHandler
 
invoke() - Method in class com.crankuptheamps.client.Functor
 
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
 
invoke(Transport, Exception) - Method in interface com.crankuptheamps.client.TransportDisconnectHandler
 
isActive() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
isConnected() - Method in class com.crankuptheamps.client.MessageStream
 
isDaemon() - Static method in class com.crankuptheamps.client.TCPTransport
 
isDiscarded(Message) - Method in interface com.crankuptheamps.client.BookmarkStore
Called for each arriving message to determine if the application has already seen this bookmark and should not be reprocessed.
isDiscarded(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
isDiscarded(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
isDiscarded(Message) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
isDiscarded(Message) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
isDiscarded(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
 
isEmpty() - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Returns if the buffer is currently empty.
isNull() - Method in class com.crankuptheamps.client.fields.Field
 
isPersisted() - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
isRequired() - Method in class com.crankuptheamps.spark.CommandOption
 
isSow() - Method in class com.crankuptheamps.client.Command
Returns true if this command queries a SOW.
isSubscribe() - Method in class com.crankuptheamps.client.Command
Returns true if this command creates a subscription.
iterator() - Method in class com.crankuptheamps.client.MessageStream
 

J

JSONMessage - Class in com.crankuptheamps.client
 
JSONMessage(CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.JSONMessage
 
JSONProtocol - Class in com.crankuptheamps.client
 
JSONProtocol() - Constructor for class com.crankuptheamps.client.JSONProtocol
 
JSONProtocol(Properties) - Constructor for class com.crankuptheamps.client.JSONProtocol
 
JSONProtocolParser - Class in com.crankuptheamps.client
 
JSONProtocolParser(JSONProtocol) - Constructor for class com.crankuptheamps.client.JSONProtocolParser
 

L

LATIN1 - Static variable in class com.crankuptheamps.client.fields.AckTypeField
 
LATIN1 - Static variable in class com.crankuptheamps.client.fields.BooleanField
 
LATIN1 - Static variable in class com.crankuptheamps.client.fields.CommandField
 
LATIN1 - Static variable in class com.crankuptheamps.client.fields.ReasonField
 
LATIN1 - Static variable in class com.crankuptheamps.client.fields.StatusField
 
LATIN1 - Static variable in class com.crankuptheamps.client.fields.StringField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.AckTypeField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.BooleanField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.CommandField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.IntegerField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.LongField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.StatusField
 
LATIN1_ZERO - Static variable in class com.crankuptheamps.client.fields.StringField
 
len - Variable in class com.crankuptheamps.client.BlockPublishStore.ByteSequence
 
length - Variable in class com.crankuptheamps.client.fields.Field
 
Live - Static variable in class com.crankuptheamps.client.Message.Options
 
log(BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Logs the bookmark by allocating an Entry, setting the Entry to active, copying the bookmark value to that entry, and returning the index of that entry.
log(Message) - Method in interface com.crankuptheamps.client.BookmarkStore
Log a bookmark to the persistent log.
log(Message) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
log(Message) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
log(Message) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
log(Message) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
log(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
 
LoggedBookmarkStore - Class in com.crankuptheamps.client
LoggedBookmarkStore implements a sequentially written log of incoming and discarded messages.
LoggedBookmarkStore(String) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore
 
LoggedBookmarkStore(String, int) - Constructor for class com.crankuptheamps.client.LoggedBookmarkStore
 
logon(long) - Method in class com.crankuptheamps.client.Client
Logs into AMPS with the parameters provided in the connect method.
logon(long, Authenticator) - Method in class com.crankuptheamps.client.Client
Logs into AMPS with the parameters provided in the connect method.
logon() - Method in class com.crankuptheamps.client.Client
Logs into AMPS with the parameters provided in the connect method.
Logon - Static variable in class com.crankuptheamps.client.Message.Command
 
LongField - Class in com.crankuptheamps.client.fields
 
LongField() - Constructor for class com.crankuptheamps.client.fields.LongField
 

M

main(String[]) - Static method in class com.crankuptheamps.spark.Spark
 
Match - Static variable in class com.crankuptheamps.client.Message.Reason
 
MemoryBookmarkStore - Class in com.crankuptheamps.client
Implements a bookmark store useful for handling server failover scenarios, but without a backing store to recover from subscriber failure.
MemoryBookmarkStore() - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore
 
MemoryBookmarkStore(int) - Constructor for class com.crankuptheamps.client.MemoryBookmarkStore
Initialize self with a target number of subscriptions to store
MemoryPublishStore - Class in com.crankuptheamps.client
A PublishStore used to remember things you've published, in case of failover to an AMPS secondary.
MemoryPublishStore(int) - Constructor for class com.crankuptheamps.client.MemoryPublishStore
 
MemoryStoreBuffer - Class in com.crankuptheamps.client
 
MemoryStoreBuffer() - Constructor for class com.crankuptheamps.client.MemoryStoreBuffer
 
MemorySubscriptionManager - Class in com.crankuptheamps.client
 
MemorySubscriptionManager() - Constructor for class com.crankuptheamps.client.MemorySubscriptionManager
 
Message - Class in com.crankuptheamps.client
 
Message(CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.Message
 
Message.AckType - Class in com.crankuptheamps.client
 
Message.AckType() - Constructor for class com.crankuptheamps.client.Message.AckType
 
Message.Command - Class in com.crankuptheamps.client
 
Message.Command() - Constructor for class com.crankuptheamps.client.Message.Command
 
Message.Options - Class in com.crankuptheamps.client
Represents the options for an AMPS command.
Message.Options() - Constructor for class com.crankuptheamps.client.Message.Options
 
Message.Reason - Class in com.crankuptheamps.client
 
Message.Reason() - Constructor for class com.crankuptheamps.client.Message.Reason
 
Message.Status - Class in com.crankuptheamps.client
 
Message.Status() - Constructor for class com.crankuptheamps.client.Message.Status
 
MessageHandler - Interface in com.crankuptheamps.client
Interface for classes the handle AMPS messages.
MessageRouter - Class in com.crankuptheamps.client
MessageRouter is used to register and manage a list of handler objects for messages, and then to route messages to those handlers as messages arrive.
MessageRouter() - Constructor for class com.crankuptheamps.client.MessageRouter
 
messageSeparator - Variable in class com.crankuptheamps.client.FIXMessage
 
messageSeparator - Variable in class com.crankuptheamps.client.FIXProtocol
 
MessageStream - Class in com.crankuptheamps.client
MessageStream provides an iteration abstraction over the results of an AMPS command such as a subscribe, a SOW query, or SOW delete.
MessageStream(Client) - Constructor for class com.crankuptheamps.client.MessageStream
 
MIN_MULTI_BOOKMARK_VERSION - Static variable in class com.crankuptheamps.client.Client
 
MIN_PERSISTED_BOOKMARK_VERSION - Static variable in class com.crankuptheamps.client.Client
 
MINIMUM_SERVER_VERSION - Static variable in class com.crankuptheamps.client.Message
 
MOST_RECENT - Static variable in class com.crankuptheamps.client.Client.Bookmarks
Start the subscription at the first undiscarded message in the bookmark store, or at the end of the bookmark store if all messages have been discarded.

N

name - Variable in class com.crankuptheamps.spark.SparkCommand
 
NameInUse - Static variable in class com.crankuptheamps.client.Message.Reason
 
NameInUseException - Exception in com.crankuptheamps.client.exception
 
NameInUseException() - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
 
NameInUseException(String) - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
 
NameInUseException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
 
NameInUseException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.NameInUseException
 
needsSequenceNumber() - Method in class com.crankuptheamps.client.Command
Returns true if this command can be associated with a client sequence number.
next() - Method in class com.crankuptheamps.client.DefaultServerChooser
 
next() - Method in class com.crankuptheamps.client.MessageStream
 
next() - Method in interface com.crankuptheamps.client.ServerChooser
Advances the server chooser to the next server it deems appropriate to connect with.
nextIdentifier() - Static method in class com.crankuptheamps.client.CommandId
 
NoEmpties - Static variable in class com.crankuptheamps.client.Message.Options
 
None - Static variable in class com.crankuptheamps.client.Message.AckType
 
None - Static variable in class com.crankuptheamps.client.Message.Options
 
None - Static variable in class com.crankuptheamps.client.Message.Reason
 
None - Static variable in class com.crankuptheamps.client.Message.Status
 
noPersistedAcks() - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Called to indicate that the server won't provide persisted acks for the bookmarks so anything that is discarded should be assumed persisted.
noPersistedAcks(Field) - Method in interface com.crankuptheamps.client.BookmarkStore
Called internally to let the bookmark store know that the AMPS server version doesn't support persisted acks for bookmarks.
noPersistedAcks(Field) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
noPersistedAcks(Field) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
noPersistedAcks(Field) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
noPersistedAcks(Field) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
noPersistedAcks() - Method in interface com.crankuptheamps.client.Subscription
 
NotEntitled - Static variable in class com.crankuptheamps.client.Message.Reason
 
NotEntitledException - Exception in com.crankuptheamps.client.exception
 
NotEntitledException() - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
 
NotEntitledException(String) - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
 
NotEntitledException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
 
NotEntitledException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.NotEntitledException
 
NOW - Static variable in class com.crankuptheamps.client.Client.Bookmarks
Start the subscription at the point in time when AMPS processes the subscription.
NVFIXBuilder - Class in com.crankuptheamps.client
 
NVFIXBuilder(int, byte) - Constructor for class com.crankuptheamps.client.NVFIXBuilder
 
NVFIXMessage - Class in com.crankuptheamps.client
 
NVFIXMessage(byte, byte, byte, CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.NVFIXMessage
 
NVFIXProtocol - Class in com.crankuptheamps.client
 
NVFIXProtocol() - Constructor for class com.crankuptheamps.client.NVFIXProtocol
 
NVFIXProtocol(Properties) - Constructor for class com.crankuptheamps.client.NVFIXProtocol
 
NVFIXProtocol(byte, byte, byte) - Constructor for class com.crankuptheamps.client.NVFIXProtocol
 
NVFIXProtocolParser - Class in com.crankuptheamps.client
 
NVFIXProtocolParser(NVFIXProtocol) - Constructor for class com.crankuptheamps.client.NVFIXProtocolParser
 
NVFIXShredder - Class in com.crankuptheamps.client
 
NVFIXShredder(byte) - Constructor for class com.crankuptheamps.client.NVFIXShredder
 

O

offset - Variable in class com.crankuptheamps.client.BlockPublishStore.ByteSequence
 
OOF - Static variable in class com.crankuptheamps.client.Message.Command
 
OOF - Static variable in class com.crankuptheamps.client.Message.Options
 
optional - Variable in class com.crankuptheamps.spark.SparkCommand
 
options - Variable in class com.crankuptheamps.spark.SparkCommand
 
Other - Static variable in class com.crankuptheamps.client.Message.Reason
 
outgoing(ByteBuffer) - Method in class com.crankuptheamps.client.DefaultTransportFilter
 
outgoing(ByteBuffer) - Method in interface com.crankuptheamps.client.TransportFilter
Called when (typically just before) raw data is sent to the AMPS instance.
outgoing(ByteBuffer) - Method in class com.crankuptheamps.client.TransportTraceFilter
 

P

Parsed - Static variable in class com.crankuptheamps.client.Message.AckType
 
persisted(BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Mark all records up to the and including the provided bookmark as safe for discard and discard all appropriate bookmarks.
persisted(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
 
persisted(Field, BookmarkField) - Method in interface com.crankuptheamps.client.BookmarkStore
Called to mark a message as safely persisted by AMPS to all of its sync replication destination.
persisted(Field, long) - Method in interface com.crankuptheamps.client.BookmarkStore
Called to mark a message as safely persisted by AMPS to all of its sync replication destination.
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
 
persisted(Field, long) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
Persisted - Static variable in class com.crankuptheamps.client.Message.AckType
 
persisted(Field, BookmarkField) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
persisted(Field, long) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
persisted(long) - Method in interface com.crankuptheamps.client.Subscription
 
persisted(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
 
persistedAcks() - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Called to check if persisted acks are expected.
PingCommand - Class in com.crankuptheamps.spark
 
PingCommand(String) - Constructor for class com.crankuptheamps.spark.PingCommand
 
Pool<T> - Class in com.crankuptheamps.client
A simple generic instance pool for objects that take a while to construct.
Pool(Class<T>, int) - Constructor for class com.crankuptheamps.client.Pool
Constructs a pool with the given size
position - Variable in class com.crankuptheamps.client.fields.Field
 
preInvoke(int) - Method in class com.crankuptheamps.client.DefaultDisconnectHandler
 
preInvoke(int) - Method in interface com.crankuptheamps.client.TransportDisconnectHandler
 
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
 
process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.FIXProtocolParser
 
process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.JSONProtocolParser
 
process(ByteBuffer, int, MessageHandler) - Method in interface com.crankuptheamps.client.ProtocolParser
 
process(ByteBuffer, int, MessageHandler) - Method in class com.crankuptheamps.client.XMLProtocolParser
 
Processed - Static variable in class com.crankuptheamps.client.Message.AckType
 
Protocol - Interface in com.crankuptheamps.client
 
ProtocolException - Exception in com.crankuptheamps.client.exception
 
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
 
ProtocolFactory() - Constructor for class com.crankuptheamps.client.ProtocolFactory
 
ProtocolNotFoundException - Exception in com.crankuptheamps.client.exception
 
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
 
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
 
PublishCommand - Class in com.crankuptheamps.spark
 
PublishCommand(String) - Constructor for class com.crankuptheamps.spark.PublishCommand
 
publishFlush() - Method in class com.crankuptheamps.client.Client
Clear the queued messages which may be waiting in the transport, publish store or in the AMPS publish queue.
publishFlush(long) - Method in class com.crankuptheamps.client.Client
Return when all published messages have been confirmed to have made it through the publish queue inside the AMPS instnace.
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
 
purge() - Method in interface com.crankuptheamps.client.BookmarkStore
Called to purge the contents of this store.
purge() - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
purge() - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
purge() - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
purge() - Method in class com.crankuptheamps.client.RingBookmarkStore
 
putByte(byte) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
putByte(byte) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
putByte(byte) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
putBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
putBytes(BlockPublishStore.ByteSequence) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
putBytes(BlockPublishStore.ByteSequence) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
putInt(int) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
putInt(int) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
putInt(int) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
putLong(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
putLong(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
putLong(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 

R

readQueueSize() - Method in class com.crankuptheamps.client.TCPTransport
 
readQueueSize() - Method in class com.crankuptheamps.client.TCPTransportImpl
 
readQueueSize() - Method in interface com.crankuptheamps.client.Transport
 
ReasonField - Class in com.crankuptheamps.client.fields
 
ReasonField() - Constructor for class com.crankuptheamps.client.fields.ReasonField
 
Received - Static variable in class com.crankuptheamps.client.Message.AckType
 
recover() - Method in class com.crankuptheamps.client.BlockPublishStore
 
register(String, String) - Static method in class com.crankuptheamps.client.ProtocolFactory
 
register(String, String) - Static method in class com.crankuptheamps.client.TransportFactory
Registers a new Transport and URI prefix with the AMPS Client.
relog(long, BookmarkField) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Re-logs the bookmark by copying an Entry to a new location and returning the index of that new location.
remove() - Method in class com.crankuptheamps.client.MessageStream
 
removeConnectionStateListener(ConnectionStateListener) - Method in class com.crankuptheamps.client.Client
Removes a ConnectionStateListener from being invoked when this client connects or disconnects.
removeRoute(CommandId) - Method in class com.crankuptheamps.client.MessageRouter
Remove a route from self.
Replace - Static variable in class com.crankuptheamps.client.Message.Options
 
replay(Store.StoreReplayer) - Method in class com.crankuptheamps.client.BlockPublishStore
 
replay(Store.StoreReplayer) - Method in class com.crankuptheamps.client.HybridPublishStore
 
replay(Store.StoreReplayer) - Method in interface com.crankuptheamps.client.Store
Replay all operations in the store using the provided StoreReplayer.
replaySingle(Store.StoreReplayer, long) - Method in class com.crankuptheamps.client.BlockPublishStore
 
replaySingle(Store.StoreReplayer, long) - Method in class com.crankuptheamps.client.HybridPublishStore
 
replaySingle(Store.StoreReplayer, long) - Method in interface com.crankuptheamps.client.Store
Replay the operation at the specified index.
reportFailure(Exception, ConnectionInfo) - Method in class com.crankuptheamps.client.DefaultServerChooser
 
reportFailure(Exception, ConnectionInfo) - Method in interface com.crankuptheamps.client.ServerChooser
Called by the HAClient when an error occurs connecting to the current URI, and/or when an error occurs logging on.
reportSuccess(ConnectionInfo) - Method in class com.crankuptheamps.client.DefaultServerChooser
 
reportSuccess(ConnectionInfo) - Method in interface com.crankuptheamps.client.ServerChooser
Called by the HAClient when successfully connected and logged on to the current instance.
required - Variable in class com.crankuptheamps.spark.SparkCommand
 
reset(int) - Method in class com.crankuptheamps.client.Command
Resets this command with a new Command type and re-initializes all other fields.
reset(String) - Method in class com.crankuptheamps.client.Command
Resets this command with a new Command type and re-initializes all other fields.
reset() - Method in class com.crankuptheamps.client.fields.Field
 
reset() - Method in class com.crankuptheamps.client.Message
 
reset() - Static method in class com.crankuptheamps.client.TransportFactory
Resets self to the default state, unregistering any Transports registered at runtime.
resubscribe(Client) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
 
resubscribe(Client) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
 
resubscribe(Client) - Method in interface com.crankuptheamps.client.SubscriptionManager
 
retry(String, String) - Method in interface com.crankuptheamps.client.Authenticator
Called when a logon "ack" is received with a status of "retry".
retry(String, String) - Method in class com.crankuptheamps.client.DefaultAuthenticator
Called when a logon "ack" is received with a status of "retry".
Retry - Static variable in class com.crankuptheamps.client.Message.Status
 
RetryOperationException - Exception in com.crankuptheamps.client.exception
 
RetryOperationException() - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
 
RetryOperationException(String) - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
 
RetryOperationException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
 
RetryOperationException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.RetryOperationException
 
returnToPool(T) - Method in class com.crankuptheamps.client.Pool
Return an object to the pool.
RingBookmarkStore - Class in com.crankuptheamps.client
RingBookmarkStore is an implementation of BookmarkStore that stores state on disk and in memory.
RingBookmarkStore(String) - Constructor for class com.crankuptheamps.client.RingBookmarkStore
 
RingBookmarkStore(String, int) - Constructor for class com.crankuptheamps.client.RingBookmarkStore
 

S

send(Message) - Method in class com.crankuptheamps.client.Client
Send a Message to AMPS via the Transport used in the Client.
send(MessageHandler, Message, long) - Method in class com.crankuptheamps.client.Client
Send a Message to AMPS and register the messageHandler for any messages resulting from the command execution.
send(Message) - Method in class com.crankuptheamps.client.TCPTransport
 
send(ByteBuffer) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
send(Message) - Method in interface com.crankuptheamps.client.Transport
 
SendKeys - Static variable in class com.crankuptheamps.client.Message.Options
 
sendWithoutRetry(Message) - Method in class com.crankuptheamps.client.TCPTransport
 
sendWithoutRetry(Message) - Method in interface com.crankuptheamps.client.Transport
 
serialize(ByteBuffer) - Method in class com.crankuptheamps.client.XMLMessage
 
serialVersionUID - Static variable in class com.crankuptheamps.client.ConnectionInfo
 
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
 
set(byte[], int, int) - Method in class com.crankuptheamps.client.fields.Field
 
set(byte[]) - Method in class com.crankuptheamps.client.fields.Field
 
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 acknowlegdement message.
setActive(boolean) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
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 batch size for this message.
setBookmark(Field) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
setBookmark(String) - Method in class com.crankuptheamps.client.Command
Set the bookmark for this command.
setBookmark(String) - Method in class com.crankuptheamps.client.Message
Sets the value for the AMPS bookmark.
setBookmark(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the value for the AMPS bookmark.
setBookmarkSeqNo(long) - Method in class com.crankuptheamps.client.Message
Sets the bookmark sequence number for this message.
setBookmarkStore(BookmarkStore) - Method in class com.crankuptheamps.client.Client
Sets the underlying bookmark store, which is used to track which messages the client has received and which messages have been processed by the program.
setBuffer(byte[]) - Method in class com.crankuptheamps.client.Message
Sets the byte buffer used by the message.
setClientName(String) - Method in class com.crankuptheamps.client.Message
Sets the name of the client sending the message.
setClientName(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the name of the client sending the message.
setClientSequenceNumber(long) - Method in class com.crankuptheamps.client.Command
Sets the client sequence number for this command.
setCommand(int) - Method in class com.crankuptheamps.client.Command
Set the command type for this command.
setCommand(int) - Method in class com.crankuptheamps.client.Message
Sets the command for this message, indicating the type of of message this is.
setCommand(String) - Method in class com.crankuptheamps.client.Message
Sets the command for this message, indicating the type of of message this is.
setCommandId(CommandId) - Method in class com.crankuptheamps.client.Command
Set the commandId for this command.
setCommandId(String) - Method in class com.crankuptheamps.client.Message
Sets the CommandId on this message.
setCommandId(CommandId) - Method in class com.crankuptheamps.client.Message
Sets the CommandId on this message.
setCommandId(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the CommandId on this message.
setCorrelationId(String) - Method in class com.crankuptheamps.client.Command
Sets the correlation Id for this command
setCorrelationId(String) - Method in class com.crankuptheamps.client.Message
Set the CorrelationId on this message.
setDaemon(boolean) - Static method in class com.crankuptheamps.client.TCPTransport
 
setData(String) - Method in class com.crankuptheamps.client.Command
Set the data for this command.
setData(byte[], int, int) - Method in class com.crankuptheamps.client.Command
Set the data for this command.
setData(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.
setDefaultResubscriptionTimeout(long) - Static method in class com.crankuptheamps.client.MemorySubscriptionManager
 
setDisconnectHandler(ClientDisconnectHandler) - Method in class com.crankuptheamps.client.Client
Sets the ClientDisconnectHandler.
setDisconnectHandler(TransportDisconnectHandler) - Method in class com.crankuptheamps.client.TCPTransport
 
setDisconnectHandler(TransportDisconnectHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
setDisconnectHandler(TransportDisconnectHandler) - Method in interface com.crankuptheamps.client.Transport
 
setDuplicateMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client
Sets the MessageHandler instance used for duplicate messages.
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.Client
Sets the ExceptionListener instance used for communicating absorbed exceptions.
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.TCPTransport
 
setExceptionListener(ExceptionListener) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
setExceptionListener(ExceptionListener) - Method in interface com.crankuptheamps.client.Transport
 
setExpiration(int) - Method in class com.crankuptheamps.client.Command
Set the expiration for this command.
setExpiration(int) - Method in class com.crankuptheamps.client.Message
Sets the expiration set for this message.
setFailedWriteHandler(FailedWriteHandler) - Method in class com.crankuptheamps.client.Client
Sets the FailedWriteHandler instance used to report on failed messages that have been written.
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 on this message.
setFilter(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the filter on this message.
setGroupSeqNo(long) - Method in class com.crankuptheamps.client.Message
Set the group sequence number.
setHeartbeat(int, int) - Method in class com.crankuptheamps.client.Client
Requests a server heartbeat, and configures the client to close the connection if a heartbeat (or other activity) is not seen on the connection.
setHeartbeat(int) - Method in class com.crankuptheamps.client.Client
Requests a server heartbeat, and configures the client to close the connection if a heartbeat (or other activity) is not seen on the connection after two heartbeat intervals.
setHeartbeat(int, int) - Method in class com.crankuptheamps.client.HAClient
 
setIndex(long) - Method in class com.crankuptheamps.client.BookmarkRingBuffer.Entry
 
setLastChanceMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client
Sets the MessageHandler instance used when no other handler matches.
setLastPersisted(long) - Method in interface com.crankuptheamps.client.Subscription
 
setLastPersisted(BookmarkField) - Method in interface com.crankuptheamps.client.Subscription
 
setLength(int) - Method in class com.crankuptheamps.client.Message
Sets the length of the message.
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.
setMaxMessages(long) - Method in class com.crankuptheamps.client.Message
Deprecated. This header is no longer used by AMPS.
setMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.TCPTransport
 
setMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
setMessageHandler(MessageHandler) - Method in interface com.crankuptheamps.client.Transport
 
setMessageId(String) - Method in class com.crankuptheamps.client.Message
Deprecated. This header is no longer used by AMPS.
setMessageId(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Deprecated. This header is no longer used by AMPS.
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 this 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
 
setPersistedAcks() - Method in class com.crankuptheamps.client.BookmarkRingBuffer
Called to indicate that the server will provide persisted acks for the bookmarks.
setPersistedAcks() - Method in interface com.crankuptheamps.client.Subscription
 
setPosition(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
setPosition(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
setPosition(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
setPublishStore(Store) - Method in class com.crankuptheamps.client.Client
Sets the underlying publish store, which is used to store published messages until the AMPS instance has acknowledged those messages.
setQueryId(CommandId) - Method in class com.crankuptheamps.client.Command
Set the queryId for this command.
setQueryId(String) - Method in class com.crankuptheamps.client.Message
Sets the QueryId for this message.
setQueryId(CommandId) - Method in class com.crankuptheamps.client.Message
Sets the QueryId for this message.
setQueryId(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the QueryId for this message.
setRawBufferLength(int) - Method in class com.crankuptheamps.client.Message
Sets the length of the message within the byte buffer.
setRawBufferOffset(int) - Method in class com.crankuptheamps.client.Message
Sets the offset into the byte buffer where this message begins.
setReadTimeout(int) - Method in class com.crankuptheamps.client.TCPTransport
 
setReadTimeout(int) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
setReadTimeout(int) - Method in interface com.crankuptheamps.client.Transport
 
setReason(int) - Method in class com.crankuptheamps.client.Message
Sets the reason value of this message.
setReconnectDelay(int) - Method in class com.crankuptheamps.client.HAClient
Sets the time delay between reconnect events.
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
 
setResizeHandler(PublishStoreResizeHandler, Store) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
setResizeHandler(PublishStoreResizeHandler, Store) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
setResizeHandler(PublishStoreResizeHandler) - Method in class com.crankuptheamps.client.BlockPublishStore
 
setResizeHandler(BookmarkStoreResizeHandler, BookmarkStore) - Method in class com.crankuptheamps.client.BookmarkRingBuffer
 
setResizeHandler(BookmarkStoreResizeHandler) - Method in interface com.crankuptheamps.client.BookmarkStore
Called to set a resize handler that is invoked when the store needs to resize.
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
setResizeHandler(PublishStoreResizeHandler) - Method in class com.crankuptheamps.client.HybridPublishStore
 
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
setResizeHandler(PublishStoreResizeHandler, Store) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
setResizeHandler(BookmarkStoreResizeHandler) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
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
 
setRunning() - Method in class com.crankuptheamps.client.MessageStream
 
setSendEmpties(boolean) - Method in class com.crankuptheamps.client.Message
Sets the value of the send empties header.
setSendMatchingIds(boolean) - Method in class com.crankuptheamps.client.Message
Gets the value of the send keys header.
setSendOOF(boolean) - Method in class com.crankuptheamps.client.Message
Sets the value of the send OOF header.
setSequence(long) - Method in class com.crankuptheamps.client.Message
Returns the sequence number for this message.
setServerChooser(ServerChooser) - Method in class com.crankuptheamps.client.HAClient
Sets a ServerChooser for self.
setServerVersion(int) - Method in interface com.crankuptheamps.client.BookmarkStore
Called by the Client when connected to an AMPS server to indicate what version the server is.
setServerVersion(int) - Method in class com.crankuptheamps.client.DefaultBookmarkStore
 
setServerVersion(int) - Method in class com.crankuptheamps.client.LoggedBookmarkStore
 
setServerVersion(int) - Method in class com.crankuptheamps.client.MemoryBookmarkStore
 
setServerVersion(int) - Method in class com.crankuptheamps.client.RingBookmarkStore
 
setSize(long) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
setSize(long) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
setSize(long) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 
setSowKey(String) - Method in class com.crankuptheamps.client.Message
Sets the SowKey for this message.
setSowKey(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the SowKey for this message.
setSOWKeys(String) - Method in class com.crankuptheamps.client.Command
The SowKeys for a command are a comma-separated list of the keys that AMPS assigns to SOW messages.
setSowKeys(String) - Method in class com.crankuptheamps.client.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
 
setSubId(CommandId) - Method in class com.crankuptheamps.client.Command
Set the subId for this command.
setSubId(String) - Method in class com.crankuptheamps.client.Command
Set the subId for this command.
setSubId(String) - Method in class com.crankuptheamps.client.Message
Sets the SubId of this message.
setSubId(CommandId) - Method in class com.crankuptheamps.client.Message
Sets the SubId of this message.
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
 
setSubscriptionManager(SubscriptionManager) - Method in class com.crankuptheamps.client.Client
Sets the SubscriptionManager instance used for recording active subscriptions.
setTimeout(long) - Method in class com.crankuptheamps.client.Command
Set the timeout for this command.
setTimeout(int) - Method in class com.crankuptheamps.client.HAClient
Sets the timeout used for logging on and resubscribing, once a connection is re-established.
setTimestamp(String) - Method in class com.crankuptheamps.client.Message
Sets the timestamp for this message.
setTimestamp(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Sets the timestamp for this message.
setTopic(String) - Method in class com.crankuptheamps.client.Command
Set the topic for this command.
setTopic(byte[], int, int) - Method in class com.crankuptheamps.client.Command
Set the topic for this command from raw bytes.
setTopic(String) - Method in class com.crankuptheamps.client.Message
Set the topic that the message applies to.
setTopic(byte[], int, int) - Method in class com.crankuptheamps.client.Message
Set the topic that the message applies to.
setTopicMatches(long) - Method in class com.crankuptheamps.client.Message
Sets the topic matches field on this message.
setTopN(int) - Method in class com.crankuptheamps.client.Command
Set the topN value for this command.
setTopN(long) - Method in class com.crankuptheamps.client.Message
Set the TopN parameter for this message.
setTransportFilter(TransportFilter) - Method in class com.crankuptheamps.client.TCPTransport
 
setTransportFilter(TransportFilter) - Method in class com.crankuptheamps.client.TCPTransportImpl
 
setTransportFilter(TransportFilter) - Method in interface com.crankuptheamps.client.Transport
Sets a TransportFilter that filters raw bytes before send and after receive.
setUnhandledMessageHandler(MessageHandler) - Method in class com.crankuptheamps.client.Client
Deprecated. Use setLastChanceMessageHandler instead.
setUsage(String) - Method in class com.crankuptheamps.spark.SparkCommand
 
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.
setV1(boolean) - Method in class com.crankuptheamps.client.FIXProtocol
 
setValue(int) - Method in class com.crankuptheamps.client.fields.AckTypeField
 
setValue(boolean) - Method in class com.crankuptheamps.client.fields.BooleanField
 
setValue(int) - Method in class com.crankuptheamps.client.fields.CommandField
 
setValue(int) - Method in class com.crankuptheamps.client.fields.IntegerField
 
setValue(long) - Method in class com.crankuptheamps.client.fields.LongField
 
setValue(int) - Method in class com.crankuptheamps.client.fields.ReasonField
 
setValue(int) - Method in class com.crankuptheamps.client.fields.StatusField
 
setValue(byte[], int, int) - Method in class com.crankuptheamps.client.fields.StringField
 
setValue(CommandId) - Method in class com.crankuptheamps.client.fields.StringField
 
setValue(String, CharsetEncoder) - Method in class com.crankuptheamps.client.fields.StringField
 
setValue(String) - Method in class com.crankuptheamps.spark.CommandOption
 
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.
socket() - Method in class com.crankuptheamps.client.TCPTransport
 
socket() - Method in class com.crankuptheamps.client.TCPTransportImpl
 
sow(String, String) - Method in class com.crankuptheamps.client.Client
Synchronously execute a SOW query.
sow(String) - Method in class com.crankuptheamps.client.Client
Synchronously execute a SOW query.
sow(MessageHandler, String, String, String, String, int, int, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query.
sow(MessageHandler, String, String, int, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query.
sow(MessageHandler, String, String, int, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query.
sow(MessageHandler, String, int, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query.
sow(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query.
SOW - Static variable in class com.crankuptheamps.client.Message.Command
 
sowAndDeltaSubscribe(MessageHandler, String, String, String, int, int, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, String, int, boolean, boolean, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, String, int, boolean, boolean, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, String, int, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, int, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a delta subscription.
sowAndDeltaSubscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a delta subscription.
SOWAndDeltaSubscribe - Static variable in class com.crankuptheamps.client.Message.Command
 
sowAndSubscribe(String, String) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(String) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, String, String, int, int, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, int, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, int, boolean, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, String, int, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, int, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
sowAndSubscribe(MessageHandler, String, long) - Method in class com.crankuptheamps.client.Client
Executes a SOW query and places a subscription.
SOWAndSubscribe - Static variable in class com.crankuptheamps.client.Message.Command
 
SOWAndSubscribeCommand - Class in com.crankuptheamps.spark
 
SOWAndSubscribeCommand(String) - Constructor for class com.crankuptheamps.spark.SOWAndSubscribeCommand
 
SOWCommand - Class in com.crankuptheamps.spark
 
SOWCommand(String) - Constructor for class com.crankuptheamps.spark.SOWCommand
 
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
 
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
 
SOWDeleteCommand - Class in com.crankuptheamps.spark
 
SOWDeleteCommand(String) - Constructor for class com.crankuptheamps.spark.SOWDeleteCommand
 
Spark - Class in com.crankuptheamps.spark
 
Spark() - Constructor for class com.crankuptheamps.spark.Spark
 
SparkCommand - Class in com.crankuptheamps.spark
 
SparkCommand(String) - Constructor for class com.crankuptheamps.spark.SparkCommand
 
startTimer() - Method in class com.crankuptheamps.client.Client
Sends a start timer command to AMPS, which can be later stopped with a stop timer command.
StartTimer - Static variable in class com.crankuptheamps.client.Message.Command
 
Stats - Static variable in class com.crankuptheamps.client.Message.AckType
 
StatusField - Class in com.crankuptheamps.client.fields
 
StatusField() - Constructor for class com.crankuptheamps.client.fields.StatusField
 
stopTimer(MessageHandler) - Method in class com.crankuptheamps.client.Client
Sends a stop timer command to AMPS
StopTimer - Static variable in class com.crankuptheamps.client.Message.Command
 
store(long, int, byte[], long, long, byte[], long, long, byte[], long, long) - Method in class com.crankuptheamps.client.BlockPublishStore
 
store(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int) - Method in class com.crankuptheamps.client.BlockPublishStore
 
store(long, int, byte[], long, long, byte[], long, long, int, CommandId) - Method in class com.crankuptheamps.client.BlockPublishStore
 
store(long, int, byte[], long, long, byte[], long, long, byte[], long, long) - Method in class com.crankuptheamps.client.HybridPublishStore
 
store(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int) - Method in class com.crankuptheamps.client.HybridPublishStore
 
store(long, int, byte[], long, long, byte[], long, long, int, CommandId) - Method in class com.crankuptheamps.client.HybridPublishStore
 
Store - Interface in com.crankuptheamps.client
Represents a message store.
store(long, int, byte[], long, long, byte[], long, long, byte[], long, long) - Method in interface com.crankuptheamps.client.Store
Store the provided operation.
store(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int) - Method in interface com.crankuptheamps.client.Store
Store the provided operation.
store(long, int, byte[], long, long, byte[], long, long, int, CommandId) - Method in interface com.crankuptheamps.client.Store
Store the provided operation.
Store.StoreReplayer - Interface in com.crankuptheamps.client
Replay the messages saved in a store.
StoreException - Exception in com.crankuptheamps.client.exception
 
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
 
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
 
StringField(byte[], int, int) - Constructor for class com.crankuptheamps.client.fields.StringField
 
StringField() - Constructor for class com.crankuptheamps.client.fields.StringField
 
SubidInUse - Static variable in class com.crankuptheamps.client.Message.Reason
 
SubidInUseException - Exception in com.crankuptheamps.client.exception
 
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, int, CommandId, String, String, String, String, int) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
 
subscribe(MessageHandler, int, CommandId, String, String, String, String, int) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
 
Subscribe - Static variable in class com.crankuptheamps.client.Message.Command
 
subscribe(MessageHandler, int, CommandId, String, String, String, String, int) - Method in interface com.crankuptheamps.client.SubscriptionManager
 
SubscribeCommand - Class in com.crankuptheamps.spark
 
SubscribeCommand(String) - Constructor for class com.crankuptheamps.spark.SubscribeCommand
 
Subscription - Interface in com.crankuptheamps.client
 
SubscriptionAlreadyExists - Static variable in class com.crankuptheamps.client.Message.Reason
 
SubscriptionAlreadyExistsException - Exception in com.crankuptheamps.client.exception
 
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
 
Success - Static variable in class com.crankuptheamps.client.Message.Status
 
sync() - Method in class com.crankuptheamps.client.PublishStore
 
synonyms - Variable in class com.crankuptheamps.spark.SparkCommand
 

T

TCPTransport - Class in com.crankuptheamps.client
 
TCPTransport(Protocol, Properties) - Constructor for class com.crankuptheamps.client.TCPTransport
 
TCPTransport(Protocol) - Constructor for class com.crankuptheamps.client.TCPTransport
 
TCPTransportImpl - Class in com.crankuptheamps.client
 
TCPTransportImpl(Protocol, Properties, TransportFilter) - Constructor for class com.crankuptheamps.client.TCPTransportImpl
 
TimedOutException - Exception in com.crankuptheamps.client.exception
 
TimedOutException() - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
 
TimedOutException(String) - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
 
TimedOutException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
 
TimedOutException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.TimedOutException
 
toMap(String) - Method in class com.crankuptheamps.client.FIXShredder
 
toNVMap(String) - Method in class com.crankuptheamps.client.NVFIXShredder
 
toString() - Method in class com.crankuptheamps.client.CommandId
 
toString() - Method in class com.crankuptheamps.client.fields.Field
 
toString() - Method in class com.crankuptheamps.client.Message
Return the message as a string.
Transport - Interface in com.crankuptheamps.client
 
TransportDisconnectHandler - Interface in com.crankuptheamps.client
 
TransportException - Exception in com.crankuptheamps.client.exception
 
TransportException() - Constructor for exception com.crankuptheamps.client.exception.TransportException
 
TransportException(String) - Constructor for exception com.crankuptheamps.client.exception.TransportException
 
TransportException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportException
 
TransportException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportException
 
TransportFactory - Class in com.crankuptheamps.client
 
TransportFactory() - Constructor for class com.crankuptheamps.client.TransportFactory
 
TransportFilter - Interface in com.crankuptheamps.client
Filter raw incoming and outgoing data on a Transport.
TransportTraceFilter - Class in com.crankuptheamps.client
An implementation of TransportFilter for tracing message bytes to an OutputStream such as System.err.
TransportTraceFilter(OutputStream) - Constructor for class com.crankuptheamps.client.TransportTraceFilter
Construct a TransportTraceFilter to trace messages on stream_.
TransportTypeException - Exception in com.crankuptheamps.client.exception
 
TransportTypeException() - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
 
TransportTypeException(String) - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
 
TransportTypeException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
 
TransportTypeException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.TransportTypeException
 

U

Unknown - Static variable in class com.crankuptheamps.client.Message.Command
 
UnknownException - Exception in com.crankuptheamps.client.exception
 
UnknownException() - Constructor for exception com.crankuptheamps.client.exception.UnknownException
 
UnknownException(String) - Constructor for exception com.crankuptheamps.client.exception.UnknownException
 
UnknownException(Throwable) - Constructor for exception com.crankuptheamps.client.exception.UnknownException
 
UnknownException(String, Throwable) - Constructor for exception com.crankuptheamps.client.exception.UnknownException
 
unpersistedCount() - Method in class com.crankuptheamps.client.BlockPublishStore
 
unpersistedCount() - Method in class com.crankuptheamps.client.HybridPublishStore
 
unpersistedCount() - Method in interface com.crankuptheamps.client.Store
Return the number of operations in the store.
unregister(String) - Static method in class com.crankuptheamps.client.ProtocolFactory
 
unregister(String) - Static method in class com.crankuptheamps.client.TransportFactory
Unregisters a Transport from the AMPS client.
UNSET_INDEX - Static variable in class com.crankuptheamps.client.BookmarkRingBuffer
 
unsetExpiration() - Method in class com.crankuptheamps.client.Command
Clears any expiration value set on self.
unsubscribe(CommandId) - Method in class com.crankuptheamps.client.Client
Remove a subscription from AMPS.
unsubscribe() - Method in class com.crankuptheamps.client.Client
Remove all of the client's subscriptions from AMPS.
unsubscribe(CommandId) - Method in class com.crankuptheamps.client.DefaultSubscriptionManager
 
unsubscribe(CommandId) - Method in class com.crankuptheamps.client.MemorySubscriptionManager
 
Unsubscribe - Static variable in class com.crankuptheamps.client.Message.Command
 
unsubscribe(CommandId) - Method in interface com.crankuptheamps.client.SubscriptionManager
 
URIProperties - Class in com.crankuptheamps.client
Provides a Properties-sytle interface to the parameters in a URI.
URIProperties(URI) - Constructor for class com.crankuptheamps.client.URIProperties
 
usage - Variable in class com.crankuptheamps.spark.SparkCommand
 
UTF8 - Static variable in class com.crankuptheamps.client.JSONProtocol
 
Utilities - Class in com.crankuptheamps.client
 
Utilities() - Constructor for class com.crankuptheamps.client.Utilities
 

W

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

X

XMLMessage - Class in com.crankuptheamps.client
 
XMLMessage(CharsetEncoder, CharsetDecoder) - Constructor for class com.crankuptheamps.client.XMLMessage
 
XMLProtocol - Class in com.crankuptheamps.client
 
XMLProtocol() - Constructor for class com.crankuptheamps.client.XMLProtocol
 
XMLProtocol(Properties) - Constructor for class com.crankuptheamps.client.XMLProtocol
 
XMLProtocolParser - Class in com.crankuptheamps.client
 
XMLProtocolParser(XMLProtocol) - Constructor for class com.crankuptheamps.client.XMLProtocolParser
 

Z

zero(long, int) - Method in class com.crankuptheamps.client.ArrayStoreBuffer
 
zero(long, int) - Method in interface com.crankuptheamps.client.BlockPublishStore.Buffer
 
zero(long, int) - Method in class com.crankuptheamps.client.MemoryStoreBuffer
 

_

_buffer - Variable in class com.crankuptheamps.client.BlockPublishStore
 
_buffer - Variable in class com.crankuptheamps.client.MemoryStoreBuffer
 
_cap - Variable in class com.crankuptheamps.client.HybridPublishStore
 
_copyTo(Message) - Method in class com.crankuptheamps.client.Message
 
_fileStore - Variable in class com.crankuptheamps.client.HybridPublishStore
 
_filter - Variable in class com.crankuptheamps.client.TCPTransportImpl
 
_impl - Variable in class com.crankuptheamps.client.TCPTransport
 
_lock - Variable in class com.crankuptheamps.client.TCPTransportImpl
 
_lowestIndexInTheFile - Variable in class com.crankuptheamps.client.HybridPublishStore
 
_lowWatermark - Variable in class com.crankuptheamps.client.HybridPublishStore
 
_memoryStore - Variable in class com.crankuptheamps.client.HybridPublishStore
 
_path - Variable in class com.crankuptheamps.client.HybridPublishStore
 
_resizeHandler - Variable in class com.crankuptheamps.client.MemoryStoreBuffer
 
_socket - Variable in class com.crankuptheamps.client.TCPTransportImpl
 
_store(long, int, byte[], long, long, byte[], long, long, byte[], long, long, int, boolean, CommandId) - Method in class com.crankuptheamps.client.BlockPublishStore
 
_store - Variable in class com.crankuptheamps.client.MemoryStoreBuffer
 

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