org.xmlBlaster.util.protocol
Interface RequestReplyExecutorMBean

All Superinterfaces:

I_AdminPlugin, I_AdminUsage

All Known Subinterfaces:

EmailExecutorMBean, SocketExecutorMBean

All Known Implementing Classes:

EmailExecutor, RequestReplyExecutor, SocketExecutor

public interface RequestReplyExecutorMBean

extends I_AdminPlugin

JMX manage Request/Reply pattern.

Author:

xmlblast@marcelruff.info

Method Summary

int	getMinSizeForCompression() Compressing too small messages won't reduce the size
long	getPingResponseTimeout()
long	getResponseTimeout() The invocation timeout for all remaining method calls like "publish", "connect", "subscribe" but NOT for "ping" and "update"
long	getResponseTimeout(java.lang.String methodName)
long	getUpdateResponseTimeout()
int	interruptInvocation() Interrupts a blocking request with a not returning reply.
boolean	isCompressZlib()
boolean	isCompressZlibStream()
boolean	isUseEmailExpiryTimestamp()
void	setCompressZlib(boolean compress)
void	setCompressZlibStream(boolean compress)
void	setMinSizeForCompression(int minSizeForCompression)
void	setPingResponseTimeout(long millis) Set the given millis to protect against blocking client for ping invocations.
void	setResponseTimeout(long millis)
void	setUpdateResponseTimeout(long millis) Set the given millis to protect against blocking client for update() invocations.
void	setUseEmailExpiryTimestamp(boolean useEmailExpiryTimestamp)

Methods inherited from interface org.xmlBlaster.util.admin.I_AdminPlugin

getType, getVersion, isShutdown, shutdown

Methods inherited from interface org.xmlBlaster.util.admin.I_AdminUsage

getUsageUrl, setUsageUrl, usage

Method Detail

setResponseTimeout

public void setResponseTimeout(long millis)

setPingResponseTimeout

public void setPingResponseTimeout(long millis)

Set the given millis to protect against blocking client for ping invocations.

Parameters:

millis - If <= 0 it is set to the default (one minute). An argument less than or equal to zero means not to wait at all and is not supported

setUpdateResponseTimeout

public void setUpdateResponseTimeout(long millis)

Set the given millis to protect against blocking client for update() invocations.

Parameters:

millis - If <= 0 it is set to the default (one minute). An argument less than or equal to zero means not to wait at all and is not supported

getResponseTimeout

public long getResponseTimeout(java.lang.String methodName)

Returns:

Returns the responseTimeout.

getPingResponseTimeout

public long getPingResponseTimeout()

getResponseTimeout

public long getResponseTimeout()

The invocation timeout for all remaining method calls like "publish", "connect", "subscribe" but NOT for "ping" and "update"

Returns:

Returns the responseTimeout.

interruptInvocation

public int interruptInvocation()

Interrupts a blocking request with a not returning reply. The pending message is handled as not delivered and will be queued

isCompressZlib

public boolean isCompressZlib()

setCompressZlib

public void setCompressZlib(boolean compress)

getMinSizeForCompression

public int getMinSizeForCompression()

Compressing too small messages won't reduce the size

Returns:

The number of bytes, only compress if bigger

setMinSizeForCompression

public void setMinSizeForCompression(int minSizeForCompression)

isCompressZlibStream

public boolean isCompressZlibStream()

setCompressZlibStream

public void setCompressZlibStream(boolean compress)

getUpdateResponseTimeout

public long getUpdateResponseTimeout()

Returns:

Returns the updateResponseTimeout.

isUseEmailExpiryTimestamp

public boolean isUseEmailExpiryTimestamp()

Returns:

Returns the useEmailExpiryTimestamp.

setUseEmailExpiryTimestamp

public void setUseEmailExpiryTimestamp(boolean useEmailExpiryTimestamp)

Parameters:

useEmailExpiryTimestamp - The useEmailExpiryTimestamp to set.