Constants.IO, Constants.Objects, Constants.RedoType, Constants.ResponseTypes
Constructor and Description |
---|
ClusterService(Node node) |
Modifier and Type | Method and Description |
---|---|
void |
checkIdle() |
void |
enqueueAndReturn(Processable processable) |
void |
enqueueAndWait(Processable processable) |
boolean |
enqueueAndWait(Processable processable,
int seconds) |
void |
enqueuePacket(Packet packet) |
void |
enqueuePriorityAndReturn(Processable processable) |
PacketProcessor |
getPacketProcessor(ClusterOperation operation) |
int |
getPacketQueueSize() |
int |
getProcessablePriorityQueueSize() |
int |
getProcessableQueueSize() |
Thread |
getServiceThread() |
void |
registerPacketProcessor(ClusterOperation operation,
PacketProcessor packetProcessor) |
void |
run() |
void |
start() |
void |
stop() |
String |
toString() |
public ClusterService(Node node)
public int getPacketQueueSize()
public int getProcessableQueueSize()
public int getProcessablePriorityQueueSize()
public Thread getServiceThread()
public void registerPacketProcessor(ClusterOperation operation, PacketProcessor packetProcessor)
public PacketProcessor getPacketProcessor(ClusterOperation operation)
public void enqueuePacket(Packet packet)
public boolean enqueueAndWait(Processable processable, int seconds)
public void enqueueAndWait(Processable processable)
public void enqueueAndReturn(Processable processable)
public void enqueuePriorityAndReturn(Processable processable)
public void start()
public void stop()
public void checkIdle()
Copyright © 2013 Hazelcast, Inc.. All rights reserved.