public interface NodeExtension
| Modifier and Type | Method and Description |
|---|---|
void |
afterStart(Node node)
Called after node is started
|
void |
beforeStart(Node node)
Called before node is started
|
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 - IOServicevoid onThreadStart(Thread thread)
thread - thread startingvoid onThreadStop(Thread thread)
onThreadStart(Thread).thread - thread stoppingMemoryStats getMemoryStats()
void destroy()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.