Package org.codice.alliance.video.stream.mpegts.netty

Class UdpStreamProcessor

java.lang.Object
org.codice.alliance.video.stream.mpegts.netty.UdpStreamProcessor
All Implemented Interfaces:
StreamProcessor
public class UdpStreamProcessor extends Object implements StreamProcessor

  • Field Details

    • MAX_METACARD_UPDATE_INITIAL_DELAY

      public static final long MAX_METACARD_UPDATE_INITIAL_DELAY

  • Constructor Details

    • UdpStreamProcessor

      public UdpStreamProcessor(StreamMonitor streamMonitor, org.osgi.framework.BundleContext bundleContext)

  • Method Details

    • getAdditionalProperties

      public Map<String,String> getAdditionalProperties()

    • setAdditionalProperties

      public void setAdditionalProperties(Map<String,String> additionalProperties)

    • getSubject

      public ddf.security.Subject getSubject()

    • setSubject

      public void setSubject(ddf.security.Subject subject)

    • getSecuritySubject

      public ddf.security.Subject getSecuritySubject(String ipAddress) throws ddf.security.service.SecurityServiceException
      Throws:
      ddf.security.service.SecurityServiceException

    • setStreamCreationPlugin

      public void setStreamCreationPlugin(StreamCreationPlugin streamCreationPlugin)
      Parameters:
      streamCreationPlugin - must be non-null

    • getDistanceTolerance

      @Nullable public Double getDistanceTolerance()

    • setDistanceTolerance

      public void setDistanceTolerance(@Nullable Double distanceTolerance)

    • getMetacardUpdateInitialDelay

      public long getMetacardUpdateInitialDelay()
      Description copied from interface: StreamProcessor
      Number of seconds to delay updates to metacards.
      Specified by:
      getMetacardUpdateInitialDelay in interface StreamProcessor
      Returns:
      seconds

    • setMetacardUpdateInitialDelay

      public void setMetacardUpdateInitialDelay(Long metacardUpdateInitialDelay)
      Parameters:
      metacardUpdateInitialDelay - must be non-null and >=0 and <=MAX_METACARD_UPDATE_INITIAL_DELAY

    • getStreamId

      public String getStreamId()
      Description copied from interface: StreamProcessor
      Get the string that uniquely identifies this stream.
      Specified by:
      getStreamId in interface StreamProcessor
      Returns:
      a unique identifier for this stream

    • getStreamUri

      public Optional<URI> getStreamUri()
      Description copied from interface: StreamProcessor
      Get the URI of the stream associated with this stream processor.
      Specified by:
      getStreamUri in interface StreamProcessor
      Returns:
      optional uri of the stream

    • getTitle

      public Optional<String> getTitle()
      Description copied from interface: StreamProcessor
      Get the title string to be used for the parent metacard.
      Specified by:
      getTitle in interface StreamProcessor
      Returns:
      optional title of the stream

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • setMegabyteCountRolloverCondition

      public void setMegabyteCountRolloverCondition(Integer count)
      Parameters:
      count - must be non-null and positive

    • setElapsedTimeRolloverCondition

      public void setElapsedTimeRolloverCondition(Long milliseconds)
      Parameters:
      milliseconds - must be non-null and positive

    • getPacketBuffer

      public PacketBuffer getPacketBuffer()

    • shutdown

      public void shutdown()
      Shutdown the stream processor. Attempts to flush and ingest any partial stream data regardless of IDR boundaries.

    • setStreamEndPlugin

      public void setStreamEndPlugin(StreamEndPlugin streamEndPlugin)

    • checkForRollover

      public void checkForRollover()

    • doRollover

      public void doRollover(File tempFile)

    • isReady

      public boolean isReady()
      Return true if the processor is ready to run.
      Returns:
      ready status

    • setRolloverAction

      public void setRolloverAction(RolloverAction rolloverAction)

    • getCatalogFramework

      public ddf.catalog.CatalogFramework getCatalogFramework()

    • setCatalogFramework

      public void setCatalogFramework(ddf.catalog.CatalogFramework catalogFramework)
      Parameters:
      catalogFramework - must be non-null

    • getFilenameGenerator

      public FilenameGenerator getFilenameGenerator()

    • setFilenameGenerator

      public void setFilenameGenerator(FilenameGenerator filenameGenerator)
      Parameters:
      filenameGenerator - must be non-null

    • getFilenameTemplate

      public String getFilenameTemplate()

    • setFilenameTemplate

      public void setFilenameTemplate(String filenameTemplate)
      Parameters:
      filenameTemplate - must be non-null

    • getMetacardTypeList

      public List<ddf.catalog.data.MetacardType> getMetacardTypeList()

    • setMetacardTypeList

      public void setMetacardTypeList(List<ddf.catalog.data.MetacardType> metacardTypeList)
      Parameters:
      metacardTypeList - must be non-null

    • getTimer

      public Timer getTimer()

    • setTimer

      public void setTimer(Timer timer)

    • init

      public void init()
      Initializes the processor. Users should call isReady() first to make sure the processor is ready to run.

    • setRolloverCondition

      public void setRolloverCondition(RolloverCondition rolloverCondition)
      Parameters:
      rolloverCondition - must be non-null

    • createChannelHandlers

      public io.netty.channel.ChannelHandler[] createChannelHandlers()
      Returns an array of ChannelHandler objects used by Netty as the pipeline.
      Returns:
      non-null array of channel handlers

    • setStreamShutdownPlugin

      public void setStreamShutdownPlugin(StreamShutdownPlugin streamShutdownPlugin)
      Parameters:
      streamShutdownPlugin - must be non-null

    • getParentMetacardUpdater

      public MetacardUpdater getParentMetacardUpdater()

    • setParentMetacardUpdater

      public void setParentMetacardUpdater(MetacardUpdater parentMetacardUpdater)

    • getUuidGenerator

      public org.codice.ddf.platform.util.uuidgenerator.UuidGenerator getUuidGenerator()

    • setUuidGenerator

      public void setUuidGenerator(org.codice.ddf.platform.util.uuidgenerator.UuidGenerator uuidGenerator)

    • getSubjectOperations

      public ddf.security.SubjectOperations getSubjectOperations()

    • setSubjectOperations

      public void setSubjectOperations(ddf.security.SubjectOperations subjectOperations)

    • getSecurityLogger

      public ddf.security.audit.SecurityLogger getSecurityLogger()

    • setSecurityLogger

      public void setSecurityLogger(ddf.security.audit.SecurityLogger securityLogger)