Package com.broadleafcommerce.common.messaging

Class MessageUtils

java.lang.Object

com.broadleafcommerce.common.messaging.MessageUtils

public final class MessageUtils
extends Object

Utility methods useful for creating and working with messages, such as compression and decompression of large payloads.

Field Summary

Fields

Modifier and Type	Field	Description
static final AtomicReference<Constructor<?>>	leadershipConstructor

Method Summary

Modifier and Type	Method	Description
static String	compressAndEncode(List<String> stringList)
static org.apache.camel.cluster.CamelClusterEventListener.Leadership	createLeadershipListener(Consumer<Boolean> leaderConsumer)	Create a leadership listener.
static List<String>	decodeAndUncompress(String stringListPayload)

Methods inherited from class java.lang.Object

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

Field Details

leadershipConstructor

public static final AtomicReference<Constructor<?>> leadershipConstructor

Method Details

decodeAndUncompress

@NonNull
public static List<String> decodeAndUncompress(@Nullable
 String stringListPayload)

compressAndEncode

@Nullable
public static String compressAndEncode(@Nullable
 List<String> stringList)

createLeadershipListener

public static org.apache.camel.cluster.CamelClusterEventListener.Leadership createLeadershipListener(Consumer<Boolean> leaderConsumer)

Create a leadership listener.

Parameters:

leaderConsumer - Consumer that receives a boolean denoting if this instance is currently the leader.

Returns:

The instantiated leadership changed listener