Field Summary

Fields 

Modifiers	Name	Description
static java.lang.String	CLOSE_CONDITION_TYPE_LABEL
static PropertyDescriptor	IGNORE_MESSAGES_BEFORE_CONNECT
static java.lang.String	IGNORE_MESSAGES_BEFORE_CONNECT_LABEL
static PropertyDescriptor	MAX_IDLE_TIME
static java.lang.String	MAX_IDLE_TIME_LABEL
static PropertyDescriptor	MAX_MESSAGES_RECEIVED
static java.lang.String	MAX_MESSAGES_RECEIVED_LABEL
static PropertyDescriptor	MAX_RUN_TIME
static java.lang.String	MAX_RUN_TIME_LABEL

Inherited fields 

Fields inherited from class	Fields
class KafkaCommonStep	SMART_BEAR_OAUTH2_ACCESS_TOKEN_TEMP_FILE
class ProMultiConfigurationTestStep	PRODUCER_PARAMETER_VALUE_PARAMETER, UPDATE_TEST_STEP_UI_CONTENT, UPDATE_TEST_STEP_UI_METADATA

Constructor Summary

Constructors 

Constructor and description
KafkaSubscriberStep (WsdlTestCase testCase, TestStepConfig config, boolean forLoadTest)

Methods Summary

Methods 

Type Params	Return Type	Name and description
	public boolean	canAssert(java.lang.String assertionId)
	public boolean	cancel()
	public MultiConfigurationStepView	getActiveStepType()
	public java.lang.String	getAssertableContent()
	public java.lang.String	getAssertableMetadata()
	public AssertableType	getAssertableType()
	public AssertionStatus	getAssertionStatus()
	public java.lang.String	getCancelActionDescription()
	public java.lang.String	getConfigEndpoint()
	public KafkaSubscriberStep.KafkaSubscribeConnectionSettingsImpl	getConnectionSettings()
	public java.util.List<ConsumerRecord<java.lang.Object, java.lang.Object>>	getCurrentMessages()
	public JSONArray	getData()
	public java.lang.String	getDefaultAssertableContent()
	public java.lang.String	getKeyType()
	public int	getMaxIdleTime()
	public int	getMaxMessagesReceived()
	public int	getMaxRunTime()
	public java.lang.String	getMessageType()
	public ConsumerRecord<java.lang.Object, java.lang.Object>	getSelectedMessage()
	public void	propertyChange(java.beans.PropertyChangeEvent evt)
	public void	reloadConnectionProperties()
	public WsdlTestStepResult	runInternal(WsdlTestStepResult result, SubmitContext context)
	public void	setKeyType(java.lang.String keyType)
	public void	setMaxIdleTime(int newValue)
	public void	setMaxMessagesReceived(int newValue)
	public void	setMaxRunTime(int newValue)
	public void	setMessageType(java.lang.String messageType)
	public void	setSelectedMessage(ConsumerRecord<java.lang.Object, java.lang.Object> selectedMessage)

Inherited Methods Summary

Inherited Methods 

Methods inherited from class	Name
class KafkaCommonStep	addEndpointChangeListener, addOperationPropertyChangeListener, dependsOn, getActiveStepType, getChannelSetting, getConnectionProperties, getConnectionSettings, getDefaultKeyType, getDefaultMessageType, getEndpointSetting, getInterface, getKeyMessageTypes, getKeySchemaContent, getKeySchemaType, getKeyType, getOperation, getPossibleMessageTypes, getProtobufKeyType, getProtobufMessageType, getProtocolName, getRequiredInterfaces, getResourceContent, getResourceType, getSchemaContent, getSchemaType, getSchemas, propertyChange, release, reloadConnectionProperties, removeEndpointChangeListener, removeOperationPropertyChangeListener, requiresSchemaConfiguration, setKeySchema, setOperationId, setProtobufKeyType, setProtobufMessageType, setValueSchema
class ProMultiConfigurationTestStep	addAssertion, addAssertionsListener, addEndpointChangeListener, areBuiltInProfilesSupported, beforeSave, canAssert, clone, cloneAssertion, erase, getActiveStepType, getAssertableContent, getAssertableContentAsXml, getAssertableType, getAssertionAt, getAssertionByName, getAssertionCount, getAssertionList, getAssertionResultsSupport, getAssertionStatus, getAssertions, getAuthProfile, getAuthProfileHolder, getCancelActionDescription, getConfigAdapter, getConfigEndpoint, getDefaultAssertableContent, getDefaultMessageType, getEndpoint, getIcon, getInitialRequestMessage, getInterface, getMessageContent, getMessageType, getMetadataParameters, getOperation, getOperationName, getPossibleMessageTypes, getPropertyExpansions, getRequiredInterfaces, getResourceContent, getResourceType, getTestRequest, getTestStep, getViewAsListForMessageType, initNew, insertAssertion, isAuthProfileSupported, isTestStepExecuting, moveAssertion, prepare, propertyChange, release, removeAssertion, removeAssertionsListener, removeEndpointChangeListener, resetConfigOnMove, run, setAuthProfile, setConfigEndpoint, setEndpoint, setKeyType, setMessageContent, setMessageType, setOperationId, setTestStepRunListener, setTestStepTopPanelHandler, updateAssertionsStatus, updateCustomPropertiesView