org.wso2.mb.integration.common.clients.operations.utils

Class AndesClientUtils

java.lang.Object

org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils

public class AndesClientUtils
extends Object

This class provides functionality to evaluate Andes Client consumers and publishers.

Constructor Summary

Constructors

Constructor and Description
AndesClientUtils()

Method Summary

Modifier and Type	Method and Description
static void	createMockFile(String filePathToRead, String filePathToCreate, int sizeInKB) Creates a file using a given file and a size.
static String	createRandomString(int sizeInBytes) Creates a one line random string
static String	createRandomString(int sizeInBytes, int maxLineSize) Creates a random string.
static void	deleteRandomFile(String filePathToDelete) Deletes a random file.
static void	flushPrintWriters() Prints print writers to file paths.
static void	initializePublishedPrintWriter(String filePath) Initialize the published messages print writer.
static void	initializeReceivedMessagesPrintWriter(String filePath) Initialize the message content print writer.
static void	initializeStatisticsPrintWriter(String filePath) Initialize the statistics print writer.
static void	shutdownClient(AndesClient client) Shutdown the client gracefully without waiting.
static void	sleepForInterval(long milliseconds) Sleeps for a certain time.
static void	waitForMessagesAndShutdown(AndesClient client, long waitTimeTillMessageCounterChanges) Waits until no messages are received.
static void	waitForMessagesAndShutdown(AndesClient client, long waitTimeTillMessageCounterChanges, long expectedMessageCount) Waits until no messages are received.
static void	writePublishedMessagesToFile(String content, String filePath) Writes published messages to a file.
static void	writeReceivedMessagesToFile(String content, String filePath) Writes received messages to a file.
static void	writeStatisticsToFile(String content, String filePath) Writes statistics to a file.

Methods inherited from class java.lang.Object

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

Constructor Detail

AndesClientUtils

public AndesClientUtils()

Method Detail

waitForMessagesAndShutdown

public static void waitForMessagesAndShutdown(AndesClient client,
                                              long waitTimeTillMessageCounterChanges,
                                              long expectedMessageCount)
                                       throws javax.jms.JMSException

Waits until no messages are received. The waiting is done by using a loop checking whether any new messages are received than the previous iteration. In each iteration it will wait for a certain time to make sure that message counter changes until no change is detected in the message counters.

Parameters:

client - The consumer client

waitTimeTillMessageCounterChanges - The amount of milliseconds to wait for new messages are received.

expectedMessageCount - Number of messages expected from the consumer

Throws:

javax.jms.JMSException

waitForMessagesAndShutdown

public static void waitForMessagesAndShutdown(AndesClient client,
                                              long waitTimeTillMessageCounterChanges)
                                       throws javax.jms.JMSException

Waits until no messages are received. The waiting is done by using a loop checking whether any new messages are received than the previous iteration. In each iteration it will wait for a certain time to make sure that message counter changes until no change is detected in the message counters.

Parameters:

client - The consumer client

waitTimeTillMessageCounterChanges - The amount of milliseconds to wait for new messages are received.

Throws:

javax.jms.JMSException

shutdownClient

public static void shutdownClient(AndesClient client)
                           throws javax.jms.JMSException

Shutdown the client gracefully without waiting.

Parameters:

client - The client to shutdown

Throws:

javax.jms.JMSException

sleepForInterval

public static void sleepForInterval(long milliseconds)

Sleeps for a certain time.

Parameters:

milliseconds - Sleep time in milliseconds.

writeReceivedMessagesToFile

public static void writeReceivedMessagesToFile(String content,
                                               String filePath)
                                        throws IOException

Writes received messages to a file.

Parameters:

content - Message content to write.

filePath - File path where the message content should be written.

Throws:

IOException

writeStatisticsToFile

public static void writeStatisticsToFile(String content,
                                         String filePath)
                                  throws IOException

Writes statistics to a file.

Parameters:

content - Statistic content.

filePath - File path where the statistics should be written.

Throws:

IOException

writePublishedMessagesToFile

public static void writePublishedMessagesToFile(String content,
                                                String filePath)
                                         throws IOException

Writes published messages to a file.

Parameters:

content - Statistic content.

filePath - File path where the statistics should be written.

Throws:

IOException

initializeReceivedMessagesPrintWriter

public static void initializeReceivedMessagesPrintWriter(String filePath)
                                                  throws IOException

Initialize the message content print writer. This needs to be invoked before each test case.

Parameters:

filePath - The file path to write to.

Throws:

IOException

initializeStatisticsPrintWriter

public static void initializeStatisticsPrintWriter(String filePath)
                                            throws IOException

Initialize the statistics print writer. This needs to be invoked before each test case.

Parameters:

filePath - The file path to write to.

Throws:

IOException

initializePublishedPrintWriter

public static void initializePublishedPrintWriter(String filePath)
                                           throws IOException

Initialize the published messages print writer. This needs to be invoked before each test case.

Parameters:

filePath - The file path to write to.

Throws:

IOException

flushPrintWriters

public static void flushPrintWriters()

Prints print writers to file paths.

createMockFile

public static void createMockFile(String filePathToRead,
                                  String filePathToCreate,
                                  int sizeInKB)
                           throws IOException

Creates a file using a given file and a size.

Parameters:

filePathToRead - The file path to read contents from.

filePathToCreate - The path in which the contents should be written with a given size.

sizeInKB - The size of the file to be written in kilobytes.

Throws:

IOException

createRandomString

public static String createRandomString(int sizeInBytes,
                                        int maxLineSize)

Creates a random string.

Parameters:

sizeInBytes - The size of the file to be written in bytes.

maxLineSize - The maximum size of one line of the file to be written in bytes.

createRandomString

public static String createRandomString(int sizeInBytes)

Creates a one line random string

Parameters:

sizeInBytes - The size of the file to be written in bytes.

deleteRandomFile

public static void deleteRandomFile(String filePathToDelete)
                             throws IOException

Deletes a random file.

Parameters:

filePathToDelete - The path in which the contents should be written with a given size.

Throws:

IOException