com.bigdata.ha.pipeline

Interface HAReceiveService.IHAReceiveCallback<M extends IHAWriteMessageBase>

Type Parameters:

M -

Enclosing class:

HAReceiveService<M extends HAMessageWrapper>

public static interface HAReceiveService.IHAReceiveCallback<M extends IHAWriteMessageBase>

Hook to notice receive events.

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
void	callback(M msg, ByteBuffer data) Hook invoked once a buffer has been received.
void	incReceive(M msg, int nreads, int rdlen, int rem) Notify that some payload bytes have been incrementally received for an IHAMessage.

Method Detail

incReceive

void incReceive(M msg,
              int nreads,
              int rdlen,
              int rem)
                throws Exception

Notify that some payload bytes have been incrementally received for an IHAMessage. This is invoked each time some data has been read from the upstream socket.

Parameters:

msg - The message.

nreads - The number of reads performed against the upstream socket for this message.

rdlen - The number of bytes read from the socket in this read.

rem - The number of bytes remaining before the payload has been fully read.

Throws:

Exception

callback

void callback(M msg,
            ByteBuffer data)
              throws Exception

Hook invoked once a buffer has been received.

Parameters:

msg - The message.

data - The buffer containing the data. The position() will be ZERO (0). The limit() will be the #of bytes available. The implementation MAY have side effects on the buffer state (position, limit, etc).

Throws:

Exception