public interface FailedWriteHandlerV4
FailedWriteHandler| Modifier and Type | Method and Description |
|---|---|
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.
|
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)
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.