com.atlassian.bamboo.setup

Class BrokerURIUtils

java.lang.Object

com.atlassian.bamboo.setup.BrokerURIUtils

public class BrokerURIUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static URI	addGlobalFailoverParameters(URI brokerURI, String failoverParams, com.atlassian.bamboo.setup.BrokerURIUtils.MergeMode mergeMode) Method to add parameters to the broker client URI.
static URI	addParametersToEachFailoverTransport(URI brokerURI, String failoverTransportsParams, com.atlassian.bamboo.setup.BrokerURIUtils.MergeMode mergeMode) Method to add parameters to the broker client URI.
static URI	changeUriIpAddress(URI uri, String newIpAddress)
static URI	decorateBrokerURI(URI brokerURI) Decorates a supplied ActiveMQ broker URI with default options.
static String	generateBrokerClientURI(String brokerConnectionAddress)
static URI	generateBrokerClientURIForCloud(String baseUrl) Build JMS broker client URI to point remote agents to JMS-over-HTTP endpoint
static Map<String,String>	parseQuery(String query)
static URI	removeParameter(URI brokerURI, String paramToRemove) Method to remove a parameter from the broker URI.

Methods inherited from class java.lang.Object

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

Method Detail

removeParameter

@NotNull
public static URI removeParameter(@NotNull
                                           URI brokerURI,
                                           @NotNull
                                           String paramToRemove)

Method to remove a parameter from the broker URI. Handles removal of params failover: composite params as well

Parameters:

brokerURI -

paramToRemove -

Returns:

changeUriIpAddress

public static URI changeUriIpAddress(@NotNull
                                     URI uri,
                                     @NotNull
                                     String newIpAddress)
                              throws URISyntaxException

Throws:

URISyntaxException

addGlobalFailoverParameters

@NotNull
public static URI addGlobalFailoverParameters(@NotNull
                                                       URI brokerURI,
                                                       @NotNull
                                                       String failoverParams,
                                                       @NotNull
                                                       com.atlassian.bamboo.setup.BrokerURIUtils.MergeMode mergeMode)

Method to add parameters to the broker client URI.

Parameters:

brokerURI -

failoverParams -

Returns:

addParametersToEachFailoverTransport

@NotNull
public static URI addParametersToEachFailoverTransport(@NotNull
                                                                URI brokerURI,
                                                                @NotNull
                                                                String failoverTransportsParams,
                                                                @NotNull
                                                                com.atlassian.bamboo.setup.BrokerURIUtils.MergeMode mergeMode)

Method to add parameters to the broker client URI.

Parameters:

brokerURI -

failoverTransportsParams -

Returns:

parseQuery

public static Map<String,String> parseQuery(@Nullable
                                            String query)
                                     throws URISyntaxException

Throws:

URISyntaxException

decorateBrokerURI

public static URI decorateBrokerURI(URI brokerURI)

Decorates a supplied ActiveMQ broker URI with default options.

Parameters:

brokerURI - The broker URI to decorate

Returns:

The decorated broker URI

generateBrokerClientURIForCloud

@NotNull
public static URI generateBrokerClientURIForCloud(String baseUrl)

Build JMS broker client URI to point remote agents to JMS-over-HTTP endpoint

Parameters:

baseUrl - Cloud instance base URL

Returns:

client endpoint URI for this

generateBrokerClientURI

@NotNull
public static String generateBrokerClientURI(String brokerConnectionAddress)
                                               throws URISyntaxException

Throws:

URISyntaxException