au.com.cybersearch2.classyjpa.persist

Class PersistenceService<E>

java.lang.Object

au.com.cybersearch2.classyjpa.persist.PersistenceWorker

au.com.cybersearch2.classyjpa.persist.PersistenceService<E>

public abstract class PersistenceService<E>
extends PersistenceWorker

PersistenceService

Author:

Andrew Bowley 25 Jan 2016

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_QUEUE_LENGTH

Constructor Summary

Constructors

Constructor and Description
PersistenceService(String persistenceUnit, PersistenceContext persistenceContext)

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	onEntityReceived(E entity)
void	put(E element) Inserts the specified element into the service queue, waiting if necessary for space to become available.
void	shutdown()

Methods inherited from class au.com.cybersearch2.classyjpa.persist.PersistenceWorker

doWork, getPersistenceContext, getPersistenceUnit, resetErrorCount

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_QUEUE_LENGTH

public static int MAX_QUEUE_LENGTH

Constructor Detail

PersistenceService

public PersistenceService(String persistenceUnit,
                  PersistenceContext persistenceContext)

Method Detail

onEntityReceived

public abstract void onEntityReceived(E entity)

put

public void put(E element)
         throws InterruptedException

Inserts the specified element into the service queue, waiting if necessary for space to become available.

Parameters:

element - the element to add

Throws:

InterruptedException - if interrupted while waiting

ClassCastException - if the class of the specified element prevents it from being added to this queue

NullPointerException - if the specified element is null

IllegalArgumentException - if some property of the specified element prevents it from being added to this queue

shutdown

public void shutdown()