Package com.suse.coco.attestation

Class ListeningThread

java.lang.Object

com.suse.coco.attestation.AbstractProcessorThread

com.suse.coco.attestation.ListeningThread

All Implemented Interfaces:

java.lang.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 java.lang.Object	connectionLock
private javax.sql.DataSource	dataSource
private boolean	forceShutdown
private static org.apache.logging.log4j.Logger	LOGGER
private org.postgresql.jdbc.PgConnection	pgConnection
private ProcessingThread	processingThread

Constructor Summary

Constructors

Constructor	Description
ListeningThread(javax.sql.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 Detail

LOGGER

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

connectionLock

private final java.lang.Object connectionLock

dataSource

private final javax.sql.DataSource dataSource

forceShutdown

private boolean forceShutdown

pgConnection

private org.postgresql.jdbc.PgConnection pgConnection

processingThread

private ProcessingThread processingThread

Constructor Detail

ListeningThread

ListeningThread(javax.sql.DataSource dataSourceIn)

Builds a listener thread

Parameters:

dataSourceIn - the datasource to be used to connect to the database

Method Detail

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)