com.hazelcast.impl.ascii

Class TextCommandServiceImpl

java.lang.Object

com.hazelcast.impl.ascii.TextCommandServiceImpl

All Implemented Interfaces:

TextCommandConstants, TextCommandService

public class TextCommandServiceImpl
extends Object
implements TextCommandService, TextCommandConstants

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.impl.ascii.TextCommandConstants

TextCommandConstants.TextCommandType

Field Summary

Fields inherited from interface com.hazelcast.impl.ascii.TextCommandConstants

CLIENT_ERROR, DELETED, END, ERROR, FLAG_ZERO, MONTH_SECONDS, NOT_FOUND, NOT_STORED, RETURN, RETURN_END, SERVER_ERROR, SPACE, STORED, VALUE_SPACE

Constructor Summary

Constructors

Constructor and Description
TextCommandServiceImpl(Node node)

Method Summary

Methods

Modifier and Type	Method and Description
Object	delete(String mapName, String key)
Object	get(String mapName, String key)
int	getAdjustedTTLSeconds(int ttl)
byte[]	getByteArray(String mapName, String key)
Node	getNode()
Stats	getStats()
long	incrementDeleteCount()
long	incrementGetCount()
long	incrementHitCount()
long	incrementSetCount()
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, int ttlSeconds)
Object	putIfAbsent(String mapName, String key, Object value, int ttlSeconds)
Object	replace(String mapName, String key, Object value)
void	sendResponse(TextCommand textCommand)
void	stop()

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

getStats

public Stats getStats()

Specified by:

getStats in interface TextCommandService

incrementDeleteCount

public long incrementDeleteCount()

Specified by:

incrementDeleteCount in interface TextCommandService

incrementGetCount

public long incrementGetCount()

Specified by:

incrementGetCount in interface TextCommandService

incrementSetCount

public long incrementSetCount()

Specified by:

incrementSetCount in interface TextCommandService

incrementHitCount

public long incrementHitCount()

Specified by:

incrementHitCount 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,
         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

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

sendResponse

public void sendResponse(TextCommand textCommand)

Specified by:

sendResponse in interface TextCommandService

stop

public void stop()