public class ProcessQueueFactoryImpl extends EventQueueFactoryImpl
Title: Dataspace framework.
Description: Process queue factory implementation.
Copyright: Copyright (c) 2011
Company: StreamScape Technologies
ASYNC_CONSUMER, CONSUMER, EVENT_SCOPE, EXCLUDE_PROPERTY_LIST, INCLUDE_PROPERTY_LIST, SELECTOR, SOURCE_EVENT_AS_BLOB, TIME_WINDOW_UNIT, WINDOW_CHECK_INTERVAL, WINDOW_CHECK_INTERVAL_UNIT, WINDOW_SIZE, WINDOW_TYPE, WITH_SOURCE_EVENT
QUEUE_CONSTRAINT_PROPERTY
QUEUE_MAX_DEPTH_PROPERTY
MEMORY_MODEL_PROPERTY
Constructor and Description |
---|
ProcessQueueFactoryImpl() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getCreateSql(com.streamscape.ds.session.Session session,
java.lang.String name) |
ProcessState |
getInitialProcessState(com.streamscape.ds.session.Session session) |
int |
getMaxAttempts(com.streamscape.ds.session.Session session) |
java.lang.String |
getMetaTableName(com.streamscape.ds.session.Session session) |
long |
getOfferInterval(com.streamscape.ds.session.Session session) |
int |
getParallelDegree(com.streamscape.ds.session.Session session) |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
long |
getRecipientTimeout(com.streamscape.ds.session.Session session) |
boolean |
getSuspendOnFailure(com.streamscape.ds.session.Session session) |
void |
setInitialProcessState(com.streamscape.ds.session.Session session,
ProcessState processState) |
void |
setMaxAttempts(com.streamscape.ds.session.Session session,
int maxAttempts) |
void |
setMetaTableName(com.streamscape.ds.session.Session session,
java.lang.String metaTableName) |
void |
setOfferInterval(com.streamscape.ds.session.Session session,
long offerInterval) |
void |
setParallelDegree(com.streamscape.ds.session.Session session,
int parallelDegree) |
void |
setRecipientTimeout(com.streamscape.ds.session.Session session,
long recipientTimeout) |
void |
setSuspendOnFailure(com.streamscape.ds.session.Session session,
boolean suspendOnFailure) |
getEventScope, getExcludedProperties, getIncludedProperties, getSelector, getTimeWindowUnit, getWindowCheckInterval, getWindowCheckIntervalUnit, getWindowSize, getWindowType, isConsumer, isConsumerAsync, isSourceEventAsBlob, isSourceEventIncluded, setEventScope, setExcludedProperties, setIncludedProperties, setIsConsumer, setIsConsumerAsync, setSelector, setSourceEventAsBlob, setSourceEventIncluded, setTimeWindowUnit, setWindowCheckInterval, setWindowCheckIntervalUnit, setWindowSize, setWindowType
getConstraint, setConstraint
getQueueMaxDepth, setQueueMaxDepth
createCollection, getCollectionType, getCollectionType, getFactoryParameter, getFactoryParameter, getMemoryModel, init, setFactoryParameter, setFactoryParameter, setMemoryModel
public void setInitialProcessState(com.streamscape.ds.session.Session session, ProcessState processState)
public ProcessState getInitialProcessState(com.streamscape.ds.session.Session session)
public void setMetaTableName(com.streamscape.ds.session.Session session, java.lang.String metaTableName)
public java.lang.String getMetaTableName(com.streamscape.ds.session.Session session)
public void setMaxAttempts(com.streamscape.ds.session.Session session, int maxAttempts)
public int getMaxAttempts(com.streamscape.ds.session.Session session)
public void setOfferInterval(com.streamscape.ds.session.Session session, long offerInterval)
public long getOfferInterval(com.streamscape.ds.session.Session session)
public void setRecipientTimeout(com.streamscape.ds.session.Session session, long recipientTimeout)
public long getRecipientTimeout(com.streamscape.ds.session.Session session)
public void setSuspendOnFailure(com.streamscape.ds.session.Session session, boolean suspendOnFailure)
public boolean getSuspendOnFailure(com.streamscape.ds.session.Session session)
public void setParallelDegree(com.streamscape.ds.session.Session session, int parallelDegree)
public int getParallelDegree(com.streamscape.ds.session.Session session)
public java.lang.String getCreateSql(com.streamscape.ds.session.Session session, java.lang.String name)
getCreateSql
in class EventQueueFactoryImpl
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
getProxy
in class EventQueueFactoryImpl
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.