Class StreamingPipelineServiceImpl

java.lang.Object

org.j7m.middleware.examples.streaming.StreamingPipelineServiceImpl

All Implemented Interfaces:

StreamingPipelineService

public final class StreamingPipelineServiceImpl
extends Object
implements StreamingPipelineService

Thread-safe in-memory implementation of StreamingPipelineService.

Constructor Summary

Constructors

Constructor	Description
StreamingPipelineServiceImpl()	Creates an empty streaming-pipeline service.

Method Summary

Modifier and Type	Method	Description
String	adminStatus()	Returns a compact status line for demo/admin output.
boolean	cancel(StreamSession session)	Cancels a session.
StreamExchangeResult	exchange(StreamSession session, List<String> clientItems, int maxServerItems)	Submits client items and reads server items in one exchange.
StreamMetrics	metrics(StreamSession session)	Reads session metrics.
StreamSession	openSession(StreamOptions options)	Opens a streaming session.
List<String>	readBatch(StreamSession session, int maxItems)	Reads up to maxItems server items.
BatchResult	submitBatch(StreamSession session, List<String> items)	Submits a client batch to the session.

Methods inherited from class Object

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

Constructor Details

StreamingPipelineServiceImpl

public StreamingPipelineServiceImpl()

Creates an empty streaming-pipeline service.

Method Details

openSession

public StreamSession openSession(StreamOptions options)

Opens a streaming session.

Specified by:

openSession in interface StreamingPipelineService

Parameters:

options - stream options

Returns:

session handle

submitBatch

public BatchResult submitBatch(StreamSession session,
 List<String> items)

Submits a client batch to the session.

Specified by:

submitBatch in interface StreamingPipelineService

Parameters:

session - session handle

items - submitted items

Returns:

batch result

readBatch

public List<String> readBatch(StreamSession session,
 int maxItems)

Reads up to maxItems server items.

Specified by:

readBatch in interface StreamingPipelineService

Parameters:

session - session handle

maxItems - maximum items to read

Returns:

immutable batch of server items

exchange

public StreamExchangeResult exchange(StreamSession session,
 List<String> clientItems,
 int maxServerItems)

Submits client items and reads server items in one exchange.

Specified by:

exchange in interface StreamingPipelineService

Parameters:

session - session handle

clientItems - client items

maxServerItems - maximum server items to return

Returns:

exchange result

cancel

public boolean cancel(StreamSession session)

Cancels a session.

Specified by:

cancel in interface StreamingPipelineService

Parameters:

session - session handle

Returns:

whether cancellation changed the session state

metrics

public StreamMetrics metrics(StreamSession session)

Reads session metrics.

Specified by:

metrics in interface StreamingPipelineService

Parameters:

session - session handle

Returns:

immutable metrics

adminStatus

public String adminStatus()

Returns a compact status line for demo/admin output.

Specified by:

adminStatus in interface StreamingPipelineService

Returns:

safe status line