org.kaazing.gateway.server.messaging.buffer

Class MemoryMessageBuffer

java.lang.Object

org.kaazing.gateway.server.messaging.buffer.MemoryMessageBuffer

All Implemented Interfaces:

MessageBuffer

public class MemoryMessageBuffer
extends Object
implements MessageBuffer

Constructor Summary

Constructors

Constructor and Description
MemoryMessageBuffer(int capacity)

Method Summary

Modifier and Type	Method and Description
MessageBufferEntry	add(MessagingMessage message)
void	addMessageBufferListener(MessageBufferListener listener)
MessageBufferEntry	get(int id)
int	getCapacity()
int	getOldestId()
int	getYoungestId()
void	removeMessageBufferListener(MessageBufferListener listener)
MessageBufferEntry	set(int index, MessagingMessage message)

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryMessageBuffer

public MemoryMessageBuffer(int capacity)

Method Detail

add

public MessageBufferEntry add(MessagingMessage message)

Specified by:

add in interface MessageBuffer

set

public MessageBufferEntry set(int index,
                              MessagingMessage message)

Specified by:

set in interface MessageBuffer

get

public MessageBufferEntry get(int id)

Specified by:

get in interface MessageBuffer

getYoungestId

public int getYoungestId()

Specified by:

getYoungestId in interface MessageBuffer

getOldestId

public int getOldestId()

Specified by:

getOldestId in interface MessageBuffer

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface MessageBuffer

addMessageBufferListener

public void addMessageBufferListener(MessageBufferListener listener)

Specified by:

addMessageBufferListener in interface MessageBuffer

removeMessageBufferListener

public void removeMessageBufferListener(MessageBufferListener listener)

Specified by:

removeMessageBufferListener in interface MessageBuffer