Constructor Detail

• public KafkaPublisherStep(WsdlTestCase testCase, TestStepConfig config, boolean forLoadTest)

Method Detail

• @java.lang.Override public TestAssertion addAssertion(java.lang.String selection)

• @java.lang.Override public void addAssertionsListener(AssertionsListener listener)

• public void beforeSave()

• @java.lang.Override public TestAssertion cloneAssertion(TestAssertion source, java.lang.String name)

• @java.lang.Override public MultiConfigurationStepView getActiveStepType()

• @java.lang.Override public TestAssertion getAssertionAt(int c)

• @java.lang.Override public TestAssertion getAssertionByName(java.lang.String name)

• @java.lang.Override public int getAssertionCount()

• @java.lang.Override public java.util.List<TestAssertion> getAssertionList()

• @java.lang.Override public java.util.Map<java.lang.String, TestAssertion> getAssertions()

• @java.lang.Override public java.lang.String getConfigEndpoint()

• public PropertiesTypeConfig getConnectionProperties()

• public java.lang.String getMessageType()

• public java.lang.String getProducerMessageContent()

• @java.lang.Override public SchemaRegistryConfig getSchemaRegistryConfig()

• @java.lang.Override public TestAssertion moveAssertion(int ix, int offset)

• @java.lang.Override public void removeAssertion(TestAssertion assertion)

• @java.lang.Override public void removeAssertionsListener(AssertionsListener listener)

• @java.lang.Override public WsdlTestStepResult runInternal(WsdlTestStepResult result, SubmitContext context)

• public void setMessageType(java.lang.String messageType)

• public void setProducerMessageContent(java.lang.String newMessage)