public class MessageQueueCollection
extends com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
Title: DBH dataspace
Description: Queue for JMS messages
Copyright: Copyright (c) 2010
Company: StreamScape Technologies
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 |
---|---|
void |
destroy(com.streamscape.ds.session.Session session) |
java.lang.String |
getModel() |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
void |
onEvent(ImmutableEventDatagram event)
Processes the specified event.
|
activateWindow, close, compile, compileInternalStatements, contains, count, getCollectionProperties, getCollectionSQL, getConstraintEventId, getEventForTrigger, getEventId, getEvents, getEventScope, getReferences, getSelector, getSourceEvent, getTimeWindowUnit, getTriggerEventId, getWindowCheckInterval, getWindowCheckIntervalUnit, getWindowSize, getWindowType, isConsumer, isStarted, isTriggerEventAutogenerated, iterator, open, read, read, readAll, readLast, removeWindow, setConstraintEventId, setEventScope, setLastSlidingTimeWindowCheckerTime, setLastSlidingTimeWindowDeletedRows, setNextSlidingTimeWindowCheckerTime, setSelector, setTimeWindowUnit, setWindowCheckInterval, setWindowCheckIntervalUnit, setWindowSize, setWindowType, start, startWindow, stop, unwrapEvent, waitToRead, waitToRead, waitToReadLast, waitToTake, waitToTake, waitToTakeLast, wrapEvent
drain, drainTo, drainTo, drainTo, getDataType, offer, poll, poll, pollLast, put, remainingCapacity, setConstraint, take, take, takeLast
add, addAll, addAll, addRow, addRows, clear, containsAll, containsAll, drainFromQueue, drainRows, drainRowsTo, drainRowsTo, drainToMap, drainToQueue, drainToRowSet, drainToTable, element, element, elementLast, fromMap, fromQueue, fromRowSet, fromTable, getMaxDepth, getName, getQueueName, getSchema, getTableName, isEmpty, offer, peek, peek, peekLast, poll, poll, pollLast, remove, remove, remove, removeAll, removeAll, removeLast, retainAll, retainAll, size, toArray, toArray, toMap, toMapCollection, toQueue, toQueueCollection, toRowSet, toTable
aggregateStateHolder, checkResultIsData, checkResultNotError, checkUpdateCountIs, count, dropReplicationSource, exposeCollectionState, getBaseTable, getCatalogName, getChangeTimestamp, getCollectionComponents, getCollectionName, getCollectionName, getCollectionType, getCollectionType, getCollectionTypeName, getCollectionTypeNameCamelCase, getComponents, getDataspace, getMemoryModel, getMemoryModel, getObjectName, getObjectType, getOwner, getReplicationSource, getSchemaName, getSQL, getSQL, getSQL, getSQL, getSQLForReplication, getStateHolder, getWindowTriggers, isReplicated, listTriggers, listTriggers, resetBaseTable, setReplicationSource, updateBaseTable, validate, validateTypes
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public java.lang.String getModel()
public void onEvent(ImmutableEventDatagram event)
FabricEventListener
onEvent
in interface FabricEventListener
onEvent
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
event
- the event to be processed.public void destroy(com.streamscape.ds.session.Session session)
destroy
in interface Collection
destroy
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
getProxy
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.