public class DefaultMessageSenderFactory
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
compressionEnabled |
private boolean |
discardMessagesIfQueueFull |
private int |
maxQueueSize |
private int |
minMessageLengthForCompression |
private java.util.Set<OutboundMessages> |
queuedMessageTypes |
private boolean |
queuingEnabled |
Constructor and Description |
---|
DefaultMessageSenderFactory() |
Modifier and Type | Method and Description |
---|---|
boolean |
getDiscardMessagesIfQueueFull() |
int |
getMaxQueueSize() |
DefaultMessageSender |
getMessageSender(WsOutbound wsOutbound,
MessageSenderListener listener) |
int |
getMinMessageLengthForCompression() |
java.util.Set<OutboundMessages> |
getQueuedMessageTypes() |
boolean |
isCompressionEnabled() |
private boolean |
isQueuedMessageType(OutboundMessages messageType) |
boolean |
isQueuingEnabled() |
void |
setCompressionEnabled(boolean compressionEnabled) |
void |
setDiscardMessagesIfQueueFull(boolean discardMessagesIfQueueFull) |
void |
setMaxQueueSize(int maxQueueSize) |
void |
setMinMessageLengthForCompression(int minMessageLengthForCompression) |
void |
setQueuedMessageTypes(java.util.Set<OutboundMessages> queuedMessageTypes) |
void |
setQueuingEnabled(boolean queuingEnabled) |
private boolean queuingEnabled
private int maxQueueSize
private boolean discardMessagesIfQueueFull
private boolean compressionEnabled
private int minMessageLengthForCompression
private java.util.Set<OutboundMessages> queuedMessageTypes
public DefaultMessageSender getMessageSender(WsOutbound wsOutbound, MessageSenderListener listener)
private boolean isQueuedMessageType(OutboundMessages messageType)
public boolean isCompressionEnabled()
public void setCompressionEnabled(boolean compressionEnabled)
public boolean isQueuingEnabled()
public void setQueuingEnabled(boolean queuingEnabled)
public int getMaxQueueSize()
public void setMaxQueueSize(int maxQueueSize)
public boolean getDiscardMessagesIfQueueFull()
public void setDiscardMessagesIfQueueFull(boolean discardMessagesIfQueueFull)
public int getMinMessageLengthForCompression()
public void setMinMessageLengthForCompression(int minMessageLengthForCompression)
public java.util.Set<OutboundMessages> getQueuedMessageTypes()
public void setQueuedMessageTypes(java.util.Set<OutboundMessages> queuedMessageTypes)