org.kaazing.gateway.server.context.resolve

Class StandaloneClusterContext

java.lang.Object

org.kaazing.gateway.server.context.resolve.StandaloneClusterContext

All Implemented Interfaces:

ClusterContext

public class StandaloneClusterContext
extends Object
implements ClusterContext

This class is the standalone case where the current node is itself the master this does not have any high availability functionality. The only supported method for now is the Map.

Constructor Summary

Constructors

Constructor and Description
StandaloneClusterContext()

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)
List<MemberId>	getMemberIds()
MessageBufferFactory	getMessageBufferFactory()
void	logClusterState()
void	logClusterStateAtInfoLevel()
void	removeBalancerMapListener(BalancerMapListener balancerMapListener)
void	removeInstanceKeyListener(InstanceKeyListener instanceKeyListener)
void	removeMembershipEventListener(MembershipEventListener eventListener)
<T> void	removeReceiver(Class<T> type)
<T> T	send(Object msg, MemberId member)
void	send(Object msg, SendListener listener, MemberId member)
void	send(Object msg, SendListener listener, String name)
<T> T	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

StandaloneClusterContext

public StandaloneClusterContext()

Method Detail

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

addReceiveQueue

public void addReceiveQueue(String name)

Specified by:

addReceiveQueue in interface ClusterContext

addReceiveTopic

public void addReceiveTopic(String name)

Specified by:

addReceiveTopic in interface ClusterContext

getClusterName

public String getClusterName()

Specified by:

getClusterName in interface ClusterContext

getMemberIds

public List<MemberId> getMemberIds()

Specified by:

getMemberIds 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

getIdGenerator

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

Specified by:

getIdGenerator in interface ClusterContext

getMessageBufferFactory

public MessageBufferFactory getMessageBufferFactory()

Specified by:

getMessageBufferFactory in interface ClusterContext

getLocalMember

public MemberId getLocalMember()

Specified by:

getLocalMember 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

removeReceiver

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

Specified by:

removeReceiver in interface ClusterContext

send

public <T> T send(Object msg,
                  MemberId member)
           throws Exception

Specified by:

send in interface ClusterContext

Throws:

Exception

send

public <T> T send(Object msg,
                  String name)
           throws Exception

Specified by:

send in interface ClusterContext

Throws:

Exception

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

setReceiver

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

Specified by:

setReceiver in interface ClusterContext

start

public void start()

Specified by:

start in interface ClusterContext

dispose

public void dispose()

Specified by:

dispose in interface ClusterContext

getCollectionsFactory

public CollectionsFactory getCollectionsFactory()

Specified by:

getCollectionsFactory in interface ClusterContext

logClusterState

public void logClusterState()

Specified by:

logClusterState in interface ClusterContext

logClusterStateAtInfoLevel

public void logClusterStateAtInfoLevel()

Specified by:

logClusterStateAtInfoLevel in interface ClusterContext