org.apache.nifi.reporting

Class SiteToSiteBulletinReportingTask

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.reporting.AbstractReportingTask

org.apache.nifi.reporting.AbstractSiteToSiteReportingTask

org.apache.nifi.reporting.SiteToSiteBulletinReportingTask

All Implemented Interfaces:

ConfigurableComponent, ReportingTask, VerifiableReportingTask

@Tags(value={"bulletin","site","site to site"})
 @CapabilityDescription(value="Publishes Bulletin events using the Site To Site protocol. Note: only up to 5 bulletins are stored per component and up to 10 bulletins at controller level for a duration of up to 5 minutes. If this reporting task is not scheduled frequently enough some bulletins may not be sent.")
 @Restricted(restrictions=@Restriction(requiredPermission=EXPORT_NIFI_DETAILS,explanation="Provides operator the ability to send sensitive details contained in bulletin events to any external system."))
 @DefaultSchedule(strategy=TIMER_DRIVEN,
                 period="1 min")
public class SiteToSiteBulletinReportingTask
extends AbstractSiteToSiteReportingTask

Field Summary

Fields

Modifier and Type	Field and Description
private long	lastSentBulletinId

Fields inherited from class org.apache.nifi.reporting.AbstractSiteToSiteReportingTask

ALLOW_NULL_VALUES, DESTINATION_URL_PATH, LAST_EVENT_ID_KEY, RECORD_WRITER, recordSchema, siteToSiteClient, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
SiteToSiteBulletinReportingTask()

Method Summary

Modifier and Type	Method and Description
protected List<PropertyDescriptor>	getSupportedPropertyDescriptors()
void	onTrigger(ReportingContext context)
private javax.json.JsonObject	serialize(javax.json.JsonObjectBuilder builder, Bulletin bulletin, DateFormat df, String platform, String nodeIdentifier, Boolean allowNullValues)

Methods inherited from class org.apache.nifi.reporting.AbstractSiteToSiteReportingTask

addField, addField, addField, addField, getClient, getData, sendData, setup, shutdown, verify

Methods inherited from class org.apache.nifi.reporting.AbstractReportingTask

getControllerServiceLookup, getIdentifier, getLogger, getName, getNodeTypeProvider, getSchedulingPeriod, init, initialize, setComponentInfo

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.reporting.ReportingTask

isStateful

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

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

lastSentBulletinId

private volatile long lastSentBulletinId

Constructor Detail

SiteToSiteBulletinReportingTask

public SiteToSiteBulletinReportingTask()
                                throws IOException

Throws:

IOException

Method Detail

getSupportedPropertyDescriptors

protected List<PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class AbstractSiteToSiteReportingTask

onTrigger

public void onTrigger(ReportingContext context)

serialize

private javax.json.JsonObject serialize(javax.json.JsonObjectBuilder builder,
                                        Bulletin bulletin,
                                        DateFormat df,
                                        String platform,
                                        String nodeIdentifier,
                                        Boolean allowNullValues)