net.bluemind.hornetq.client.impl

Class ClusterNode

java.lang.Object

net.bluemind.hornetq.client.impl.ClusterNode

Direct Known Subclasses:

ClusterClient, ClusterMember

public abstract class ClusterNode
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.CompletableFuture<com.hazelcast.core.HazelcastInstance>	hzStart
protected org.slf4j.Logger	logger
protected java.util.Map<java.lang.String,Producer>	producers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClusterNode(java.lang.String jvmType)

Method Summary

Modifier and Type	Method and Description
long	clusterTime()
Producer	getProducer(java.lang.String topic)
protected abstract com.hazelcast.core.HazelcastInstance	hazelcastConnectImpl(java.lang.String jvmType)
java.util.concurrent.CompletableFuture<com.hazelcast.core.HazelcastInstance>	hz()
java.util.concurrent.CompletableFuture<java.lang.Void>	init()
void	init(MQ.IMQConnectHandler handler)
protected java.lang.String	memberAddress()
protected static java.lang.String	memberJvm(com.hazelcast.core.Member m)
Consumer	registerConsumer(java.lang.String topic, OutOfProcessMessageHandler handler)
Consumer	registerConsumer(java.lang.String topic, java.util.function.Predicate<io.vertx.core.json.JsonObject> filter, OutOfProcessMessageHandler handler)
Producer	registerProducer(java.lang.String topic)
protected abstract void	setupMetrics(com.hazelcast.core.HazelcastInstance hzInstance)
<K,V> MQ.SharedMap<K,V>	sharedMap(java.lang.String name)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

producers

protected final java.util.Map<java.lang.String,Producer> producers

hzStart

protected final java.util.concurrent.CompletableFuture<com.hazelcast.core.HazelcastInstance> hzStart

Constructor Detail

ClusterNode

protected ClusterNode(java.lang.String jvmType)

Method Detail

hz

public java.util.concurrent.CompletableFuture<com.hazelcast.core.HazelcastInstance> hz()

setupMetrics

protected abstract void setupMetrics(com.hazelcast.core.HazelcastInstance hzInstance)

memberJvm

protected static java.lang.String memberJvm(com.hazelcast.core.Member m)

init

public java.util.concurrent.CompletableFuture<java.lang.Void> init()

init

public final void init(MQ.IMQConnectHandler handler)

memberAddress

protected java.lang.String memberAddress()

hazelcastConnectImpl

protected abstract com.hazelcast.core.HazelcastInstance hazelcastConnectImpl(java.lang.String jvmType)

clusterTime

public long clusterTime()

sharedMap

public <K,V> MQ.SharedMap<K,V> sharedMap(java.lang.String name)

registerConsumer

public Consumer registerConsumer(java.lang.String topic,
                                 OutOfProcessMessageHandler handler)

Parameters:

topic -

handler -

Returns:

registerConsumer

public Consumer registerConsumer(java.lang.String topic,
                                 java.util.function.Predicate<io.vertx.core.json.JsonObject> filter,
                                 OutOfProcessMessageHandler handler)

Parameters:

topic -

handler -

Returns:

registerProducer

public Producer registerProducer(java.lang.String topic)

getProducer

public Producer getProducer(java.lang.String topic)