|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.integration.dispatcher.DispatcherPolicy
public class DispatcherPolicy
Metadata for a MessageDispatcher
.
Field Summary | |
---|---|
static int |
DEFAULT_MAX_MESSAGES_PER_TASK
|
static long |
DEFAULT_RECEIVE_TIMEOUT
|
static int |
DEFAULT_REJECTION_LIMIT
|
static long |
DEFAULT_RETRY_INTERVAL
|
Constructor Summary | |
---|---|
DispatcherPolicy()
|
|
DispatcherPolicy(boolean publishSubscribe)
Create a DispatcherPolicy. |
Method Summary | |
---|---|
int |
getMaxMessagesPerTask()
Return the maximum number of messages for each retrieval attempt. |
long |
getReceiveTimeout()
Return the maximum amount of time in milliseconds to wait for a message to be available. |
int |
getRejectionLimit()
Return the maximum number of retries upon rejection. |
long |
getRetryInterval()
Return the amount of time in milliseconds to wait between rejections. |
boolean |
getShouldFailOnRejectionLimit()
Return whether an exception should be thrown when this dispatcher's rejectionLimit is reached. |
boolean |
isPublishSubscribe()
Return whether the dispatcher should attempt to publish to all of its handlers. |
void |
setMaxMessagesPerTask(int maxMessagesPerTask)
Set the maximum number of messages for each retrieval attempt. |
void |
setReceiveTimeout(long receiveTimeout)
Set the maximum amount of time in milliseconds to wait for a message to be available. |
void |
setRejectionLimit(int rejectionLimit)
Set the maximum number of retries upon rejection. |
void |
setRetryInterval(long retryInterval)
Set the amount of time in milliseconds to wait between rejections. |
void |
setShouldFailOnRejectionLimit(boolean shouldFailOnRejectionLimit)
Specify whether an exception should be thrown when this dispatcher's rejectionLimit is reached. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int DEFAULT_MAX_MESSAGES_PER_TASK
public static final long DEFAULT_RECEIVE_TIMEOUT
public static final int DEFAULT_REJECTION_LIMIT
public static final long DEFAULT_RETRY_INTERVAL
Constructor Detail |
---|
public DispatcherPolicy()
public DispatcherPolicy(boolean publishSubscribe)
publishSubscribe
- whether the dispatcher should attempt to publish
to all of its subscribed handlers. If 'false
' it will attempt
to send to a single handler (point-to-point).Method Detail |
---|
public boolean isPublishSubscribe()
public int getMaxMessagesPerTask()
public void setMaxMessagesPerTask(int maxMessagesPerTask)
public long getReceiveTimeout()
public void setReceiveTimeout(long receiveTimeout)
public int getRejectionLimit()
public void setRejectionLimit(int rejectionLimit)
public long getRetryInterval()
public void setRetryInterval(long retryInterval)
public boolean getShouldFailOnRejectionLimit()
rejectionLimit
is reached.
public void setShouldFailOnRejectionLimit(boolean shouldFailOnRejectionLimit)
rejectionLimit
is reached. The default value is 'true'.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |