org.mycontroller.standalone.offheap

Class MessageQueueImpl

java.lang.Object

org.mycontroller.standalone.offheap.MessageQueueImpl

All Implemented Interfaces:

IQueue<IMessage>

public class MessageQueueImpl
extends Object
implements IQueue<IMessage>

Since:

1.2.0

Author:

Jeeva Kandasamy (jkandasa)

Field Summary

Fields inherited from interface org.mycontroller.standalone.offheap.IQueue

COUNTER_PREFIX, QUEUE_PREFIX

Constructor Summary

Constructors

Constructor and Description
MessageQueueImpl(String name)

Method Summary

Modifier and Type	Method and Description
void	add(IMessage message)
void	clear()
void	delete()
boolean	isEmpty()
int	size()
IMessage	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageQueueImpl

public MessageQueueImpl(String name)

Method Detail

add

public void add(IMessage message)

Specified by:

add in interface IQueue<IMessage>

take

public IMessage take()

Specified by:

take in interface IQueue<IMessage>

size

public int size()

Specified by:

size in interface IQueue<IMessage>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface IQueue<IMessage>

clear

public void clear()

Specified by:

clear in interface IQueue<IMessage>

delete

public void delete()

Specified by:

delete in interface IQueue<IMessage>