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 Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final String -
Constructor Summary
ConstructorsConstructorDescriptionSessionInfo(String sessionID) SessionInfo(String sessionID, String connectionName) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidcheckParameter(String value, String parameterName) intlonglonglonglongintintintintbooleanbooleanbooleanbooleanbooleanbooleanbooleanprotected StringparseParameter(String localParameterName, String globalParameterName, TemplatePropertiesWrapper wrapperProperties, String defaultValue) protected SessionInfoparseSessionInfo(String prefix, Properties properties) Parses information about session.voidsetAdditionalParams(Map<String, Object> additionalParams) voidsetAllowMeasureIncomingTimestamp(boolean allowMeasureIncomingTimestamp) voidsetBackUpConnectionName(String backUpConnectionName) voidsetChronicleQueue(boolean chronicleQueue) voidsetConnectionCount(int connectionCount) voidsetConnectionName(String connectionName) voidsetCustomMessageType(String customMessageType) voidsetDeliveryMode(DeliveryMode deliveryMode) voidsetDestinationURL(String destinationURL) voidsetDurableSubscription(boolean durableSubscription) voidsetDurableSubscriptionName(String durableSubscriptionName) voidsetEnableRejectMessages(boolean enableRejectMessages) voidsetMaskedTags(Map<byte[], Set<Integer>> maskedTags) voidsetMaxConnectedStateWaitTime(long maxConnectedStateWaitTime) voidsetMessageType(MessageType messageType) voidsetMessagingMode(MessagingMode messagingMode) voidsetPublishTimeout(long publishTimeout) voidsetQueueMaxFileSize(long queueMaxFileSize) voidsetQueueNormalFileSize(long queueNormalFileSize) voidsetQueuePersistent(boolean queuePersistent) voidsetQueueSize(int queueSize) voidsetSelector(String selector) voidsetSessionAckMode(SessionAckMode sessionAckMode) voidsetSessionID(String sessionID) voidsetSessionType(SessionType sessionType) voidsetStorageDir(String storageDir) voidsetStorageForcedFlush(boolean isStorageForcedFlush) voidsetThreadPerConnection(int threadPerConnection) voidsetTimeToLive(int timeToLive) voidsetTransacted(boolean transacted) voidsetTransactionBatchSize(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
-