com.hazelcast.internal.ascii

Interface TextCommandService

All Known Implementing Classes:

TextCommandServiceImpl

public interface TextCommandService

Method Summary

Modifier and Type	Method and Description
Object	delete(String mapName, String key)
void	deleteAll(String mapName)
Object	get(String mapName, String key)
int	getAdjustedTTLSeconds(int ttl)
Map<String,Object>	getAll(String mapName, Set<String> keys)
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
byte[]	toByteArray(Object value)
void	unlock(String mapName, String key)

Method Detail

offer

boolean offer(String queueName,
              Object value)

poll

Object poll(String queueName,
            int seconds)

poll

Object poll(String queueName)

processRequest

void processRequest(TextCommand command)

sendResponse

void sendResponse(TextCommand textCommand)

get

Object get(String mapName,
           String key)

getAll

Map<String,Object> getAll(String mapName,
                          Set<String> keys)

getByteArray

byte[] getByteArray(String mapName,
                    String key)

put

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

put

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

putIfAbsent

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

replace

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

lock

void lock(String mapName,
          String key)
   throws InterruptedException

Throws:

InterruptedException

unlock

void unlock(String mapName,
            String key)

getAdjustedTTLSeconds

int getAdjustedTTLSeconds(int ttl)

incrementDeleteHitCount

long incrementDeleteHitCount(int inc)

incrementDeleteMissCount

long incrementDeleteMissCount()

incrementGetHitCount

long incrementGetHitCount()

incrementGetMissCount

long incrementGetMissCount()

incrementSetCount

long incrementSetCount()

incrementIncHitCount

long incrementIncHitCount()

incrementIncMissCount

long incrementIncMissCount()

incrementDecrHitCount

long incrementDecrHitCount()

incrementDecrMissCount

long incrementDecrMissCount()

incrementTouchCount

long incrementTouchCount()

size

int size(String queueName)

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

Parameters:

queueName - name of the distributed queue

Returns:

the size of the distributed queue instance with the specified name

delete

Object delete(String mapName,
              String key)

deleteAll

void deleteAll(String mapName)

getStats

Stats getStats()

getNode

Node getNode()

toByteArray

byte[] toByteArray(Object value)