org.kaazing.gateway.server.context.resolve

Class DefaultClusterContext

java.lang.Object

org.kaazing.gateway.server.context.resolve.DefaultClusterContext

All Implemented Interfaces:

com.hazelcast.logging.LogListener, ClusterContext

public class DefaultClusterContext
extends Object
implements ClusterContext, com.hazelcast.logging.LogListener

ClusterContext for KEG

Balancer data

1. HttpBalancerService.MEMBERID_BALANCER_MAP_NAME:
   • List of balanced URIs for one member
   • Key: Cluster member id
   • Value: Map(key: balancerURI, value: acceptURIs)
2. HttpBalancerService.BALANCER_MAP_NAME
   • List of balanced URIs for whole cluster
   • Key: balanceURI
   • Value: acceptURIs

Constructor Summary

Constructors

Constructor and Description
DefaultClusterContext(String name, List<MemberId> interfaces, List<MemberId> members, SchedulerProvider schedulerProvider)
DefaultClusterContext(String name, List<MemberId> interfaces, List<MemberId> members, SchedulerProvider schedulerProvider, ClusterConnectOptionsContext connectOptions)

Method Summary

Modifier and Type	Method and Description
void	addBalancerMapListener(BalancerMapListener balancerMapListener)
void	addInstanceKeyListener(InstanceKeyListener instanceKeyListener)
void	addMembershipEventListener(MembershipEventListener eventListener)
void	addReceiveQueue(String name)
void	addReceiveTopic(String name)
void	dispose()
List<MemberId>	getAccepts()
String	getClusterName()
CollectionsFactory	getCollectionsFactory()
ClusterConnectOptionsContext	getConnectOptions()
List<MemberId>	getConnects()
com.hazelcast.core.IdGenerator	getIdGenerator(String name)
String	getInstanceKey(MemberId memberId)
MemberId	getLocalMember()
Lock	getLock(Object obj)
Collection<MemberId>	getMemberIds()
MessageBufferFactory	getMessageBufferFactory()
void	log(com.hazelcast.logging.LogEvent logEvent)
void	logClusterState()
void	logClusterStateAtInfoLevel()
void	removeBalancerMapListener(BalancerMapListener balancerMapListener)
void	removeInstanceKeyListener(InstanceKeyListener instanceKeyListener)
void	removeMembershipEventListener(MembershipEventListener eventListener)
<T> void	removeReceiver(Class<T> type)
Object	send(Object msg, MemberId member)
void	send(Object msg, SendListener listener, MemberId member)
void	send(Object msg, SendListener listener, String name)
Object	send(Object msg, String name)
<T> void	setReceiver(Class<T> type, ReceiveListener<T> receiveListener)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultClusterContext

public DefaultClusterContext(String name,
                             List<MemberId> interfaces,
                             List<MemberId> members,
                             SchedulerProvider schedulerProvider)

DefaultClusterContext

public DefaultClusterContext(String name,
                             List<MemberId> interfaces,
                             List<MemberId> members,
                             SchedulerProvider schedulerProvider,
                             ClusterConnectOptionsContext connectOptions)

Method Detail

start

public void start()

Specified by:

start in interface ClusterContext

dispose

public void dispose()

Specified by:

dispose in interface ClusterContext

getLocalMember

public MemberId getLocalMember()

Specified by:

getLocalMember in interface ClusterContext

getMemberIds

public Collection<MemberId> getMemberIds()

Specified by:

getMemberIds in interface ClusterContext

getInstanceKey

public String getInstanceKey(MemberId memberId)

Specified by:

getInstanceKey in interface ClusterContext

getLock

public Lock getLock(Object obj)

Specified by:

getLock in interface ClusterContext

getIdGenerator

public com.hazelcast.core.IdGenerator getIdGenerator(String name)

Specified by:

getIdGenerator in interface ClusterContext

addReceiveQueue

public void addReceiveQueue(String name)

Specified by:

addReceiveQueue in interface ClusterContext

addReceiveTopic

public void addReceiveTopic(String name)

Specified by:

addReceiveTopic in interface ClusterContext

send

public void send(Object msg,
                 SendListener listener,
                 MemberId member)

Specified by:

send in interface ClusterContext

send

public void send(Object msg,
                 SendListener listener,
                 String name)

Specified by:

send in interface ClusterContext

send

public Object send(Object msg,
                   MemberId member)
            throws Exception

Specified by:

send in interface ClusterContext

Throws:

Exception

send

public Object send(Object msg,
                   String name)
            throws Exception

Specified by:

send in interface ClusterContext

Throws:

Exception

setReceiver

public <T> void setReceiver(Class<T> type,
                            ReceiveListener<T> receiveListener)

Specified by:

setReceiver in interface ClusterContext

removeReceiver

public <T> void removeReceiver(Class<T> type)

Specified by:

removeReceiver in interface ClusterContext

addMembershipEventListener

public void addMembershipEventListener(MembershipEventListener eventListener)

Specified by:

addMembershipEventListener in interface ClusterContext

removeMembershipEventListener

public void removeMembershipEventListener(MembershipEventListener eventListener)

Specified by:

removeMembershipEventListener in interface ClusterContext

addInstanceKeyListener

public void addInstanceKeyListener(InstanceKeyListener instanceKeyListener)

Specified by:

addInstanceKeyListener in interface ClusterContext

removeInstanceKeyListener

public void removeInstanceKeyListener(InstanceKeyListener instanceKeyListener)

Specified by:

removeInstanceKeyListener in interface ClusterContext

addBalancerMapListener

public void addBalancerMapListener(BalancerMapListener balancerMapListener)

Specified by:

addBalancerMapListener in interface ClusterContext

removeBalancerMapListener

public void removeBalancerMapListener(BalancerMapListener balancerMapListener)

Specified by:

removeBalancerMapListener in interface ClusterContext

getClusterName

public String getClusterName()

Specified by:

getClusterName in interface ClusterContext

getAccepts

public List<MemberId> getAccepts()

Specified by:

getAccepts in interface ClusterContext

getConnects

public List<MemberId> getConnects()

Specified by:

getConnects in interface ClusterContext

getConnectOptions

public ClusterConnectOptionsContext getConnectOptions()

Specified by:

getConnectOptions in interface ClusterContext

getMessageBufferFactory

public MessageBufferFactory getMessageBufferFactory()

Specified by:

getMessageBufferFactory in interface ClusterContext

logClusterState

public void logClusterState()

Specified by:

logClusterState in interface ClusterContext

logClusterStateAtInfoLevel

public void logClusterStateAtInfoLevel()

Specified by:

logClusterStateAtInfoLevel in interface ClusterContext

getCollectionsFactory

public CollectionsFactory getCollectionsFactory()

Specified by:

getCollectionsFactory in interface ClusterContext

log

public void log(com.hazelcast.logging.LogEvent logEvent)

Specified by:

log in interface com.hazelcast.logging.LogListener