net.bluemind.hornetq.client

Class MQ

java.lang.Object

net.bluemind.hornetq.client.MQ

public final class MQ
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MQ.IMQConnectHandler
static interface	MQ.SharedMap<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CLUSTER_ID For now use a fixed cluster id as we don't use multicast anymore and want to avoid the split between bluemind-noid & bluemind- after install.
static java.lang.String	MEMBERSHIP_EVENTS_ADDRESS

Constructor Summary

Constructors

Constructor and Description
MQ()

Method Summary

Modifier and Type	Method and Description
static long	clusterTime() The cluster tries to keep a cluster-wide time which might be different than the member's own system time.
static Producer	getProducer(java.lang.String topic)
static java.util.concurrent.CompletableFuture<java.lang.Void>	init()
static void	init(MQ.IMQConnectHandler handler)
static IdGenerator	newIdGenerator(java.lang.String seqName)
static OOPMessage	newMessage()
static Consumer	registerConsumer(java.lang.String topic, OutOfProcessMessageHandler handler)
static Consumer	registerConsumer(java.lang.String topic, java.util.function.Predicate<io.vertx.core.json.JsonObject> filter, OutOfProcessMessageHandler handler)
static Producer	registerProducer(java.lang.String topic)
static <K,V> MQ.SharedMap<K,V>	sharedMap(java.lang.String name)
static java.util.List<java.lang.String>	topics()

Methods inherited from class java.lang.Object

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

Field Detail

MEMBERSHIP_EVENTS_ADDRESS

public static final java.lang.String MEMBERSHIP_EVENTS_ADDRESS

See Also:

Constant Field Values

CLUSTER_ID

public static final java.lang.String CLUSTER_ID

For now use a fixed cluster id as we don't use multicast anymore and want to avoid the split between bluemind-noid & bluemind- after install.

See Also:

Constant Field Values

Constructor Detail

MQ

public MQ()

Method Detail

init

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

init

public static final void init(MQ.IMQConnectHandler handler)

clusterTime

public static long clusterTime()

The cluster tries to keep a cluster-wide time which might be different than the member's own system time. Cluster-wide time is -almost- the same on all members of the cluster.

Returns:

the timestamp

sharedMap

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

registerConsumer

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

Parameters:

topic -

handler -

Returns:

registerConsumer

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

Parameters:

topic -

handler -

Returns:

registerProducer

public static Producer registerProducer(java.lang.String topic)

getProducer

public static Producer getProducer(java.lang.String topic)

newMessage

public static OOPMessage newMessage()

newIdGenerator

public static IdGenerator newIdGenerator(java.lang.String seqName)

topics

public static java.util.List<java.lang.String> topics()