ome.smuggler.providers.q

Class Messages

java.lang.Object

ome.smuggler.providers.q.Messages

public class Messages
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ScheduleCountKey

Constructor Summary

Constructors

Constructor and Description
Messages()

Method Summary

Modifier and Type	Method and Description
static java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>	durableMessage()
static java.util.Optional<PositiveN>	getScheduleCount(org.apache.activemq.artemis.api.core.client.ClientMessage msg)
static java.util.function.Function<org.apache.activemq.artemis.api.core.client.ClientMessage,org.apache.activemq.artemis.api.core.client.ClientMessage>	setProp(java.lang.String key, long value)
static java.util.function.Function<org.apache.activemq.artemis.api.core.client.ClientMessage,org.apache.activemq.artemis.api.core.client.ClientMessage>	setScheduleCount(PositiveN count)
static java.util.function.Function<org.apache.activemq.artemis.api.core.client.ClientMessage,org.apache.activemq.artemis.api.core.client.ClientMessage>	setScheduledDeliveryTime(FutureTimepoint when)

Methods inherited from class java.lang.Object

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

Field Detail

ScheduleCountKey

public static final java.lang.String ScheduleCountKey

Constructor Detail

Messages

public Messages()

Method Detail

durableMessage

public static java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage> durableMessage()

setProp

public static java.util.function.Function<org.apache.activemq.artemis.api.core.client.ClientMessage,org.apache.activemq.artemis.api.core.client.ClientMessage> setProp(java.lang.String key,
                                                                                                                                                                       long value)

setScheduledDeliveryTime

public static java.util.function.Function<org.apache.activemq.artemis.api.core.client.ClientMessage,org.apache.activemq.artemis.api.core.client.ClientMessage> setScheduledDeliveryTime(FutureTimepoint when)

setScheduleCount

public static java.util.function.Function<org.apache.activemq.artemis.api.core.client.ClientMessage,org.apache.activemq.artemis.api.core.client.ClientMessage> setScheduleCount(PositiveN count)

getScheduleCount

public static java.util.Optional<PositiveN> getScheduleCount(org.apache.activemq.artemis.api.core.client.ClientMessage msg)