org.apache.nifi.processors.aws.sqs

Class DeleteSQS

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.AbstractProcessor

org.apache.nifi.processors.aws.AbstractAWSProcessor<ClientType>

org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor<com.amazonaws.services.sqs.AmazonSQSClient>

org.apache.nifi.processors.aws.sqs.AbstractSQSProcessor

org.apache.nifi.processors.aws.sqs.DeleteSQS

All Implemented Interfaces:

ConfigurableComponent, Processor

@SupportsBatching
 @SeeAlso(value={GetSQS.class,PutSQS.class})
 @InputRequirement(value=INPUT_REQUIRED)
 @Tags(value={"Amazon","AWS","SQS","Queue","Delete"})
 @CapabilityDescription(value="Deletes a message from an Amazon Simple Queuing Service Queue")
public class DeleteSQS
extends AbstractSQSProcessor

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.List<PropertyDescriptor>	properties
static PropertyDescriptor	RECEIPT_HANDLE

Fields inherited from class org.apache.nifi.processors.aws.sqs.AbstractSQSProcessor

BATCH_SIZE, QUEUE_URL

Fields inherited from class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor

AWS_CREDENTIALS_PROVIDER_SERVICE

Fields inherited from class org.apache.nifi.processors.aws.AbstractAWSProcessor

ACCESS_KEY, client, CREDENTIALS_FILE, DEFAULT_PROTOCOL, DEFAULT_USER_AGENT, ENDPOINT_OVERRIDE, PROXY_HOST, PROXY_HOST_PORT, region, REGION, REL_FAILURE, REL_SUCCESS, relationships, SECRET_KEY, SSL_CONTEXT_SERVICE, TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DeleteSQS()

Method Summary

Modifier and Type	Method and Description
protected java.util.List<PropertyDescriptor>	getSupportedPropertyDescriptors() Allows subclasses to register which property descriptor objects are supported.
void	onTrigger(ProcessContext context, ProcessSession session)

Methods inherited from class org.apache.nifi.processors.aws.sqs.AbstractSQSProcessor

createClient, createClient

Methods inherited from class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor

getCredentialsProvider, onScheduled, onScheduledUsingControllerService, onShutDown

Methods inherited from class org.apache.nifi.processors.aws.AbstractAWSProcessor

createConfiguration, customValidate, getClient, getCredentials, getRegion, getRelationships, initializeRegionAndEndpoint, onShutdown

Methods inherited from class org.apache.nifi.processor.AbstractProcessor

onTrigger

Methods inherited from class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, init, initialize, isConfigurationRestored, isScheduled, toString, updateConfiguredRestoredTrue, updateScheduledFalse, updateScheduledTrue

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, hashCode, onPropertyModified, validate

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

RECEIPT_HANDLE

public static final PropertyDescriptor RECEIPT_HANDLE

properties

public static final java.util.List<PropertyDescriptor> properties

Constructor Detail

DeleteSQS

public DeleteSQS()

Method Detail

getSupportedPropertyDescriptors

protected java.util.List<PropertyDescriptor> getSupportedPropertyDescriptors()

Description copied from class: AbstractConfigurableComponent

Allows subclasses to register which property descriptor objects are supported. Default return is an empty set.

Overrides:

getSupportedPropertyDescriptors in class AbstractConfigurableComponent

Returns:

PropertyDescriptor objects this processor currently supports

onTrigger

public void onTrigger(ProcessContext context,
                      ProcessSession session)

Specified by:

onTrigger in class AbstractProcessor