Index (PubSub+ Connector Framework Build 3.0.6 API)

A B C D E G J M N P R S V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accessType() - Element in annotation interface com.solace.connector.test.resources.resource.SolaceQueue: The queue accessType.
action() - Method in class com.solace.connector.test.resources.resource.SempV2Api: Gets the action SEMPv2 API client.
autoRegistered() - Element in annotation interface com.solace.connector.test.resources.resource.SolaceQueue: Whether the queue is automatically registered with other resources like ConnectorArgBuilder and SolaceMessaging.

B

build() - Method in class com.solace.connector.test.resources.annotation.SolaceQueueBuilder
build() - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Builds the command line arguments from the properties.

C

com.solace.connector.test.resources - package com.solace.connector.test.resources: Provides utilities and resources to support micro-integration testing.
com.solace.connector.test.resources.annotation - package com.solace.connector.test.resources.annotation: Convenient builders for instantiating resource annotation objects from an extension class.
com.solace.connector.test.resources.resource - package com.solace.connector.test.resources.resource: Resources managed by the PubSubPlusExtension for integration testing.
config() - Method in class com.solace.connector.test.resources.resource.SempV2Api: Gets the config SEMPv2 API client.
ConnectorArgsBuilder - Class in com.solace.connector.test.resources.resource: A builder class for constructing command-line arguments for micro-integration applications.
ConnectorArgsBuilder() - Constructor for class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Creates a new empty ConnectorArgsBuilder.
ConnectorArgsBuilder(Map<String, String>) - Constructor for class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Creates a new ConnectorArgsBuilder with the provided initial properties.
consumeAll(int) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Retrieve all messages that were processed by a workflow in the `Vendor -> Solace` direction.
consumeAll(Destination) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Consume all messages from a Solace queue.
consumeAndAssert(int, int, Consumer<BytesXMLMessage>) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Retrieve messages that were processed by a workflow in the `Vendor -> Solace` direction and perform validations on those messages.
consumeAndAssert(int, int, Consumer<BytesXMLMessage>, Duration) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Retrieve messages that were processed by a workflow in the `Vendor -> Solace` direction and perform validations on those messages.
consumeAndAssert(int, Destination, Consumer<BytesXMLMessage>) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Retrieve messages from a Solace queue and validate for correctness.
consumeAndAssert(int, Destination, Consumer<BytesXMLMessage>, Duration) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Retrieve messages from a Solace queue and validate for correctness.

D

deepCopy() - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Creates a deep copy of this builder with all the same properties.

E

ExcludeMessageFromExpectedCountException() - Constructor for exception com.solace.connector.test.resources.resource.SolaceMessaging.ExcludeMessageFromExpectedCountException
EXCLUSIVE - Enum constant in enum class com.solace.connector.test.resources.resource.SolaceQueue.AccessType

G

getInputDestination(int) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Gets the input destination configured for a specific workflow.
getOutputDestination(int) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Gets the output destination configured for a specific workflow.
getValue() - Method in enum class com.solace.connector.test.resources.resource.SolaceQueue.AccessType

J

JUNIT_STORE_KEY - Static variable in class com.solace.connector.test.resources.resource.SolaceMessaging

M

managementQueue(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the management queue.
ManagementQueue - Annotation Interface in com.solace.connector.test.resources.resource: Provision an exclusive management queue on the Solace broker.
managementSessionClientPassword(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the password for the management session.
managementSessionClientUsername(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the username for the management session.
managementSessionHost(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the host for the management session.
maxMsgSize() - Element in annotation interface com.solace.connector.test.resources.resource.SolaceQueue: The maximum message size in bytes Default 10000000
maxRedeliveryCount() - Element in annotation interface com.solace.connector.test.resources.resource.SolaceQueue: The maximum number of time the queue will deliver the message.
monitor() - Method in class com.solace.connector.test.resources.resource.SempV2Api: Gets the monitor SEMPv2 API client.

N

name() - Element in annotation interface com.solace.connector.test.resources.resource.ManagementQueue: The name of the management queue that is provisioned on the broker.
name() - Element in annotation interface com.solace.connector.test.resources.resource.SolaceQueue: The name of the queue that is provisioned on the broker.
NON_EXCLUSIVE - Enum constant in enum class com.solace.connector.test.resources.resource.SolaceQueue.AccessType

P

produceAsync(int, int, Supplier<BytesXMLMessage>) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Asynchronously publish messages to the Solace queue which is feeding a specific workflow.
produceAsync(int, Destination, Supplier<BytesXMLMessage>) - Method in class com.solace.connector.test.resources.resource.SolaceMessaging: Asynchronously publish messages to a Solace queue.
PubSubPlusExtension - Class in com.solace.connector.test.resources: Junit 5 extension for Micro-Integration Testing
PubSubPlusExtension() - Constructor for class com.solace.connector.test.resources.PubSubPlusExtension
put(String, Object) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Adds a property with the given key and object value.
put(String, String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Adds a property with the given key and string value.

R

redeliveryEnabled() - Element in annotation interface com.solace.connector.test.resources.resource.SolaceQueue: Whether message redelivery is enabled; set to false so that a message is never redelivered.

S

SempV2Api - Class in com.solace.connector.test.resources.resource: A wrapper for the SEMPv2 API that provides access to the Solace Event Broker's management interface.
solaceClientPassword(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the Solace client password.
solaceClientUsername(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the Solace client username.
solaceHost(String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the Solace broker host.
SolaceMessaging - Class in com.solace.connector.test.resources.resource: A utility to either:
- generate traffic on a workflow in the `Solace -> Vendor` direction OR
- retrieve messages that were processed by a workflow in the `Vendor -> Solace` direction and assert for correctness

Currently, this utility assumes that the Solace input and output destinations are always Queues.
SolaceMessaging.ExcludeMessageFromExpectedCountException - Exception in com.solace.connector.test.resources.resource: Exception that can be thrown by message validators to indicate that a specific message should be excluded from the expected message count.
SolaceQueue - Annotation Interface in com.solace.connector.test.resources.resource: Provision a queue on the Solace broker.
SolaceQueue.AccessType - Enum Class in com.solace.connector.test.resources.resource
SolaceQueueBuilder - Class in com.solace.connector.test.resources.annotation: Convenient builder for instantiating SolaceQueue annotation objects from an extension class.
SolaceQueueBuilder(String) - Constructor for class com.solace.connector.test.resources.annotation.SolaceQueueBuilder

V

valueOf(String) - Static method in enum class com.solace.connector.test.resources.resource.SolaceQueue.AccessType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.solace.connector.test.resources.resource.SolaceQueue.AccessType: Returns an array containing the constants of this enum class, in the order they are declared.

W

withAccessType(SolaceQueue.AccessType) - Method in class com.solace.connector.test.resources.annotation.SolaceQueueBuilder
withAutoRegistered(boolean) - Method in class com.solace.connector.test.resources.annotation.SolaceQueueBuilder
withMaxMsgSize(int) - Method in class com.solace.connector.test.resources.annotation.SolaceQueueBuilder
withMaxRedeliveryCount(long) - Method in class com.solace.connector.test.resources.annotation.SolaceQueueBuilder
withRedeliveryEnabled(boolean) - Method in class com.solace.connector.test.resources.annotation.SolaceQueueBuilder
workflowAcknowledgmentPublishAsync(int, boolean) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures whether acknowledgment publishing is asynchronous for a specific workflow.
workflowBatchEnabled(int, boolean) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures whether batch mode is enabled for a specific workflow.
workflowBatchMaxSize(int, int) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the maximum batch size for a specific workflow.
workflowEnable(int, boolean) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures whether a specific workflow is enabled.
workflowInputDestination(int, String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the input destination for a specific workflow.
workflowOutputDestination(int, String) - Method in class com.solace.connector.test.resources.resource.ConnectorArgsBuilder: Configures the output destination for a specific workflow.

A B C D E G J M N P R S V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form