com.hazelcast.ascii
Class TextCommandServiceImpl

java.lang.Object
  com.hazelcast.ascii.TextCommandServiceImpl

All Implemented Interfaces:

TextCommandService

public class TextCommandServiceImpl
extends Object
implements TextCommandService

Constructor Summary

TextCommandServiceImpl(Node node)

Method Summary

Object	delete(String mapName, String key)
void	deleteAll(String mapName)
Object	get(String mapName, String key)
int	getAdjustedTTLSeconds(int ttl)
byte[]	getByteArray(String mapName, String key)
Node	getNode()
Stats	getStats()
long	incrementDecrHitCount()
long	incrementDecrMissCount()
long	incrementDeleteHitCount(int inc)
long	incrementDeleteMissCount()
long	incrementGetHitCount()
long	incrementGetMissCount()
long	incrementIncHitCount()
long	incrementIncMissCount()
long	incrementSetCount()
long	incrementTouchCount()
void	lock(String mapName, String key)
boolean	offer(String queueName, Object value)
Object	poll(String queueName)
Object	poll(String queueName, int seconds)
void	processRequest(TextCommand command)
Object	put(String mapName, String key, Object value)
Object	put(String mapName, String key, Object value, int ttlSeconds)
Object	putIfAbsent(String mapName, String key, Object value, int ttlSeconds)
Object	replace(String mapName, String key, Object value)
void	sendResponse(TextCommand textCommand)
int	size(String queueName) Returns the size of the distributed queue instance with the specified name
void	stop()
byte[]	toByteArray(Object value)
void	unlock(String mapName, String key)

Methods inherited from class java.lang.Object

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

Constructor Detail

TextCommandServiceImpl

public TextCommandServiceImpl(Node node)

Method Detail

getNode

public Node getNode()

Specified by:

getNode in interface TextCommandService

toByteArray

public byte[] toByteArray(Object value)

Specified by:

toByteArray in interface TextCommandService

getStats

public Stats getStats()

Specified by:

getStats in interface TextCommandService

incrementDeleteHitCount

public long incrementDeleteHitCount(int inc)

Specified by:

incrementDeleteHitCount in interface TextCommandService

incrementDeleteMissCount

public long incrementDeleteMissCount()

Specified by:

incrementDeleteMissCount in interface TextCommandService

incrementGetHitCount

public long incrementGetHitCount()

Specified by:

incrementGetHitCount in interface TextCommandService

incrementGetMissCount

public long incrementGetMissCount()

Specified by:

incrementGetMissCount in interface TextCommandService

incrementSetCount

public long incrementSetCount()

Specified by:

incrementSetCount in interface TextCommandService

incrementIncHitCount

public long incrementIncHitCount()

Specified by:

incrementIncHitCount in interface TextCommandService

incrementIncMissCount

public long incrementIncMissCount()

Specified by:

incrementIncMissCount in interface TextCommandService

incrementDecrHitCount

public long incrementDecrHitCount()

Specified by:

incrementDecrHitCount in interface TextCommandService

incrementDecrMissCount

public long incrementDecrMissCount()

Specified by:

incrementDecrMissCount in interface TextCommandService

incrementTouchCount

public long incrementTouchCount()

Specified by:

incrementTouchCount in interface TextCommandService

processRequest

public void processRequest(TextCommand command)

Specified by:

processRequest in interface TextCommandService

get

public Object get(String mapName,
                  String key)

Specified by:

get in interface TextCommandService

getAdjustedTTLSeconds

public int getAdjustedTTLSeconds(int ttl)

Specified by:

getAdjustedTTLSeconds in interface TextCommandService

getByteArray

public byte[] getByteArray(String mapName,
                           String key)

Specified by:

getByteArray in interface TextCommandService

put

public Object put(String mapName,
                  String key,
                  Object value)

Specified by:

put in interface TextCommandService

put

public Object put(String mapName,
                  String key,
                  Object value,
                  int ttlSeconds)

Specified by:

put in interface TextCommandService

putIfAbsent

public Object putIfAbsent(String mapName,
                          String key,
                          Object value,
                          int ttlSeconds)

Specified by:

putIfAbsent in interface TextCommandService

replace

public Object replace(String mapName,
                      String key,
                      Object value)

Specified by:

replace in interface TextCommandService

lock

public void lock(String mapName,
                 String key)
          throws InterruptedException

Specified by:

lock in interface TextCommandService

Throws:

InterruptedException

unlock

public void unlock(String mapName,
                   String key)

Specified by:

unlock in interface TextCommandService

deleteAll

public void deleteAll(String mapName)

Specified by:

deleteAll in interface TextCommandService

delete

public Object delete(String mapName,
                     String key)

Specified by:

delete in interface TextCommandService

offer

public boolean offer(String queueName,
                     Object value)

Specified by:

offer in interface TextCommandService

poll

public Object poll(String queueName,
                   int seconds)

Specified by:

poll in interface TextCommandService

poll

public Object poll(String queueName)

Specified by:

poll in interface TextCommandService

size

public int size(String queueName)

Description copied from interface: TextCommandService

Returns the size of the distributed queue instance with the specified name

Specified by:

size in interface TextCommandService

Parameters:

queueName - name of the distributed queue

Returns:

the size of the distributed queue instance with the specified name

sendResponse

public void sendResponse(TextCommand textCommand)

Specified by:

sendResponse in interface TextCommandService

stop

public void stop()