JabRef 6.0-beta.1 · org.jabref.logic.shared.notifications.NotificationListener

A listener for PostgreSQL database notifications.

Opens - and on failures reopens - its own database connection, because polling for notifications blocks the connection it runs on. Reconnecting is retried for as long as the library is open: every successful reconnect is followed by a full pull, so an outage costs nothing but delay.

Field Summary

Modifier and Type	Field and Description
private volatile @Nullable Connection	connection
private final DatabaseConnection	dbmsConnection
private final DBMSSynchronizer	dbmsSynchronizer
private final Gson	gson
private static final Logger	LOGGER
private static final long	MAX_RECONNECT_DELAY_MILLIS
private volatile @Nullable PGConnection	pgConnection
private final String	processorId
private volatile boolean	stop

Constructor Summary

Access	Constructor and Description
public	NotificationListener(DBMSSynchronizer dbmsSynchronizer, DatabaseConnection dbmsConnection, String processorId)

Method Summary

Modifier and Type	Method and Description
private void	closeConnection()
private PGConnection	connect()
private void	handleNotification(PGNotification notification)
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public void	start() Registers the notification subscription.
public void	stop()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

connection	back to summary
private volatile @Nullable Connection connection

dbmsConnection	back to summary
private final DatabaseConnection dbmsConnection

dbmsSynchronizer	back to summary
private final DBMSSynchronizer dbmsSynchronizer

gson	back to summary
private final Gson gson

LOGGER	back to summary
private static final Logger LOGGER

MAX_RECONNECT_DELAY_MILLIS	back to summary
private static final long MAX_RECONNECT_DELAY_MILLIS

pgConnection	back to summary
private volatile @Nullable PGConnection pgConnection

processorId	back to summary
private final String processorId

stop	back to summary
private volatile boolean stop

Constructor Detail

NotificationListener	back to summary
public NotificationListener(DBMSSynchronizer dbmsSynchronizer, DatabaseConnection dbmsConnection, String processorId)

Method Detail

closeConnection	back to summary
private void closeConnection()

connect	back to summary
private PGConnection connect() throws SQLException

handleNotification	back to summary
private void handleNotification(PGNotification notification)

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

start	back to summary
public void start() throws SQLException Registers the notification subscription. Called before the polling starts, so that no notification sent right after this method returns can be missed.