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

Class AndesClientOutputParser

java.lang.Object

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

public class AndesClientOutputParser
extends Object

This class is used to get Andes Client outputs from parse file. The class provides evaluation functions for testing purposes.

Constructor Summary

Constructors

Constructor and Description
AndesClientOutputParser(String filePath) Creates an output parse for andes with a give file path.

Method Summary

Modifier and Type	Method and Description
boolean	checkIfMessagesAreInOrder() Checks if messages are received in the correct order.
boolean	checkIfTransactedRollbackPreservesOrder(long messagesPerRollback) Check whether all the messages are received in-order when subscriber rollbacks after certain number of messages.
Map<Long,Integer>	getDuplicatedMessages() Gets the map used for message duplication.
long	numberDuplicatedMessages() Parse the file and get the number of duplicate message IDs.
void	printDuplicateMessages() Prints duplicated message IDs Suppressing "UnusedDeclaration" as this could be used for debugging purposes
void	printMessagesMap() Prints the map that contains received messages.
void	printMessagesSorted() Prints received message IDs in sorted.
void	printMissingMessages(int numberOfSentMessages) Prints missing message IDs.
boolean	transactedOperations(long operationOccurredIndex) Check whether all the messages are transacted

Methods inherited from class java.lang.Object

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

Constructor Detail

AndesClientOutputParser

public AndesClientOutputParser(String filePath)
                        throws IOException

Creates an output parse for andes with a give file path.

Parameters:

filePath - The file path for received messages.

Throws:

IOException

Method Detail

getDuplicatedMessages

public Map<Long,Integer> getDuplicatedMessages()

Gets the map used for message duplication.

Returns:

A map of duplicated message IDs as key.

checkIfMessagesAreInOrder

public boolean checkIfMessagesAreInOrder()

Checks if messages are received in the correct order.

Returns:

true if messages are in order, false otherwise.

printMissingMessages

public void printMissingMessages(int numberOfSentMessages)

Prints missing message IDs. Suppressing "UnusedDeclaration" as this could be used for debugging purposes

Parameters:

numberOfSentMessages - Number of messages to print.

printDuplicateMessages

public void printDuplicateMessages()

Prints duplicated message IDs Suppressing "UnusedDeclaration" as this could be used for debugging purposes

printMessagesMap

public void printMessagesMap()

Prints the map that contains received messages. Suppressing "UnusedDeclaration" as this could be used for debugging purposes

printMessagesSorted

public void printMessagesSorted()

Prints received message IDs in sorted. Suppressing "UnusedDeclaration" as this could be used for debugging purposes

transactedOperations

public boolean transactedOperations(long operationOccurredIndex)
                             throws FileNotFoundException

Check whether all the messages are transacted

Parameters:

operationOccurredIndex - Index of the operation occurred message

Returns:

transactedResult

Throws:

FileNotFoundException

checkIfTransactedRollbackPreservesOrder

public boolean checkIfTransactedRollbackPreservesOrder(long messagesPerRollback)
                                                throws FileNotFoundException

Check whether all the messages are received in-order when subscriber rollbacks after certain number of messages.

Parameters:

messagesPerRollback - Number of messages received per rollback

Returns:

Result as true if transacted rollback operation has successfully preserved order of all messages.

Throws:

FileNotFoundException

numberDuplicatedMessages

public long numberDuplicatedMessages()

Parse the file and get the number of duplicate message IDs.

Returns:

Duplicated message ID count.