public class EventQueueFactory extends BlockingQueueFactory implements ConsumerAndEventPropertiesFactoryInterface, TimeWindowFactoryInterface
Title: Dataspace framework
Description: Event queue factory proxy implementation.
Copyright: Copyright (c) 2011
Company: StreamScape Technologies
Constructor and Description |
---|
EventQueueFactory() |
Modifier and Type | Method and Description |
---|---|
EventScope |
getEventScope() |
java.util.List |
getExcludedProperties() |
java.util.List |
getIncludedProperties() |
java.lang.String |
getSelector() |
java.util.concurrent.TimeUnit |
getTimeWindowUnit() |
long |
getWindowCheckInterval() |
java.util.concurrent.TimeUnit |
getWindowCheckIntervalUnit() |
long |
getWindowSize() |
com.streamscape.ds.core.CollectionWindowType |
getWindowType() |
boolean |
isConsumer() |
boolean |
isConsumerAsync() |
boolean |
isSourceEventAsBlob() |
boolean |
isSourceEventIncluded() |
void |
setConstraint(java.lang.String eventId) |
void |
setEventScope(EventScope eventScope) |
void |
setExcludedProperties(java.util.List eventProps) |
void |
setIncludedProperties(java.util.List eventProps) |
void |
setIsConsumer(boolean isConsumer) |
void |
setIsConsumerAsync(boolean isConsumerAsync) |
void |
setSelector(java.lang.String selector) |
void |
setSourceEventAsBlob(boolean sourceEventAsBlob) |
void |
setSourceEventIncluded(boolean include) |
void |
setTimeWindowUnit(java.util.concurrent.TimeUnit unit) |
void |
setWindowCheckInterval(long size) |
void |
setWindowCheckIntervalUnit(java.util.concurrent.TimeUnit unit) |
void |
setWindowSize(long size) |
void |
setWindowType(com.streamscape.ds.core.CollectionWindowType type) |
getConstraint
getFactoryParameter, setFactoryParameter
createCollection, getCollectionType, getCreateSql, getMemoryModel, setMemoryModel
public void setConstraint(java.lang.String eventId)
setConstraint
in class BlockingQueueFactory
public boolean isConsumer()
isConsumer
in interface ConsumerAndEventPropertiesFactoryInterface
public void setIsConsumer(boolean isConsumer)
setIsConsumer
in interface ConsumerAndEventPropertiesFactoryInterface
public boolean isConsumerAsync()
isConsumerAsync
in interface ConsumerAndEventPropertiesFactoryInterface
public void setIsConsumerAsync(boolean isConsumerAsync)
setIsConsumerAsync
in interface ConsumerAndEventPropertiesFactoryInterface
public EventScope getEventScope()
public void setEventScope(EventScope eventScope)
public java.lang.String getSelector()
getSelector
in interface ConsumerAndEventPropertiesFactoryInterface
public void setSelector(java.lang.String selector)
setSelector
in interface ConsumerAndEventPropertiesFactoryInterface
public void setExcludedProperties(java.util.List eventProps)
setExcludedProperties
in interface ConsumerAndEventPropertiesFactoryInterface
public java.util.List getExcludedProperties()
getExcludedProperties
in interface ConsumerAndEventPropertiesFactoryInterface
public void setIncludedProperties(java.util.List eventProps)
setIncludedProperties
in interface ConsumerAndEventPropertiesFactoryInterface
public java.util.List getIncludedProperties()
getIncludedProperties
in interface ConsumerAndEventPropertiesFactoryInterface
public boolean isSourceEventIncluded()
isSourceEventIncluded
in interface ConsumerAndEventPropertiesFactoryInterface
public boolean isSourceEventAsBlob()
isSourceEventAsBlob
in interface ConsumerAndEventPropertiesFactoryInterface
public void setSourceEventIncluded(boolean include)
setSourceEventIncluded
in interface ConsumerAndEventPropertiesFactoryInterface
public void setSourceEventAsBlob(boolean sourceEventAsBlob)
setSourceEventAsBlob
in interface ConsumerAndEventPropertiesFactoryInterface
public com.streamscape.ds.core.CollectionWindowType getWindowType()
getWindowType
in interface TimeWindowFactoryInterface
public void setWindowType(com.streamscape.ds.core.CollectionWindowType type)
setWindowType
in interface TimeWindowFactoryInterface
public long getWindowSize()
getWindowSize
in interface TimeWindowFactoryInterface
public void setWindowSize(long size)
setWindowSize
in interface TimeWindowFactoryInterface
public java.util.concurrent.TimeUnit getTimeWindowUnit()
getTimeWindowUnit
in interface TimeWindowFactoryInterface
public void setTimeWindowUnit(java.util.concurrent.TimeUnit unit)
setTimeWindowUnit
in interface TimeWindowFactoryInterface
public long getWindowCheckInterval()
getWindowCheckInterval
in interface TimeWindowFactoryInterface
public void setWindowCheckInterval(long size)
setWindowCheckInterval
in interface TimeWindowFactoryInterface
public java.util.concurrent.TimeUnit getWindowCheckIntervalUnit()
getWindowCheckIntervalUnit
in interface TimeWindowFactoryInterface
public void setWindowCheckIntervalUnit(java.util.concurrent.TimeUnit unit)
setWindowCheckIntervalUnit
in interface TimeWindowFactoryInterface
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.