com.atlassian.bamboo.amq

Class AgentJmsUtils

java.lang.Object

com.atlassian.bamboo.amq.AgentJmsUtils

public final class AgentJmsUtils
extends Object

Utility class for dealing with JMS messages.

Method Summary

Methods

Modifier and Type	Method and Description
static String	getDestinationName(javax.jms.Topic topic, String id)
static Long	getInstanceFingerprint(javax.jms.Message message)
static Integer	getUuidHash(javax.jms.Message message) Retrieves UUID hash from the message.
static boolean	isExpensive(javax.jms.Message message) Checks whether the message was marked as expensive.
static void	setExpensive(javax.jms.Message message, boolean expensive) Marks message as expensive.
static void	setFingerprint(javax.jms.Message message, ServerFingerprint fingerprint)
static void	setUuidHash(javax.jms.Message message, int uuidHash) Sets agent UUID hash on the message.

Methods inherited from class java.lang.Object

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

Method Detail

getUuidHash

@Nullable
public static Integer getUuidHash(javax.jms.Message message)

Retrieves UUID hash from the message.

setUuidHash

public static void setUuidHash(javax.jms.Message message,
               int uuidHash)

Sets agent UUID hash on the message.

setExpensive

public static void setExpensive(javax.jms.Message message,
                boolean expensive)

Marks message as expensive. See ExpensiveMessage

isExpensive

public static boolean isExpensive(javax.jms.Message message)

Checks whether the message was marked as expensive.

getDestinationName

public static String getDestinationName(javax.jms.Topic topic,
                        String id)

getInstanceFingerprint

@Nullable
public static Long getInstanceFingerprint(javax.jms.Message message)
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setFingerprint

public static void setFingerprint(javax.jms.Message message,
                  ServerFingerprint fingerprint)
                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException