public abstract class AbstractQueueCollection extends AbstractCollection implements com.streamscape.sef.dii.AccessibleObject
Title: Dataspace Framework
Description: Abstract queue collection implementation.
Copyright: Copyright (c) 2009
Company: StreamScape Technologies
Modifier and Type | Class and Description |
---|---|
static class |
AbstractQueueCollection.KeyValue |
SchemaObject.ConstraintTypes, SchemaObject.Deferable, SchemaObject.Nullability, SchemaObject.ParameterModes, SchemaObject.ReferentialAction, SchemaObject.ViewCheckModes
ACTOR, ASPECTS, ASSERTION, CATALOG, CHARSET, COLLATION, COLLECTION, COLUMN, CONNECTION_FACTORY, CONSTRAINT, CURSOR, DOMAIN, emptyArray, EVENT_PROTOTYPE, FACETS, FILE_DESCRIPTOR, FULL_TEXT_INDEX, FUNCTION, GRANTEE, INDEX, JOB, LABEL, PARAMETER, PROCEDURE, REFERENCE_LINK, REPLICA, REPLICATION_SOURCE, ROUTINE, SCHEMA, SEMANTIC_TYPE, SEQUENCE, SERVER, SPECIFIC_ROUTINE, SUBQUERY, TABLE, TIMER, TRANSIENT_VAR, TRANSITION, TRIGGER, TYPE, VARIABLE, VIEW, WRAPPER
Modifier and Type | Method and Description |
---|---|
boolean |
add(com.streamscape.ds.session.Session session,
java.lang.Object object) |
boolean |
addAll(com.streamscape.ds.session.Session session,
java.util.Collection c) |
boolean |
addAll(com.streamscape.ds.session.Session session,
java.lang.String nodeName,
java.lang.String componentType,
java.lang.String componentName,
java.lang.String collectionName) |
void |
addRow(com.streamscape.ds.session.Session session,
java.lang.Object[] row) |
void |
addRows(com.streamscape.ds.session.Session session,
java.lang.Object[][] rows) |
void |
clear(com.streamscape.ds.session.Session session) |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
compileInternalStatements(com.streamscape.ds.session.Session session) |
boolean |
contains(com.streamscape.ds.session.Session session,
java.lang.Object o) |
boolean |
containsAll(com.streamscape.ds.session.Session session,
java.util.Collection c) |
boolean |
containsAll(com.streamscape.ds.session.Session session,
java.lang.String nodeName,
java.lang.String componentType,
java.lang.String componentName,
java.lang.String collectionName) |
void |
drainFromQueue(com.streamscape.ds.session.Session session,
java.util.Queue queue) |
java.lang.Object[][] |
drainRows(com.streamscape.ds.session.Session session,
java.lang.String selector) |
int |
drainRowsTo(com.streamscape.ds.session.Session session,
AbstractQueueCollection queue,
java.lang.String selector) |
int |
drainRowsTo(com.streamscape.ds.session.Session session,
java.lang.String nodeName,
java.lang.String componentType,
java.lang.String componentName,
java.lang.String collectionName,
java.lang.String selector) |
void |
drainToMap(com.streamscape.ds.session.Session session,
java.util.Map map) |
void |
drainToQueue(com.streamscape.ds.session.Session session,
java.util.Queue queue) |
void |
drainToRowSet(com.streamscape.ds.session.Session session,
RowSet rowSet) |
void |
drainToTable(com.streamscape.ds.session.Session session,
Table table) |
java.lang.Object |
element(com.streamscape.ds.session.Session session) |
java.lang.Object |
element(com.streamscape.ds.session.Session session,
boolean isLast) |
java.lang.Object |
elementLast(com.streamscape.ds.session.Session session) |
void |
fromMap(com.streamscape.ds.session.Session session,
java.util.Map map) |
void |
fromQueue(com.streamscape.ds.session.Session session,
java.util.Queue queue) |
void |
fromRowSet(com.streamscape.ds.session.Session session,
RowSet rowSet) |
void |
fromTable(com.streamscape.ds.session.Session session,
TableCollection table) |
long |
getMaxDepth() |
java.lang.String |
getName() |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
java.lang.String |
getQueueName() |
java.lang.String |
getSchema()
Gets schema where queue table exists.
|
java.lang.String |
getTableName()
Gets the table name that is used to store queue data.
|
boolean |
isEmpty(com.streamscape.ds.session.Session session) |
AbstractIterator |
iterator(com.streamscape.ds.session.Session session) |
boolean |
offer(com.streamscape.ds.session.Session session,
java.lang.Object eventObject) |
java.lang.Object |
peek(com.streamscape.ds.session.Session session) |
java.lang.Object |
peek(com.streamscape.ds.session.Session session,
boolean isLast) |
java.lang.Object |
peekLast(com.streamscape.ds.session.Session session) |
java.lang.Object |
poll(com.streamscape.ds.session.Session session) |
java.lang.Object |
poll(com.streamscape.ds.session.Session session,
boolean isLast) |
java.lang.Object |
pollLast(com.streamscape.ds.session.Session session) |
java.lang.Object |
remove(com.streamscape.ds.session.Session session) |
java.lang.Object |
remove(com.streamscape.ds.session.Session session,
boolean isLast) |
boolean |
remove(com.streamscape.ds.session.Session session,
java.lang.Object o) |
boolean |
removeAll(com.streamscape.ds.session.Session session,
java.util.Collection c) |
boolean |
removeAll(com.streamscape.ds.session.Session session,
java.lang.String nodeName,
java.lang.String componentType,
java.lang.String componentName,
java.lang.String collectionName) |
java.lang.Object |
removeLast(com.streamscape.ds.session.Session session) |
boolean |
retainAll(com.streamscape.ds.session.Session session,
java.util.Collection c) |
boolean |
retainAll(com.streamscape.ds.session.Session session,
java.lang.String nodeName,
java.lang.String componentType,
java.lang.String componentName,
java.lang.String collectionName) |
long |
size(com.streamscape.ds.session.Session session) |
java.lang.Object[] |
toArray(com.streamscape.ds.session.Session session) |
java.lang.Object[] |
toArray(com.streamscape.ds.session.Session session,
java.lang.Object[] a) |
java.util.Map |
toMap(com.streamscape.ds.session.Session session) |
MapCollection |
toMapCollection(com.streamscape.ds.session.Session session) |
java.util.Queue |
toQueue(com.streamscape.ds.session.Session session) |
BlockingQueueCollection |
toQueueCollection(com.streamscape.ds.session.Session session) |
RowSet |
toRowSet(com.streamscape.ds.session.Session session) |
TableCollection |
toTable(com.streamscape.ds.session.Session session) |
aggregateStateHolder, checkResultIsData, checkResultNotError, checkUpdateCountIs, close, count, destroy, dropReplicationSource, exposeCollectionState, getBaseTable, getCatalogName, getChangeTimestamp, getCollectionComponents, getCollectionName, getCollectionName, getCollectionProperties, getCollectionType, getCollectionType, getCollectionTypeName, getCollectionTypeNameCamelCase, getComponents, getDataspace, getEventForTrigger, getEvents, getMemoryModel, getMemoryModel, getObjectName, getObjectType, getOwner, getReferences, getReplicationSource, getSchemaName, getSQL, getSQL, getSQL, getSQL, getSQLForReplication, getStateHolder, getTriggerEventId, getWindowTriggers, isReplicated, isTriggerEventAutogenerated, listTriggers, listTriggers, open, resetBaseTable, setReplicationSource, unwrapEvent, updateBaseTable, validate, validateTypes, wrapEvent
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class AbstractCollection
public void compileInternalStatements(com.streamscape.ds.session.Session session)
compileInternalStatements
in interface Collection
compileInternalStatements
in class AbstractCollection
public long getMaxDepth()
public java.lang.String getName()
public java.lang.String getQueueName() throws javax.jms.JMSException
javax.jms.JMSException
public java.lang.String getSchema()
public java.lang.String getTableName()
public boolean offer(com.streamscape.ds.session.Session session, java.lang.Object eventObject)
public java.lang.Object remove(com.streamscape.ds.session.Session session)
public java.lang.Object removeLast(com.streamscape.ds.session.Session session)
public java.lang.Object remove(com.streamscape.ds.session.Session session, boolean isLast)
public java.lang.Object poll(com.streamscape.ds.session.Session session)
public java.lang.Object pollLast(com.streamscape.ds.session.Session session)
public java.lang.Object poll(com.streamscape.ds.session.Session session, boolean isLast)
public java.lang.Object element(com.streamscape.ds.session.Session session)
public java.lang.Object elementLast(com.streamscape.ds.session.Session session)
public java.lang.Object element(com.streamscape.ds.session.Session session, boolean isLast)
public java.lang.Object peek(com.streamscape.ds.session.Session session)
public java.lang.Object peekLast(com.streamscape.ds.session.Session session)
public java.lang.Object peek(com.streamscape.ds.session.Session session, boolean isLast)
public boolean remove(com.streamscape.ds.session.Session session, java.lang.Object o)
public boolean add(com.streamscape.ds.session.Session session, java.lang.Object object)
public long size(com.streamscape.ds.session.Session session)
public boolean isEmpty(com.streamscape.ds.session.Session session)
public void clear(com.streamscape.ds.session.Session session)
public boolean contains(com.streamscape.ds.session.Session session, java.lang.Object o)
public java.lang.Object[] toArray(com.streamscape.ds.session.Session session)
public AbstractIterator iterator(com.streamscape.ds.session.Session session)
public boolean addAll(com.streamscape.ds.session.Session session, java.util.Collection c)
public boolean addAll(com.streamscape.ds.session.Session session, java.lang.String nodeName, java.lang.String componentType, java.lang.String componentName, java.lang.String collectionName)
public boolean containsAll(com.streamscape.ds.session.Session session, java.util.Collection c)
public boolean containsAll(com.streamscape.ds.session.Session session, java.lang.String nodeName, java.lang.String componentType, java.lang.String componentName, java.lang.String collectionName)
public boolean removeAll(com.streamscape.ds.session.Session session, java.util.Collection c)
public boolean removeAll(com.streamscape.ds.session.Session session, java.lang.String nodeName, java.lang.String componentType, java.lang.String componentName, java.lang.String collectionName)
public boolean retainAll(com.streamscape.ds.session.Session session, java.util.Collection c)
public boolean retainAll(com.streamscape.ds.session.Session session, java.lang.String nodeName, java.lang.String componentType, java.lang.String componentName, java.lang.String collectionName)
public java.lang.Object[] toArray(com.streamscape.ds.session.Session session, java.lang.Object[] a)
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
public RowSet toRowSet(com.streamscape.ds.session.Session session)
public void fromRowSet(com.streamscape.ds.session.Session session, RowSet rowSet)
public java.util.Queue toQueue(com.streamscape.ds.session.Session session)
public void fromQueue(com.streamscape.ds.session.Session session, java.util.Queue queue)
public void drainFromQueue(com.streamscape.ds.session.Session session, java.util.Queue queue)
public java.util.Map toMap(com.streamscape.ds.session.Session session)
public void fromMap(com.streamscape.ds.session.Session session, java.util.Map map)
public TableCollection toTable(com.streamscape.ds.session.Session session)
public void fromTable(com.streamscape.ds.session.Session session, TableCollection table)
public MapCollection toMapCollection(com.streamscape.ds.session.Session session)
public BlockingQueueCollection toQueueCollection(com.streamscape.ds.session.Session session)
public void drainToMap(com.streamscape.ds.session.Session session, java.util.Map map)
public void drainToRowSet(com.streamscape.ds.session.Session session, RowSet rowSet)
public void drainToTable(com.streamscape.ds.session.Session session, Table table)
public void drainToQueue(com.streamscape.ds.session.Session session, java.util.Queue queue)
public void addRow(com.streamscape.ds.session.Session session, java.lang.Object[] row)
public void addRows(com.streamscape.ds.session.Session session, java.lang.Object[][] rows)
public int drainRowsTo(com.streamscape.ds.session.Session session, AbstractQueueCollection queue, java.lang.String selector)
public java.lang.Object[][] drainRows(com.streamscape.ds.session.Session session, java.lang.String selector)
public int drainRowsTo(com.streamscape.ds.session.Session session, java.lang.String nodeName, java.lang.String componentType, java.lang.String componentName, java.lang.String collectionName, java.lang.String selector)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.