org.wso2.esb.integration.common.utils

Class Utils

java.lang.Object

org.wso2.esb.integration.common.utils.Utils

public class Utils
extends Object

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static boolean	assertIfSystemLogContains(org.wso2.carbon.integration.common.admin.client.LogViewerClient logViewerClient, String expected) Check if the system log contains the expected string.
static boolean	checkForLog(org.wso2.carbon.integration.common.admin.client.LogViewerClient logViewerClient, String expected, int timeout) Check for the existence of the given log message.
static boolean	checkForLogsWithPriority(org.wso2.carbon.integration.common.admin.client.LogViewerClient logViewerClient, String priority, String expected, int timeout) Check for the existence of a given log message of given priority within the given timeout
static org.apache.axiom.om.OMElement	getCustomPayload(String symbol)
static org.apache.axiom.om.OMElement	getCustomQuoteRequest(String symbol)
static org.apache.axiom.om.OMElement	getIncorrectRequest(String stringValue)
static org.apache.axiom.om.OMElement	getSimpleQuoteRequest(String symbol)
static org.apache.axiom.om.OMElement	getStockQuoteRequest(String symbol)
static boolean	isCarFileDeployed(String carFileName, org.wso2.carbon.integration.common.admin.client.ApplicationAdminClient applicationAdminClient, int timeout) Util function to check whether specified car file is deployed
static boolean	isQueueEmpty(String queueName) Check if the given queue does not contain any messages
static void	shutdownFailsafe(int port) method to kill existing servers which are bind to the given port
static boolean	waitForMessageCount(MessageStoreAdminClient messageStoreAdminClient, String messageStoreName, int expectedCount, long timeout) Wait for expected message count found in the message store until a defined timeout

Methods inherited from class java.lang.Object

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

Constructor Detail

Utils

public Utils()

Method Detail

getSimpleQuoteRequest

public static org.apache.axiom.om.OMElement getSimpleQuoteRequest(String symbol)

getCustomQuoteRequest

public static org.apache.axiom.om.OMElement getCustomQuoteRequest(String symbol)

getStockQuoteRequest

public static org.apache.axiom.om.OMElement getStockQuoteRequest(String symbol)

getIncorrectRequest

public static org.apache.axiom.om.OMElement getIncorrectRequest(String stringValue)

getCustomPayload

public static org.apache.axiom.om.OMElement getCustomPayload(String symbol)

shutdownFailsafe

public static void shutdownFailsafe(int port)
                             throws IOException

method to kill existing servers which are bind to the given port

Parameters:

port -

Throws:

IOException

isQueueEmpty

public static boolean isQueueEmpty(String queueName)
                            throws Exception

Check if the given queue does not contain any messages

Parameters:

queueName - queue to be checked

Returns:

true in queue is empty, false otherwise

Throws:

Exception - if error while checking

assertIfSystemLogContains

public static boolean assertIfSystemLogContains(org.wso2.carbon.integration.common.admin.client.LogViewerClient logViewerClient,
                                                String expected)
                                         throws RemoteException,
                                                org.wso2.carbon.logging.view.stub.LogViewerLogViewerException

Check if the system log contains the expected string. The search will be done for maximum 10 seconds.

Parameters:

logViewerClient - log viewer used for test

expected - expected string

Returns:

true if a match found, false otherwise

Throws:

RemoteException - due to a logviewer error

org.wso2.carbon.logging.view.stub.LogViewerLogViewerException - due to a logviewer error

checkForLog

public static boolean checkForLog(org.wso2.carbon.integration.common.admin.client.LogViewerClient logViewerClient,
                                  String expected,
                                  int timeout)
                           throws InterruptedException,
                                  RemoteException,
                                  org.wso2.carbon.logging.view.stub.LogViewerLogViewerException

Check for the existence of the given log message. The polling will happen in one second intervals.

Parameters:

logViewerClient - log viewer used for test

expected - expected log string

timeout - max time to do polling in seconds

Returns:

true if the log is found with given timeout, false otherwise

Throws:

InterruptedException - if interrupted while sleeping

RemoteException - due to a logviewer error

org.wso2.carbon.logging.view.stub.LogViewerLogViewerException - due to a logviewer error

checkForLogsWithPriority

public static boolean checkForLogsWithPriority(org.wso2.carbon.integration.common.admin.client.LogViewerClient logViewerClient,
                                               String priority,
                                               String expected,
                                               int timeout)
                                        throws InterruptedException,
                                               org.wso2.carbon.logging.view.stub.LogViewerLogViewerException,
                                               RemoteException

Check for the existence of a given log message of given priority within the given timeout

Parameters:

logViewerClient - LogViewerClient object

priority - priority level

expected - expected string to search in logs

timeout - timeout value in seconds

Returns:

true if a log found with the given priority and content within the given timeout, false otherwise

Throws:

InterruptedException

org.wso2.carbon.logging.view.stub.LogViewerLogViewerException

RemoteException

waitForMessageCount

public static boolean waitForMessageCount(MessageStoreAdminClient messageStoreAdminClient,
                                          String messageStoreName,
                                          int expectedCount,
                                          long timeout)
                                   throws InterruptedException,
                                          RemoteException

Wait for expected message count found in the message store until a defined timeout

Parameters:

messageStoreName - Message store name

expectedCount - Expected message count

timeout - Timeout to wait in Milliseconds

Returns:

true if the expected message count found, false otherwise

Throws:

InterruptedException

RemoteException

isCarFileDeployed

public static boolean isCarFileDeployed(String carFileName,
                                        org.wso2.carbon.integration.common.admin.client.ApplicationAdminClient applicationAdminClient,
                                        int timeout)
                                 throws Exception

Util function to check whether specified car file is deployed

Parameters:

carFileName - - Name of the car file to deploy

applicationAdminClient - - Application admin client

timeout - - timeout for car deployment

Returns:

true if the car file deployed successfully else, false

Throws:

Exception