com.goldencode.p2j.persist

Class TemporaryBuffer.Multiplexer

java.lang.Object

com.goldencode.p2j.persist.TemporaryBuffer.Multiplexer

All Implemented Interfaces:

Finalizable

Enclosing class:

TemporaryBuffer

private class TemporaryBuffer.Multiplexer
extends java.lang.Object
implements Finalizable

An object registered with the TransactionManager to be notified when its enclosing buffer's scope is closing. This drives cleanup of the backing temp table, which can take one of two forms:

• if no other buffers are using the backing table any longer, the table is dropped (along with all records);
• otherwise, only those records associated with this buffer instance (as defined by this buffer's multiplex ID) are removed from the table, but the table itself is left intact.

Constructor Summary

Constructors

Constructor and Description
Multiplexer(Persistence.Context ctx) Constructor.

Method Summary

Modifier and Type	Method and Description
void	deleted() Provides a notification that the external program in which the object is registered is being deleted and the object's reference may be lost after this method is called.
void	finished() Cleans up the backing temp table by either dropping it (if no other buffers are using it any longer), or by removing this buffer's records from it.
void	iterate() No-op.
void	retry() No-op.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.goldencode.p2j.util.Finalizable

entry, initFailure, weight

Constructor Detail

Multiplexer

Multiplexer(Persistence.Context ctx)

Constructor.

Parameters:

ctx - Persistence context for transaction management.

Method Detail

iterate

public void iterate()

No-op.

Specified by:

iterate in interface Finalizable

retry

public void retry()

No-op.

Specified by:

retry in interface Finalizable

finished

public void finished()

Cleans up the backing temp table by either dropping it (if no other buffers are using it any longer), or by removing this buffer's records from it. If we are not already within a database-level transaction, begin a transaction before making the changes, and commit it afterward.

Specified by:

finished in interface Finalizable

deleted

public void deleted()

Provides a notification that the external program in which the object is registered is being deleted and the object's reference may be lost after this method is called.

This implementation does nothing.

Specified by:

deleted in interface Finalizable