com.crankuptheamps.client
Interface FailedWriteHandler
public interface FailedWriteHandler
An interface for receiving information on messages that you've written, but
for which the server indicates were not persisted.
Method Summary |
void |
failedWrite(long sequenceNumber,
int operation,
byte[] topic,
long topicOffset,
long topicLength,
byte[] data,
long dataOffset,
long dataLength,
byte[] correlationId,
long correlationIdOffset,
long correlationIdLength,
int reason)
The AMPS instance reports that a write has failed. |
failedWrite
void failedWrite(long sequenceNumber,
int operation,
byte[] topic,
long topicOffset,
long topicLength,
byte[] data,
long dataOffset,
long dataLength,
byte[] correlationId,
long correlationIdOffset,
long correlationIdLength,
int reason)
- The AMPS instance reports that a write has failed.
- Parameters:
sequenceNumber
- The sequence number of the message that could not be written.operation
- A value from Message.Command (Publish, DeltaPublish, or SOWDelete).topic
- The topic of the message.topicOffset
- The index in topic where the topic bytes begin.topicLength
- The length of the topic, in bytes.data
- The data of the message.dataOffset
- The index in data where the data bytes begin.dataLength
- The length of the data, in bytes.correlationId
- the correlation ID for this messagecorrelationIdOffset
- the offset into the correlation ID array where the correlation ID beginscorrelationIdLength
- the length of the correlation IDreason
- A value from Message.Reason indicating the reason for this failed write.