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<org.vertx.java.core.json.JsonObject> filter, OutOfProcessMessageHandler handler)
Producer	registerProducer(java.lang.String topic)
protected abstract void	setupMetrics(com.hazelcast.core.HazelcastInstance hzInstance)

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()

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<org.vertx.java.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)