com.atlassian.bamboo.setup

Class BrokerURIUtils

java.lang.Object

com.atlassian.bamboo.setup.BrokerURIUtils

public class BrokerURIUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BrokerURIUtils.MergeMode

Method Summary

Modifier and Type	Method and Description
static URI	addGlobalFailoverParameters(URI brokerURI, String failoverParams, BrokerURIUtils.MergeMode mergeMode) Method to add parameters to the broker client URI.
static URI	addParametersToEachFailoverTransport(URI brokerURI, String failoverTransportsParams, BrokerURIUtils.MergeMode mergeMode) Method to add parameters to the broker client URI.
static URI	addParametersToFailoverTransport(URI brokerURI, String protocol, String failoverTransportsParams, BrokerURIUtils.MergeMode mergeMode)
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 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
                                                       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
                                                                BrokerURIUtils.MergeMode mergeMode)

Method to add parameters to the broker client URI.

Parameters:

brokerURI -

failoverTransportsParams -

Returns:

addParametersToFailoverTransport

public static URI addParametersToFailoverTransport(@NotNull
                                                   URI brokerURI,
                                                   @NotNull
                                                   String protocol,
                                                   @NotNull
                                                   String failoverTransportsParams,
                                                   @NotNull
                                                   BrokerURIUtils.MergeMode mergeMode)

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

generateBrokerClientURI

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

Throws:

URISyntaxException