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

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<org.vertx.java.core.json.JsonObject> filter, OutOfProcessMessageHandler handler)
static Producer	registerProducer(java.lang.String topic)
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

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