com.hazelcast.instance
public interface NodeExtension
Modifier and Type | Method and Description |
---|---|
void |
afterStart(Node node)
Called after node is started
|
void |
beforeJoin()
Called before a new node is joining to cluster,
executed if node is the master node before join event.
|
void |
beforeStart(Node node)
Called before node is started
|
MessageTaskFactory |
createMessageTaskFactory(Node node)
Creates factory method that creates server side client message handlers
|
PacketReader |
createPacketReader(TcpIpConnection connection,
IOService ioService)
Creates a PacketReader for given Connection instance.
|
PacketWriter |
createPacketWriter(TcpIpConnection connection,
IOService ioService)
Creates a PacketWriter for given Connection instance.
|
SerializationService |
createSerializationService()
Creates a SerializationService instance to be used by this Node.
|
<T> T |
createService(Class<T> type)
Creates a service which is an implementation of given type parameter.
|
void |
destroy()
Destroys NodeExtension.
|
MemberSocketInterceptor |
getMemberSocketInterceptor()
Returns MemberSocketInterceptor for this Node if available,
otherwise returns null.
|
MemoryStats |
getMemoryStats()
Returns MemoryStats of for the JVM and current HazelcastInstance.
|
Storage<DataRef> |
getNativeDataStorage()
Deprecated.
|
SecurityContext |
getSecurityContext()
Returns SecurityContext for this Node if available, otherwise returns null.
|
SocketChannelWrapperFactory |
getSocketChannelWrapperFactory()
Returns SocketChannelWrapperFactory instance to be used by this Node.
|
void |
onThreadStart(Thread thread)
Called on thread start to inject/intercept extension specific logic,
like; registering thread in some service,
executing a special method before thread starts to do its own task.
|
void |
onThreadStop(Thread thread)
Called before a thread stops to clean/release injected by
onThreadStart(Thread) . |
void |
printNodeInfo(Node node)
Called to print node information during startup
|
void beforeStart(Node node)
void printNodeInfo(Node node)
void afterStart(Node node)
SerializationService createSerializationService()
SecurityContext getSecurityContext()
@Deprecated Storage<DataRef> getNativeDataStorage()
<T> T createService(Class<T> type)
type
- type of serviceIllegalArgumentException
- if type is not knownMemberSocketInterceptor getMemberSocketInterceptor()
SocketChannelWrapperFactory getSocketChannelWrapperFactory()
PacketReader createPacketReader(TcpIpConnection connection, IOService ioService)
connection
- tcp-ip connectionioService
- IOServicePacketWriter createPacketWriter(TcpIpConnection connection, IOService ioService)
connection
- tcp-ip connectionioService
- IOServiceMessageTaskFactory createMessageTaskFactory(Node node)
node
- nodevoid onThreadStart(Thread thread)
thread
- thread startingvoid onThreadStop(Thread thread)
onThreadStart(Thread)
.thread
- thread stoppingMemoryStats getMemoryStats()
void destroy()
void beforeJoin()
ClusterServiceImpl
calls this method,
when handleJoinRequest method is called. By this way, we can check the logic we want
by implementing this method. Implementation should throw required exception, with a valid
message which explains rejection reason.Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.