org.wso2.esb.integration.common.utils

Class Utils

java.lang.Object

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

public class Utils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Utils.ArtifactType

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static boolean	assertIfSystemLogContains(CarbonLogReader carbonLogReader, String expected) Check if the log contains the expected string.
static boolean	checkForLog(CarbonLogReader logReader, String expected, int timeout) Check for the existence of the given log message.
static void	deploySynapseConfiguration(org.apache.axiom.om.OMElement config, String artifactName, String artifactType, boolean isRestartRequired)
static void	deploySynapseConfiguration(org.apache.axiom.om.OMElement config, String artifactName, Utils.ArtifactType type, boolean isRestartRequired)
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 boolean	logExists(CarbonLogReader logReader, String expected, int timeout) Checks if the expected string is available in the tailed logs of carbon log reader.
static void	shutdownFailsafe(int port) method to kill existing servers which are bind to the given port
static void	undeploySynapseConfiguration(String artifactName, String artifactType)
static void	undeploySynapseConfiguration(String artifactName, String artifactType, boolean restartServer)
static void	undeploySynapseConfiguration(String artifactName, Utils.ArtifactType type, boolean restartServer)
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(CarbonLogReader carbonLogReader,
                                                String expected)

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

Parameters:

carbonLogReader - carbon log reader

expected - expected string

Returns:

true if a match found, false otherwise

logExists

public static boolean logExists(CarbonLogReader logReader,
                                String expected,
                                int timeout)
                         throws InterruptedException

Checks if the expected string is available in the tailed logs of carbon log reader. Stops the log reader once found. The polling will happen in one second intervals

Parameters:

logReader - Carbon log reader

expected - expected log string

timeout - max time to do polling

Throws:

InterruptedException - if interrupted while sleeping

checkForLog

public static boolean checkForLog(CarbonLogReader logReader,
                                  String expected,
                                  int timeout)
                           throws InterruptedException

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

Parameters:

logReader - Carbon log reader

expected - expected log string

timeout - max time to do polling

Throws:

InterruptedException - if interrupted while sleeping

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

deploySynapseConfiguration

public static void deploySynapseConfiguration(org.apache.axiom.om.OMElement config,
                                              String artifactName,
                                              Utils.ArtifactType type,
                                              boolean isRestartRequired)
                                       throws IOException

Throws:

IOException

deploySynapseConfiguration

public static void deploySynapseConfiguration(org.apache.axiom.om.OMElement config,
                                              String artifactName,
                                              String artifactType,
                                              boolean isRestartRequired)
                                       throws IOException

Throws:

IOException

undeploySynapseConfiguration

public static void undeploySynapseConfiguration(String artifactName,
                                                Utils.ArtifactType type,
                                                boolean restartServer)

undeploySynapseConfiguration

public static void undeploySynapseConfiguration(String artifactName,
                                                String artifactType)

undeploySynapseConfiguration

public static void undeploySynapseConfiguration(String artifactName,
                                                String artifactType,
                                                boolean restartServer)