org.kaazing.gateway.server.messaging.buffer

Class ClusterMemoryMessageBuffer

java.lang.Object

org.kaazing.gateway.server.messaging.buffer.ClusterMemoryMessageBuffer

All Implemented Interfaces:

Serializable, MessageBuffer

public class ClusterMemoryMessageBuffer
extends Object
implements MessageBuffer, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClusterMemoryMessageBuffer()
	ClusterMemoryMessageBuffer(com.hazelcast.core.HazelcastInstance cluster, 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)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterMemoryMessageBuffer

protected ClusterMemoryMessageBuffer()

ClusterMemoryMessageBuffer

public ClusterMemoryMessageBuffer(com.hazelcast.core.HazelcastInstance cluster,
                                  int capacity)

Method Detail

add

public MessageBufferEntry add(MessagingMessage message)

Specified by:

add in interface MessageBuffer

get

public MessageBufferEntry get(int id)

Specified by:

get in interface MessageBuffer

set

public MessageBufferEntry set(int index,
                              MessagingMessage message)

Specified by:

set 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

toString

public String toString()

Overrides:

toString in class Object