Package com.epam.fixengine.jms.config
Class SessionInfo
java.lang.Object
com.epam.fixengine.jms.config.SessionInfo
Stores information about session.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
static final String
-
Constructor Summary
ConstructorsConstructorDescriptionSessionInfo
(String sessionID) SessionInfo
(String sessionID, String connectionName) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
checkParameter
(String value, String parameterName) int
long
long
long
long
int
int
int
int
boolean
boolean
boolean
boolean
boolean
boolean
boolean
protected String
parseParameter
(String localParameterName, String globalParameterName, TemplatePropertiesWrapper wrapperProperties, String defaultValue) protected SessionInfo
parseSessionInfo
(String prefix, Properties properties) Parses information about session.void
setAdditionalParams
(Map<String, Object> additionalParams) void
setAllowMeasureIncomingTimestamp
(boolean allowMeasureIncomingTimestamp) void
setBackUpConnectionName
(String backUpConnectionName) void
setChronicleQueue
(boolean chronicleQueue) void
setConnectionCount
(int connectionCount) void
setConnectionName
(String connectionName) void
setCustomMessageType
(String customMessageType) void
setDeliveryMode
(DeliveryMode deliveryMode) void
setDestinationURL
(String destinationURL) void
setDurableSubscription
(boolean durableSubscription) void
setDurableSubscriptionName
(String durableSubscriptionName) void
setEnableRejectMessages
(boolean enableRejectMessages) void
setMaskedTags
(Map<byte[], Set<Integer>> maskedTags) void
setMaxConnectedStateWaitTime
(long maxConnectedStateWaitTime) void
setMessageType
(MessageType messageType) void
setMessagingMode
(MessagingMode messagingMode) void
setPublishTimeout
(long publishTimeout) void
setQueueMaxFileSize
(long queueMaxFileSize) void
setQueueNormalFileSize
(long queueNormalFileSize) void
setQueuePersistent
(boolean queuePersistent) void
setQueueSize
(int queueSize) void
setSelector
(String selector) void
setSessionAckMode
(SessionAckMode sessionAckMode) void
setSessionID
(String sessionID) void
setSessionType
(SessionType sessionType) void
setStorageDir
(String storageDir) void
setStorageForcedFlush
(boolean isStorageForcedFlush) void
setThreadPerConnection
(int threadPerConnection) void
setTimeToLive
(int timeToLive) void
setTransacted
(boolean transacted) void
setTransactionBatchSize
(int transactionBatchSize) toString
(StringBuilder stringBuffer)
-
Field Details
-
STORAGE_FLUSH_MODE_FORCE
- See Also:
-
CONNECTION_NAME
- See Also:
-
SELECTOR
- See Also:
-
SESSION_TYPE
- See Also:
-
MESSAGING_MODE
- See Also:
-
DESTINATION_URI
- See Also:
-
CLIENT
- See Also:
-
DELIVERY_MODE
- See Also:
-
TIME_TO_LIVE
- See Also:
-
TRANSACTED
- See Also:
-
TRANSACTION_BATCH_SIZE
- See Also:
-
DURABLE_SUBSCRIPTION
- See Also:
-
DURABLE_SUBSCRIPTION_NAME
- See Also:
-
MESSAGE_TYPE
- See Also:
-
CUSTOM_MESSAGE_TYPE
- See Also:
-
SESSION_ACK_MODE
- See Also:
-
STORAGE_DIR
- See Also:
-
QUEUE_NORMAL_FILE_SIZE
- See Also:
-
QUEUE_MAX_FILE_SIZE
- See Also:
-
QUEUE_SIZE
- See Also:
-
QUEUE_PERSISTENT
- See Also:
-
CHRONICLE_QUEUE
- See Also:
-
THREADS_PER_CONNECTION
- See Also:
-
CONNECTIONS_COUNT
- See Also:
-
PUBLISH_TIMEOUT
- See Also:
-
MASKED_TAGS
- See Also:
-
STORAGE_FLUSH_MODE
- See Also:
-
ALLOW_REJECT_MESSAGES
- See Also:
-
ALLOW_MEASURE_INCOMING_TIMESTAMP
- See Also:
-
MAX_CONNECTED_STATE_WAIT_TIME
- See Also:
-
-
Constructor Details
-
SessionInfo
-
SessionInfo
-
-
Method Details
-
getSessionID
-
setSessionID
-
getConnectionName
-
setConnectionName
-
getSelector
-
setSelector
-
getBackUpConnectionName
-
setBackUpConnectionName
-
getSessionType
-
setSessionType
-
getMessagingMode
-
setMessagingMode
-
getDestinationURL
-
setDestinationURL
-
isTransacted
public boolean isTransacted() -
setTransacted
public void setTransacted(boolean transacted) -
getTransactionBatchSize
public int getTransactionBatchSize() -
setTransactionBatchSize
public void setTransactionBatchSize(int transactionBatchSize) -
getDeliveryMode
-
setDeliveryMode
-
getTimeToLive
public int getTimeToLive() -
setTimeToLive
public void setTimeToLive(int timeToLive) -
isDurableSubscription
public boolean isDurableSubscription() -
setDurableSubscription
public void setDurableSubscription(boolean durableSubscription) -
getDurableSubscriptionName
-
setDurableSubscriptionName
-
getMessageType
-
setMessageType
-
getCustomMessageType
-
setCustomMessageType
-
getSessionAckMode
-
setSessionAckMode
-
getStorageDir
-
setStorageDir
-
getQueueNormalFileSize
public long getQueueNormalFileSize() -
setQueueNormalFileSize
public void setQueueNormalFileSize(long queueNormalFileSize) -
getQueueMaxFileSize
public long getQueueMaxFileSize() -
setQueueMaxFileSize
public void setQueueMaxFileSize(long queueMaxFileSize) -
isQueuePersistent
public boolean isQueuePersistent() -
setQueuePersistent
public void setQueuePersistent(boolean queuePersistent) -
getQueueSize
public int getQueueSize() -
setQueueSize
public void setQueueSize(int queueSize) -
getThreadPerConnection
public int getThreadPerConnection() -
setThreadPerConnection
public void setThreadPerConnection(int threadPerConnection) -
getConnectionCount
public int getConnectionCount() -
setConnectionCount
public void setConnectionCount(int connectionCount) -
setPublishTimeout
public void setPublishTimeout(long publishTimeout) -
getPublishTimeout
public long getPublishTimeout() -
getMaskedTags
-
setMaskedTags
-
isStorageForcedFlush
public boolean isStorageForcedFlush() -
setStorageForcedFlush
public void setStorageForcedFlush(boolean isStorageForcedFlush) -
isEnableRejectMessages
public boolean isEnableRejectMessages() -
setEnableRejectMessages
public void setEnableRejectMessages(boolean enableRejectMessages) -
isChronicleQueue
public boolean isChronicleQueue() -
setChronicleQueue
public void setChronicleQueue(boolean chronicleQueue) -
isAllowMeasureIncomingTimestamp
public boolean isAllowMeasureIncomingTimestamp() -
setAllowMeasureIncomingTimestamp
public void setAllowMeasureIncomingTimestamp(boolean allowMeasureIncomingTimestamp) -
getMaxConnectedStateWaitTime
public long getMaxConnectedStateWaitTime() -
setMaxConnectedStateWaitTime
public void setMaxConnectedStateWaitTime(long maxConnectedStateWaitTime) -
getAdditionalParams
-
setAdditionalParams
-
parseSessionInfo
Parses information about session.- Parameters:
prefix
-properties
-- Returns:
- SessionInfo
-
parseParameter
protected String parseParameter(String localParameterName, String globalParameterName, TemplatePropertiesWrapper wrapperProperties, String defaultValue) -
checkParameter
-
toString
-
toMap
-