|
Oracle Fusion Middleware Java API Reference for Oracle Event Processing 11g Release 1 (11.1.1.7) E14303-11 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Method Summary | |
void |
configureQueueing(int consumerThreads, int queueSize) This method sets both the max threads and the max size. |
int |
getCurrentSize() Returns the current (used) size of Event Queue |
int |
getMaxSize() This method reads the size of the Channel . |
int |
getMaxThreads() This method reads the maximum number of Threads associated with the Stream's WorkManager |
long |
getOfferTimeout() Returns the timeout value used for waiting up until space becomes available in the event queue. |
boolean |
isFailWhenRejected() Returns true if an event processing exception should be raised when event queue is full and no space is available after offer timeout expires. |
void |
setFailWhenRejected(boolean value) Raise an EventProcessingException if the event queue is full when the offer timeout expires. |
void |
setMaxSize(int size) This method sets the size of the Channel . |
void |
setMaxThreads(int size) This method sets the maximum number of Threads associated with the Stream's WorkManager |
void |
setOfferTimeout(long timeout) Sets the timeout value used when the event queue is full and a pending insert (offer) is blocked. |
Method Detail |
public int getMaxSize() throws javax.management.JMException
Channel
. Only applicable if maxThreads
is greater than zero.public void setMaxSize(int size) throws javax.management.JMException
Channel
. Only applicable if maxThreads
is greater than zero.size
- - size of the Stream to setpublic int getMaxThreads() throws javax.management.JMException
public void setMaxThreads(int size) throws javax.management.JMException
size
- - Number of maximum threads that is associated with the WorkManagerpublic void configureQueueing(int consumerThreads, int queueSize) throws javax.management.JMException
consumerThreads
- queueSize
- public int getCurrentSize() throws javax.management.JMException
public long getOfferTimeout() throws javax.management.JMException
public void setOfferTimeout(long timeout) throws javax.management.JMException
timeout
- offer timeoutpublic void setFailWhenRejected(boolean value) throws javax.management.JMException
The default value is false.
value
- true if exception should be raised when rejected, false if event should be dropped instead.public boolean isFailWhenRejected() throws javax.management.JMException
|
Copyright © 2007, 2013 Oracle and/or its affiliates. All rights reserved. | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |