org.openmdx.base.stream.rmi.spi
Interface StreamSynchronization_1_0

All Superinterfaces:

Synchronization_1_0

All Known Subinterfaces:

StreamSynchronization_1_1

public interface StreamSynchronization_1_0
extends Synchronization_1_0

Stream Synchronization Interface

Nested Class Summary

static interface	StreamSynchronization_1_0.SinkEntry Sink Entry
static interface	StreamSynchronization_1_0.SourceEntry Source Entry

Method Summary

StreamSynchronization_1_0.SinkEntry	add(Sink_1_0 nonTransactionalSink) Create a sink entry
StreamSynchronization_1_0.SourceEntry	add(Source_1_0 nonTransactionalSource) Create a source entry

Methods inherited from interface org.openmdx.base.transaction.Synchronization_1_0

afterBegin, afterCompletion, beforeCompletion

Method Detail

add

StreamSynchronization_1_0.SourceEntry add(Source_1_0 nonTransactionalSource)
                                          throws IOException

Create a source entry

The source will be copied to the cache before the unit of work starts.

Parameters:

nonTransactionalSource -

Throws:

IOException

add

StreamSynchronization_1_0.SinkEntry add(Sink_1_0 nonTransactionalSink)
                                        throws IOException

Create a sink entry

The sink will be flushed after the unit of work's commitment.

Parameters:

nonTransactionalSink -

Throws:

IOException