Skip navigation links
A B C D E F G I J M N O P Q R S T U V W 

A

addReceivedMessage(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Adding the message content to the received messages list, after receiving the message, for this consumer.
addTopic(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.TopicAdminClient
Adds a new topic
ANDES_ACK_WAIT_TIMEOUT_PROPERTY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
System property name of andes acknowledgement wait timeout
ANDES_ICF - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Andes initial context factory.
ANDES_INITIAL_CONTEXT_FACTORY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.JMSClientHelper
Full qualified class name of the andes initial context factory
ANDES_REDELIVERY_DELAY_PROPERTY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
System property name of andes redelivery delay
ANDES_SET_ROUTING_KEY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
JMS Property allowing to append routing key for messages.
AndesAdminClient - Class in org.wso2.mb.integration.common.clients.operations.clients
Andes Admin Client is a client which is used to contact the Andes Admin services
AndesAdminClient(String, String) - Constructor for class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Initializes Andes Admin Client
AndesClient - Class in org.wso2.mb.integration.common.clients
This class represents the Andes Client which is used to publish/consume JMS messages.
AndesClient(AndesJMSClientConfiguration, boolean) - Constructor for class org.wso2.mb.integration.common.clients.AndesClient
Creates a single consumer or publisher based on the configuration passed
AndesClient(AndesJMSClientConfiguration, int, boolean) - Constructor for class org.wso2.mb.integration.common.clients.AndesClient
The constructor used for creating multiple consumer or publishers based on the configuration passed.
AndesClientConfigurationException - Exception in org.wso2.mb.integration.common.clients.exceptions
Exception class for andes client configuration.
AndesClientConfigurationException() - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientConfigurationException
Creates Andes configuration exception
AndesClientConfigurationException(String) - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientConfigurationException
Creates Andes configuration exception with error message
AndesClientConfigurationException(String, Throwable) - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientConfigurationException
Creates Andes configuration exception with error message and throwable
AndesClientConfigurationException(Throwable) - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientConfigurationException
Creates Andes configuration exception with throwable.
AndesClientConstants - Class in org.wso2.mb.integration.common.clients.operations.utils
This class contains the constants that are being used by the andes client.
AndesClientConstants() - Constructor for class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
 
AndesClientException - Exception in org.wso2.mb.integration.common.clients.exceptions
Exception class for andes client.
AndesClientException() - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientException
Creates Andes exception
AndesClientException(String) - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientException
Creates Andes exception with error message
AndesClientException(String, Throwable) - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientException
Creates Andes exception with error message and throwable
AndesClientException(Throwable) - Constructor for exception org.wso2.mb.integration.common.clients.exceptions.AndesClientException
Creates Andes exception with throwable.
AndesClientOutputParser - Class in org.wso2.mb.integration.common.clients.operations.utils
This class is used to get Andes Client outputs from parse file.
AndesClientOutputParser(String) - Constructor for class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Creates an output parse for andes with a give file path.
AndesClientUtils - Class in org.wso2.mb.integration.common.clients.operations.utils
This class provides functionality to evaluate Andes Client consumers and publishers.
AndesClientUtils() - Constructor for class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
 
AndesJMSBase - Class in org.wso2.mb.integration.common.clients
The base class for JMS publishers and consumers.
AndesJMSBase(AndesJMSClientConfiguration) - Constructor for class org.wso2.mb.integration.common.clients.AndesJMSBase
Creates the initial context.
AndesJMSClientConfiguration - Class in org.wso2.mb.integration.common.clients.configurations
This class acts as a configuration class for the Andes Client.
AndesJMSClientConfiguration() - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
The empty constructor which will create a queue related test case.
AndesJMSClientConfiguration(ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string with the default username, password, hostname, port.
AndesJMSClientConfiguration(String, int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string with default username, password and a given host name, port.
AndesJMSClientConfiguration(int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string with default username, password, hostname and a given port.
AndesJMSClientConfiguration(String, String, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string with a given username, password, exchange type and destination name.
AndesJMSClientConfiguration(int, String, String, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string with a given port, username, password, exchange type and destination name.
AndesJMSClientConfiguration(String, String, String, int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string with a given username, password, hostname, port, exchange type and destination name.
AndesJMSClientConfiguration(String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates a connection string using an xml file.
AndesJMSClientConfiguration(AndesJMSClientConfiguration) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Copy constructor for the client.
AndesJMSClientConfiguration(String, String, String, int, ExchangeType, String, String, String, String, String, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Creates an SSL connection string with a given username, password, hostname, port, exchange type and destination name.
AndesJMSConsumer - Class in org.wso2.mb.integration.common.clients
The JMS message consumer used for creating a consumer, reading messages synchronously and also asynchronously.
AndesJMSConsumer(AndesJMSConsumerClientConfiguration, boolean) - Constructor for class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Creates a new JMS consumer with a given configuration.
AndesJMSConsumerClientConfiguration - Class in org.wso2.mb.integration.common.clients.configurations
This class represents the Andes client consumer configuration.
AndesJMSConsumerClientConfiguration() - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer configuration with default values.
AndesJMSConsumerClientConfiguration(ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer with a given exchange type and destination with default connection string.
AndesJMSConsumerClientConfiguration(String, int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer with a given host name, port for connection string and exchange type and destination name.
AndesJMSConsumerClientConfiguration(int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer with a given port for connection string and exchange type and destination name.
AndesJMSConsumerClientConfiguration(String, String, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer with a given username, password, for connection string and exchange type and destination name.
AndesJMSConsumerClientConfiguration(int, String, String, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer with a given port, username, password, for connection string and exchange type and destination name.
AndesJMSConsumerClientConfiguration(String, String, String, int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a consumer with a given user name, password, host name, port for connection string and exchange type and destination name.
AndesJMSConsumerClientConfiguration(String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a configuration for a consumer using an xml file.
AndesJMSConsumerClientConfiguration(AndesJMSClientConfiguration) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
The copy constructor for the JMS base class.
AndesJMSConsumerClientConfiguration(String, String, String, int, ExchangeType, String, String, String, String, String, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Creates a JMS message consumer with a given AMQP transport connection string for SSL and a given exchange type and destination.
AndesJMSPublisher - Class in org.wso2.mb.integration.common.clients
The JMS message publisher used for creating a publisher and for publishing JMS messages.
AndesJMSPublisher(AndesJMSPublisherClientConfiguration, boolean) - Constructor for class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Creates a new JMS publisher with a given configuration.
AndesJMSPublisherClientConfiguration - Class in org.wso2.mb.integration.common.clients.configurations
This class represents the Andes client publisher configuration.
AndesJMSPublisherClientConfiguration() - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a connection string with default properties.
AndesJMSPublisherClientConfiguration(ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a publisher with a given exchange type and destination with default connection string.
AndesJMSPublisherClientConfiguration(String, int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a publisher with a given host name, port for connection string and exchange type and destination name.
AndesJMSPublisherClientConfiguration(int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a publisher with a given host name, port for connection string and exchange type and destination name.
AndesJMSPublisherClientConfiguration(String, String, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a publisher with a given username, password, for connection string and exchange type and destination name.
AndesJMSPublisherClientConfiguration(int, String, String, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a publisher with a given port, username, password, for connection string and exchange type and destination name.
AndesJMSPublisherClientConfiguration(String, String, String, int, ExchangeType, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a publisher with a given user name, password, host name, password for connection string and exchange type and destination name.
AndesJMSPublisherClientConfiguration(String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a configuration for a publisher using an xml file.
AndesJMSPublisherClientConfiguration(AndesJMSClientConfiguration) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
The copy constructor for the JMS base class.
AndesJMSPublisherClientConfiguration(String, String, String, int, ExchangeType, String, String, String, String, String, String) - Constructor for class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Creates a JMS message publisher with a given AMQP transport connection string for SSL and a given exchange type and destination.
authenticateStub(String, Stub) - Static method in class org.wso2.mb.integration.common.clients.operations.clients.utils.AuthenticateStubUtil
Stub authentication method
authenticateStub(String, String, Stub) - Static method in class org.wso2.mb.integration.common.clients.operations.clients.utils.AuthenticateStubUtil
Authenticate the given web service stub against the Product user manager.
AuthenticateStubUtil - Class in org.wso2.mb.integration.common.clients.operations.clients.utils
This class is used to authenticate a web services so that it's stubs can be used.
AuthenticateStubUtil() - Constructor for class org.wso2.mb.integration.common.clients.operations.clients.utils.AuthenticateStubUtil
 

B

browseQueue(String, int, int) - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Gets messages in a queue

C

CARBON_CLIENT_ID - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Carbon client ID.
CARBON_VIRTUAL_HOST_NAME - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
WSO2 carbon factory name.
CF_NAME - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Andes connection factory name
CF_NAME_PREFIX - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Connection factory name prefix.
checkIfMessagesAreDuplicated() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the duplicated messages received for a single consumer.
checkIfMessagesAreInOrder() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Checks whether the received messages are in order for a single consumer.
checkIfMessagesAreInOrder() - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Checks if messages are received in the correct order.
checkIfTransactedRollbackPreservesOrder(long) - Method in class org.wso2.mb.integration.common.clients.AndesClient
This method will check whether received messages are ordered correctly for a single consumer when rollback.
checkIfTransactedRollbackPreservesOrder(long) - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Check whether all the messages are received in-order when subscriber rollbacks after certain number of messages.
ClientMode - Enum in org.wso2.mb.integration.common.clients
The MQTT client mode to use.
clone() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
clone() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
createMockFile(String, String, int) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Creates a file using a given file and a size.
createQueue(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Creates a new queue
createRandomString(int, int) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Creates a random string.
createRandomString(int) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Creates a one line random string

D

DEFAULT_CLUSTER_SYNC_TIME - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Default waiting time that is used to check whether the consumer has received messages.
DEFAULT_HOST_NAME - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Default host name for AMQP connection string
DEFAULT_PASSWORD - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Admin password for AMQP connection string
DEFAULT_PORT - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Default port for AMQP connections string
DEFAULT_RUN_TIME - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Default waiting time that is used to check whether the consumer has received messages.
DEFAULT_USERNAME - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Admin user name for AMQP connection string
deleteQueue(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Deletes a queue
deleteRandomFile(String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Deletes a random file.

E

errorMessage - Variable in exception org.wso2.mb.integration.common.clients.exceptions.AndesClientConfigurationException
Error message for exception
errorMessage - Variable in exception org.wso2.mb.integration.common.clients.exceptions.AndesClientException
Error message for exception
ExchangeType - Enum in org.wso2.mb.integration.common.clients.operations.utils
Enumeration for JMS exchange types.

F

FILE_PATH_FOR_CREATING_A_NEW_FILE - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
File path creating a file.
FILE_PATH_FOR_ONE_KB_SAMPLE_FILE - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
File path for a file of size 1 kb.
FILE_PATH_TO_WRITE_RECEIVED_MESSAGES - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Default file path to write received messages by subscriber/consumer
FILE_PATH_TO_WRITE_STATISTICS - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Default file path to write statistics by subscriber/consumer and publisher Suppressing "UnusedDeclaration" as this may be used in client configuration
flushPrintWriters() - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Prints print writers to file paths.

G

getAcknowledgeAfterEachMessageCount() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the message count at which a message should be acknowledged after.
getAcknowledgeMode() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets acknowledge mode for messages.
getAverageLatency() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the average latency for consumer(s).
getAverageLatency() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the average latency for the consumer in receiving messages.
getCommitAfterEachMessageCount() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the message count at which the session should be committed.
getConfig() - Method in class org.wso2.mb.integration.common.clients.AndesJMSBase
Gets the configuration.
getConfig() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the configuration.
getConfig() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Gets the configuration.
getConnection() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the JMS message consuming connection (Connection).
getConnection() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Gets the JMS message sending connection (Connection).
getConnectionString() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the AMQP connection string.
getConsumers() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the all the consumers created by the client.
getConsumerTPS() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the average transactions per second for consumer(s).
getConsumerTPS() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the consumer transactions per seconds.
getDestinationName() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the destination name for publishing/consuming jms messages.
getDlcQueue() - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Get dead letter channel queue
getDuplicatedMessages() - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Gets the map used for message duplication.
getExchangeType() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the exchange type used for publishing/consuming jms messages.
getFilePathToWritePublishedMessages() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Gets the file path where published messages are written.
getFilePathToWriteReceivedMessages() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the file path where the received messages should be written to,
getFilePathToWriteStatistics() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the file path to write statistics such as TPS, Average latency against Timestamp.
getHostName() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the host name used in the AMQP connection string.
getInitialContext() - Method in class org.wso2.mb.integration.common.clients.AndesJMSBase
Gets the initial context.
getInitialContextForQueue(String, String, String, String, String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.JMSClientHelper
Create a inital context with the given parameters
getInitialContextForTopic(String, String, String, String, String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.JMSClientHelper
Create a inital context with the given parameters
getJMSHeaderProperties() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
 
getJMSMessageExpiryTime() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Gets the messages expiry time.
getJMSMessageType() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Gets JMS message type.
getJMSType() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Get JMS type
getKey() - Method in class org.wso2.mb.integration.common.clients.configurations.JMSHeaderProperty
Get Key of the header property
getMaximumMessagesToReceived() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the maximum number of messages to received.
getMessage() - Method in exception org.wso2.mb.integration.common.clients.exceptions.AndesClientConfigurationException
getMessage() - Method in exception org.wso2.mb.integration.common.clients.exceptions.AndesClientException
getMessageContentFromFile() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Reads message content from a file which is used as the message content to when publishing messages.
getMessagesContentToSet() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Get the message content to send
getNumberOfMessagesToSend() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Gets the number of messages to be sent by the publisher.
getPassword() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the password used in the AMQP connection string.
getPort() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the port used in the AMQP connection string.
getPrintsPerMessageCount() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the number of console logging per message count
getPublishers() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the all the publisher created by the client.
getPublisherTPS() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the average transactions per seconds for publisher(s).
getPublisherTPS() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Gets the transactions per seconds for publisher.
getQueueByName(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Get queue object by queue name
getReadMessagesFromFilePath() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Gets the file path to read a string content which would be used to as message content when publishing.
getReceivedMessageCount() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the received messages for all consumers in the client.
getReceivedMessageCount() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the received message count for the consumer.
getReceivedMessages() - Method in class org.wso2.mb.integration.common.clients.AndesClient
This method returns received messages for a single consumer.
getReceivedMessages() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
This method returns received messages for this consumer.
getReceiver() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the JMS message consumer (MessageConsumer).
getRecoverAfterEachMessageCount() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the message count at which the session should be recovered.
getRollbackAfterEachMessageCount() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the message count at which the session should be rolled-back.
getRunningDelay() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the delay used in publishing/consuming messages in milliseconds.
getSelectors() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the selectors query used by the consumer for filtering.
getSender() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Gets the JMS message producer (MessageProducer).
getSentMessageCount() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Gets the number of messages sent by the publisher(s).
getSentMessageCount() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Gets the published message count.
getSession() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Gets the JMS message consuming session (Session).
getSession() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Gets the JMS message sending session (Session).
getStatus() - Method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSDeliveryStatus
Gets JMS delivery status.
getSubscriptionID() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the subscription ID.
getTopicByName(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.TopicAdminClient
Get topic node by topic name
getTotalNumberOfDuplicates() - Method in class org.wso2.mb.integration.common.clients.AndesClient
This method returns number of duplicate received messages for a single consumer.
getType() - Method in class org.wso2.mb.integration.common.clients.configurations.JMSHeaderProperty
Get property of the header property.
getType() - Method in enum org.wso2.mb.integration.common.clients.operations.utils.ExchangeType
Gets exchange string.
getType() - Method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSAcknowledgeMode
Gets acknowledge mode
getType() - Method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSMessageType
Gets JMS message type.
getUnSubscribeAfterEachMessageCount() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Gets the message count to un-subscribe the consumer.
getUserName() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Gets the user name used in the AMQP connection string.
getValue() - Method in class org.wso2.mb.integration.common.clients.configurations.JMSHeaderProperty
Get value of the header property
getValue() - Method in enum org.wso2.mb.integration.common.clients.QualityOfService
Get the corresponding value for the given quality of service.

I

initializePublishedPrintWriter(String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Initialize the published messages print writer.
initializeReceivedMessagesPrintWriter(String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Initialize the message content print writer.
initializeStatisticsPrintWriter(String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Initialize the statistics print writer.
isAsync() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Checks whether consumer is asynchronously reading messages.
isDurable() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Checks whether the subscriber/consumer is durable.
isTransactionalSession() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Whether the session needs to be transactional or not.

J

JMS_ANDES_ROUTING_KEY_MESSAGE_PROPERTY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
The JMS property which stores routing key.
JMSAcknowledgeMode - Enum in org.wso2.mb.integration.common.clients.operations.utils
Enumeration for acknowledge modes in JMS
JMSClientHelper - Class in org.wso2.mb.integration.common.clients.operations.utils
 
JMSClientHelper() - Constructor for class org.wso2.mb.integration.common.clients.operations.utils.JMSClientHelper
 
jmsConfig - Variable in class org.wso2.mb.integration.common.clients.AndesJMSBase
The configuration file used in creating the JMS publishers and consumers.
JMSDeliveryStatus - Enum in org.wso2.mb.integration.common.clients.operations.utils
 
JMSHeaderProperty - Class in org.wso2.mb.integration.common.clients.configurations
This class represents configuration of a JMS Header property.
JMSHeaderProperty(String, Object, JMSHeaderPropertyType) - Constructor for class org.wso2.mb.integration.common.clients.configurations.JMSHeaderProperty
Create a new JMSHeaderProperty.
JMSHeaderPropertyType - Enum in org.wso2.mb.integration.common.clients.configurations
Keeps the type of the JMS header property.
JMSMessageType - Enum in org.wso2.mb.integration.common.clients.operations.utils
Enumeration for JMS message types.

M

MAP_MESSAGE_CONTENT_INPUT_FILE_PATH - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
File path to read message content for publishing
MESSAGE_CONTENT_INPUT_FILE_PATH_1MB - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
File path to read message content for publishing
MESSAGE_CONTENT_INPUT_FILE_PATH_WITHOUT_REPETITIONS_256KB - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
File path to read message content for publishing

N

numberDuplicatedMessages() - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Parse the file and get the number of duplicate message IDs.

O

onMessage(Message) - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
org.wso2.mb.integration.common.clients - package org.wso2.mb.integration.common.clients
 
org.wso2.mb.integration.common.clients.configurations - package org.wso2.mb.integration.common.clients.configurations
 
org.wso2.mb.integration.common.clients.exceptions - package org.wso2.mb.integration.common.clients.exceptions
 
org.wso2.mb.integration.common.clients.operations.clients - package org.wso2.mb.integration.common.clients.operations.clients
 
org.wso2.mb.integration.common.clients.operations.clients.utils - package org.wso2.mb.integration.common.clients.operations.clients.utils
 
org.wso2.mb.integration.common.clients.operations.utils - package org.wso2.mb.integration.common.clients.operations.utils
 

P

printDuplicateMessages() - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Prints duplicated message IDs Suppressing "UnusedDeclaration" as this could be used for debugging purposes
printMessagesMap() - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Prints the map that contains received messages.
printMessagesSorted() - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Prints received message IDs in sorted.
printMissingMessages(int) - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Prints missing message IDs.
PUBLISH_MESSAGE_FORMAT - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientConstants
Message publishing format
PUBLISHER_ROLE - Static variable in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
 
purgeQueue(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Deletes all messages in a queue

Q

QualityOfService - Enum in org.wso2.mb.integration.common.clients
The quality of service levels in MQTT.
QUEUE_CONNECTION_FACTORY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.JMSClientHelper
Queue connection factory name used

R

removeTopic(String) - Method in class org.wso2.mb.integration.common.clients.operations.clients.TopicAdminClient
Removes a topic
run() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
run() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher

S

setAcknowledgeAfterEachMessageCount(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the message count at which a message should be acknowledged after.
setAcknowledgeMode(JMSAcknowledgeMode) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets acknowledge mode for messages.
setAsync(boolean) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the consumer to read message asynchronously.
setCommitAfterEachMessageCount(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the message count at which the session should be committed.
setConnection(Connection) - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Sets the JMS message consuming connection (Connection).
setConnection(Connection) - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Sets the JMS message sending connection (Connection).
setConnectionString(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the AMQP transport connection string.
setDestinationName(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the destination name for publishing/consuming jms messages.
setDurable(boolean, String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets values for a durable subscription
setExchangeType(ExchangeType) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the exchange type used for publishing/consuming jms messages Suppressing "UnusedDeclaration" as this is a configuration
setFilePathToWritePublishedMessages(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Sets the file path to write messages that are being published by the client.
setFilePathToWriteReceivedMessages(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the file path where the received messages should be written to,
setFilePathToWriteStatistics(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the file path to write statistics such as TPS, Average latency against Timestamp Suppressing "UnusedDeclaration" as this is a configuration
setHostName(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets host name for the AMQP connection string.
setJMSHeaderProperty(String, Object, JMSHeaderPropertyType) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Set a header property to the messages published
setJMSMessageExpiryTime(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Sets the message expiry time.
setJMSMessageType(JMSMessageType) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Sets JMS message type.
setJMSType(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Set JMS Type to be set for publishing messages
setMaximumMessagesToReceived(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the maximum number of messages to received.
setMessagesContentOfConfiguration(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Set the message content to send
setNumberOfMessagesToSend(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Sets the number of messages to be sent by the publisher
setPassword(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets password for the AMQP connection string
setPort(int) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the AMQP connection string port.
setPrintsPerMessageCount(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the number of console logging per message count
setReadMessagesFromFilePath(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Sets the file path to read a string content which would be used to as message content when publishing.
setReceiver(MessageConsumer) - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Sets the JMS message consumer (MessageConsumer).
setRecoverAfterEachMessageCount(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets message count at which the session should be recovered.
setRollbackAfterEachMessageCount(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets message count at which the session should be rolled-back.
setRunningDelay(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets the delay used in publishing/consuming messages in milliseconds.
setSelectors(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the selectors query used by the consumer for filtering.
setSender(MessageProducer) - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Sets the JMS message producer (MessageProducer).
setSession(Session) - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Sets the JMS message consuming session (Session).
setSession(Session) - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Sets the JMS message sending session (Session).
setStartDelay(long) - Method in class org.wso2.mb.integration.common.clients.AndesClient
Sets the starting delay when starting publishers or consumers.
setSubscriptionID(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets the subscription ID
setTransactionalSession(boolean) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
Set the session transactional.
setUnSubscribeAfterEachMessageCount(long) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
Sets message count to un-subscribe the consumer.
setUserName(String) - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
Sets user name for the AMQP connection string
shutdownClient(AndesClient) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Shutdown the client gracefully without waiting.
sleepForInterval(long) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Sleeps for a certain time.
startClient() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Starts up the consumer(s) or publisher(s) to consume or publish messages.
startClient() - Method in class org.wso2.mb.integration.common.clients.AndesJMSBase
Starts up the publisher or consumer.
startClient() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Starts up the publisher or consumer.
startClient() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Starts up the publisher or consumer.
stopClient() - Method in class org.wso2.mb.integration.common.clients.AndesClient
Stops the client from publishing or consuming messages.
stopClient() - Method in class org.wso2.mb.integration.common.clients.AndesJMSBase
Stops the publisher or consumer
stopClient() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Stops the publisher or consumer
stopClient() - Method in class org.wso2.mb.integration.common.clients.AndesJMSPublisher
Stops the publisher or consumer
stopClientSync() - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
 

T

TOPIC_CONNECTION_FACTORY - Static variable in class org.wso2.mb.integration.common.clients.operations.utils.JMSClientHelper
Topic connection factory name used
TopicAdminClient - Class in org.wso2.mb.integration.common.clients.operations.clients
Topic Admin Client is a client which is used to contact the Topic Admin services
TopicAdminClient(String, String) - Constructor for class org.wso2.mb.integration.common.clients.operations.clients.TopicAdminClient
Initializes Topic Admin Client
toString() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSClientConfiguration
toString() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSConsumerClientConfiguration
toString() - Method in class org.wso2.mb.integration.common.clients.configurations.AndesJMSPublisherClientConfiguration
transactedOperation(long) - Method in class org.wso2.mb.integration.common.clients.AndesClient
This method returns whether received messages are transacted for a single consumer.
transactedOperations(long) - Method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientOutputParser
Check whether all the messages are transacted

U

unSubscribe(boolean) - Method in class org.wso2.mb.integration.common.clients.AndesJMSConsumer
Un-Subscribes and closes a consumers.
updatePermissionForQueue(String, QueueRolePermission) - Method in class org.wso2.mb.integration.common.clients.operations.clients.AndesAdminClient
Updating permissions for a queue.
updatePermissionForTopic(String, TopicRolePermission) - Method in class org.wso2.mb.integration.common.clients.operations.clients.TopicAdminClient
Updating permissions for a topic.

V

valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.ClientMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.configurations.JMSHeaderPropertyType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.ExchangeType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSAcknowledgeMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSDeliveryStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSMessageType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wso2.mb.integration.common.clients.QualityOfService
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.wso2.mb.integration.common.clients.ClientMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wso2.mb.integration.common.clients.configurations.JMSHeaderPropertyType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.ExchangeType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSAcknowledgeMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSDeliveryStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wso2.mb.integration.common.clients.operations.utils.JMSMessageType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wso2.mb.integration.common.clients.QualityOfService
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitForMessagesAndShutdown(AndesClient, long, long) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Waits until no messages are received.
waitForMessagesAndShutdown(AndesClient, long) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Waits until no messages are received.
writePublishedMessagesToFile(String, String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Writes published messages to a file.
writeReceivedMessagesToFile(String, String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Writes received messages to a file.
writeStatisticsToFile(String, String) - Static method in class org.wso2.mb.integration.common.clients.operations.utils.AndesClientUtils
Writes statistics to a file.
A B C D E F G I J M N O P Q R S T U V W 
Skip navigation links

Copyright © 2019 WSO2. All rights reserved.