org.apache.synapse.transport.amqp

Class AMQPTransportUtils

java.lang.Object

org.apache.synapse.transport.amqp.AMQPTransportUtils

public final class AMQPTransportUtils
extends Object

Contains some utility methods for the AMQP transport implementation

Constructor Summary

Constructors

Constructor and Description
AMQPTransportUtils()

Method Summary

Modifier and Type	Method and Description
static com.rabbitmq.client.Address[]	getAddressArray(String addressString, String regex, char subRegex) Digest the address array in the form hostName1:portNumber1,hostName2:portNumber2,hostName3:portNumber3
static Boolean	getBooleanProperty(String name, boolean def)
static double	getDoubleProperty(String name, double def)
static int	getIntProperty(String name, int def) Read the value of a int property.
static long	getLongProperty(String name, long def) Read the value of a property of type long
static Boolean	getOptionalBooleanParameter(String key, Map<String,String> srcMap1, Map<String,String> srcMap2)
static Double	getOptionalDoubleParameter(String key, Map<String,String> srcMap1, Map<String,String> srcMap2)
static Integer	getOptionalIntParameter(String key, Map<String,String> srcMap1, Map<String,String> srcMap2)
static String	getOptionalStringParameter(String key, Map<String,String> srcMap1, Map<String,String> srcMap2)
static Map<String,String>	getServiceStringParameters(List<org.apache.axis2.description.Parameter> list)
static String	getStringProperty(String name, String def) Read the value of a string property.
static void	moveElements(BlockingQueue<AMQPTransportMessage> src, List<AMQPTransportMessage> dest, int blockSize) Move elements between buffers.
static Map<String,String>	parseAMQPUri(String amqpUri)
static String[]	split(String src, String delimiter)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportUtils

public AMQPTransportUtils()

Method Detail

getStringProperty

public static String getStringProperty(String name,
                                       String def)
                                throws NumberFormatException

Read the value of a string property.

Parameters:

name - name of the property.

def - default value.

Returns:

the string value

Throws:

NumberFormatException - in case invalid property value.

getIntProperty

public static int getIntProperty(String name,
                                 int def)
                          throws NumberFormatException

Read the value of a int property.

Parameters:

name - name of the property.

def - default value if no value is found.

Returns:

the property value.

Throws:

NumberFormatException - in case of an invalid property value.

getLongProperty

public static long getLongProperty(String name,
                                   long def)
                            throws NumberFormatException

Read the value of a property of type long

Parameters:

name - name of the property

def - value of the property

Returns:

value of property

Throws:

NumberFormatException - throws in case of an error.

getDoubleProperty

public static double getDoubleProperty(String name,
                                       double def)
                                throws NumberFormatException

Throws:

NumberFormatException

getBooleanProperty

public static Boolean getBooleanProperty(String name,
                                         boolean def)
                                  throws NumberFormatException

Throws:

NumberFormatException

getServiceStringParameters

public static Map<String,String> getServiceStringParameters(List<org.apache.axis2.description.Parameter> list)

getOptionalStringParameter

public static String getOptionalStringParameter(String key,
                                                Map<String,String> srcMap1,
                                                Map<String,String> srcMap2)

getOptionalBooleanParameter

public static Boolean getOptionalBooleanParameter(String key,
                                                  Map<String,String> srcMap1,
                                                  Map<String,String> srcMap2)

getOptionalIntParameter

public static Integer getOptionalIntParameter(String key,
                                              Map<String,String> srcMap1,
                                              Map<String,String> srcMap2)
                                       throws AMQPTransportException

Throws:

AMQPTransportException

getOptionalDoubleParameter

public static Double getOptionalDoubleParameter(String key,
                                                Map<String,String> srcMap1,
                                                Map<String,String> srcMap2)
                                         throws AMQPTransportException

Throws:

AMQPTransportException

split

public static String[] split(String src,
                             String delimiter)

getAddressArray

public static com.rabbitmq.client.Address[] getAddressArray(String addressString,
                                                            String regex,
                                                            char subRegex)
                                                     throws NumberFormatException

Digest the address array in the form hostName1:portNumber1,hostName2:portNumber2,hostName3:portNumber3

Parameters:

addressString - Address array string

regex - the first regex to split the string

subRegex - the sub regex to split the string

Returns:

the address array

Throws:

NumberFormatException - in case an invalid port.

moveElements

public static void moveElements(BlockingQueue<AMQPTransportMessage> src,
                                List<AMQPTransportMessage> dest,
                                int blockSize)
                         throws AMQPTransportException

Move elements between buffers. No need of additional synchronization locks, BlockingQueue#drainTo is thread safe, but not atomic, which is not a problem. See BlockingQueue.drainTo(java.util.Collection, int)

Parameters:

src - source buffer

dest - destination buffer

blockSize - blockSize of message bulk that need to move

Throws:

AMQPTransportException - in case of drains fails

parseAMQPUri

public static Map<String,String> parseAMQPUri(String amqpUri)
                                       throws AMQPTransportException

Throws:

AMQPTransportException