com.northconcepts.datapipeline.core.DataEndpointGroup

public class DataEndpointGroup extends DataEndpoint

Helper class--makes it easy to work with multiple readers and writers as a single unit.

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint
DataEndpoint.State
Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject
id, log, name, TIMESTAMP_FORMAT
Constructor Summary

Constructors

Constructor

Description

DataEndpointGroup()
Method Summary

Modifier and Type

Method

Description

DataEndpointGroup

add(DataEndpoint... endpoints)

Adds endpoints to this group; open() opens them in the order added and close() closes them in reverse order.

void

close()

Indicates that this endpoint has finished reading or writing.

DataEndpoint

get(int index)

int

getCount()

Returns the number of endpoints in this group.

void

open()

Makes this endpoint ready for reading or writing.

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint
addExceptionProperties, decrementRecordCount, enableJmx, getLastRecord, getNestedEndpoint, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, getRootEndpoint, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription

Methods inherited from class com.northconcepts.datapipeline.core.DataObject
exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- DataEndpointGroup
  
  public DataEndpointGroup()
Method Details
- getCount
  
  public int getCount()
  
  Returns the number of endpoints in this group.
- add
  
  public DataEndpointGroup add(DataEndpoint... endpoints)
  
  Adds endpoints to this group; open() opens them in the order added and close() closes them in reverse order.
- get
  
  public DataEndpoint get(int index)
- open
  
  public void open() throws DataException
  
  Description copied from class: DataEndpoint
  
  Makes this endpoint ready for reading or writing.
  
  Overrides:
  
  open in class DataEndpoint
  
  Throws:
  
  DataException
- close
  
  public void close() throws DataException
  
  Description copied from class: DataEndpoint
  
  Indicates that this endpoint has finished reading or writing.
  
  Overrides:
  
  close in class DataEndpoint
  
  Throws:
  
  DataException

Class DataEndpointGroup

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

Constructor Summary

Method Summary

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

Methods inherited from class java.lang.Object

Constructor Details

DataEndpointGroup

Method Details

getCount

add

get

open

close