org.apache.hadoop.hbase.namequeues

Class RingBufferEnvelope

java.lang.Object

org.apache.hadoop.hbase.namequeues.RingBufferEnvelope

@InterfaceAudience.Private
final class RingBufferEnvelope
extends Object

An envelope to carry payload in the ring buffer that serves as online buffer to provide latest events

Field Summary

Fields

Modifier and Type	Field and Description
private NamedQueuePayload	namedQueuePayload

Constructor Summary

Constructors

Constructor and Description
RingBufferEnvelope()

Method Summary

Modifier and Type	Method and Description
NamedQueuePayload	getPayload() Retrieve current namedQueue payload NamedQueuePayload available on Envelope and free up the Envelope
void	load(NamedQueuePayload namedQueuePayload) Load the Envelope with RpcCall

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

namedQueuePayload

private NamedQueuePayload namedQueuePayload

Constructor Detail

RingBufferEnvelope

RingBufferEnvelope()

Method Detail

load

public void load(NamedQueuePayload namedQueuePayload)

Load the Envelope with RpcCall

Parameters:

namedQueuePayload - all details of rpc call that would be useful for ring buffer consumers

getPayload

public NamedQueuePayload getPayload()

Retrieve current namedQueue payload NamedQueuePayload available on Envelope and free up the Envelope

Returns:

Retrieve rpc log details