ListeningThread

java.lang.Object

com.suse.coco.attestation.AbstractProcessorThread

com.suse.coco.attestation.ListeningThread

All Implemented Interfaces:: Runnable

class ListeningThread extends AbstractProcessorThread

Listener thread of the AttestationQueueProcessor. Waits for the PostgreSQL notifications and notifies the ProcessingThread when there is data to process.

Field Summary

Fields

Modifier and Type

Field

Description

private final Object

connectionLock

private final DataSource

dataSource

private boolean

forceShutdown

private static final org.apache.logging.log4j.Logger

LOGGER

private org.postgresql.jdbc.PgConnection

pgConnection

private ProcessingThread

processingThread
Constructor Summary

Constructors

Constructor

Description

ListeningThread(DataSource dataSourceIn)

Builds a listener thread
Method Summary

Modifier and Type

Method

Description

private void

abortConnection()

void

run()

void

setProcessingThread(ProcessingThread processingThreadIn)

void

start()

Starts the processing of the thread.

void

stop()

Stops the processing of the thread, if it is running.

private void

updateConnection(org.postgresql.jdbc.PgConnection pgConnectionIn)

Methods inherited from class com.suse.coco.attestation.AbstractProcessorThread
await, isRunning, setRunning

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- LOGGER
  
  private static final org.apache.logging.log4j.Logger LOGGER
- connectionLock
  
  private final Object connectionLock
- dataSource
  
  private final DataSource dataSource
- forceShutdown
  
  private boolean forceShutdown
- pgConnection
  
  private org.postgresql.jdbc.PgConnection pgConnection
- processingThread
  
  private ProcessingThread processingThread
Constructor Details
- ListeningThread
  
  ListeningThread(DataSource dataSourceIn)
  
  Builds a listener thread
  
  Parameters:
  
  dataSourceIn - the datasource to be used to connect to the database
Method Details
- setProcessingThread
  
  public void setProcessingThread(ProcessingThread processingThreadIn)
- start
  
  public void start()
  
  Description copied from class: AbstractProcessorThread
  
  Starts the processing of the thread.
  
  Overrides:
  
  start in class AbstractProcessorThread
- stop
  
  public void stop()
  
  Description copied from class: AbstractProcessorThread
  
  Stops the processing of the thread, if it is running.
  
  Overrides:
  
  stop in class AbstractProcessorThread
- run
  
  public void run()
- abortConnection
  
  private void abortConnection()
- updateConnection
  
  private void updateConnection(org.postgresql.jdbc.PgConnection pgConnectionIn)