com.epam.fixengine.jms.config

Class SessionInfo

java.lang.Object

com.epam.fixengine.jms.config.SessionInfo

public class SessionInfo
extends Object

Stores information about session.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALLOW_MEASURE_INCOMING_TIMESTAMP
static String	ALLOW_REJECT_MESSAGES
static String	CLIENT
static String	CONNECTION_NAME
static String	CONNECTIONS_COUNT
static String	CUSTOM_MESSAGE_TYPE
static String	DELIVERY_MODE
static String	DESTINATION_URI
static String	DURABLE_SUBSCRIPTION
static String	DURABLE_SUBSCRIPTION_NAME
static String	MASKED_TAGS
static String	MESSAGE_TYPE
static String	MESSAGING_MODE
static String	PUBLISH_TIMEOUT
static String	QUEUE_MAX_FILE_SIZE
static String	QUEUE_NORMAL_FILE_SIZE
static String	QUEUE_PERSISTENT
static String	QUEUE_SIZE
static String	SELECTOR
static String	SESSION_ACK_MODE
static String	SESSION_TYPE
static String	STORAGE_DIR
static String	STORAGE_FLUSH_MODE
static String	STORAGE_FLUSH_MODE_FORCE
static String	THREADS_PER_CONNECTION
static String	TIME_TO_LIVE
static String	TRANSACTED
static String	TRANSACTION_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
SessionInfo(String sessionID)
SessionInfo(String sessionID, String connectionName)

Method Summary

Modifier and Type	Method and Description
protected void	checkParameter(String value, String parameterName)
Map<String,Object>	getAdditionalParams()
String	getBackUpConnectionName()
int	getConnectionCount()
String	getConnectionName()
String	getCustomMessageType()
DeliveryMode	getDeliveryMode()
String	getDestinationURL()
String	getDurableSubscriptionName()
Map<byte[],Set<Integer>>	getMaskedTags()
MessageType	getMessageType()
MessagingMode	getMessagingMode()
long	getPublishTimeout()
long	getQueueMaxFileSize()
long	getQueueNormalFileSize()
int	getQueueSize()
String	getSelector()
SessionAckMode	getSessionAckMode()
String	getSessionID()
SessionType	getSessionType()
String	getStorageDir()
int	getThreadPerConnection()
int	getTimeToLive()
int	getTransactionBatchSize()
boolean	isAllowMeasureIncomingTimestamp()
boolean	isDurableSubscription()
boolean	isEnableRejectMessages()
boolean	isQueuePersistent()
boolean	isStorageForcedFlush()
boolean	isTransacted()
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	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	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)
Map<String,String>	toMap(Map<String,String> map)
StringBuilder	toString(StringBuilder stringBuffer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

STORAGE_FLUSH_MODE_FORCE

public static final String STORAGE_FLUSH_MODE_FORCE

See Also:

Constant Field Values

CONNECTION_NAME

public static final String CONNECTION_NAME

See Also:

Constant Field Values

SELECTOR

public static final String SELECTOR

See Also:

Constant Field Values

SESSION_TYPE

public static final String SESSION_TYPE

See Also:

Constant Field Values

MESSAGING_MODE

public static final String MESSAGING_MODE

See Also:

Constant Field Values

DESTINATION_URI

public static final String DESTINATION_URI

See Also:

Constant Field Values

CLIENT

public static final String CLIENT

See Also:

Constant Field Values

DELIVERY_MODE

public static final String DELIVERY_MODE

See Also:

Constant Field Values

TIME_TO_LIVE

public static final String TIME_TO_LIVE

See Also:

Constant Field Values

TRANSACTED

public static final String TRANSACTED

See Also:

Constant Field Values

TRANSACTION_BATCH_SIZE

public static final String TRANSACTION_BATCH_SIZE

See Also:

Constant Field Values

DURABLE_SUBSCRIPTION

public static final String DURABLE_SUBSCRIPTION

See Also:

Constant Field Values

DURABLE_SUBSCRIPTION_NAME

public static final String DURABLE_SUBSCRIPTION_NAME

See Also:

Constant Field Values

MESSAGE_TYPE

public static final String MESSAGE_TYPE

See Also:

Constant Field Values

CUSTOM_MESSAGE_TYPE

public static final String CUSTOM_MESSAGE_TYPE

See Also:

Constant Field Values

SESSION_ACK_MODE

public static final String SESSION_ACK_MODE

See Also:

Constant Field Values

STORAGE_DIR

public static final String STORAGE_DIR

See Also:

Constant Field Values

QUEUE_NORMAL_FILE_SIZE

public static final String QUEUE_NORMAL_FILE_SIZE

See Also:

Constant Field Values

QUEUE_MAX_FILE_SIZE

public static final String QUEUE_MAX_FILE_SIZE

See Also:

Constant Field Values

QUEUE_SIZE

public static final String QUEUE_SIZE

See Also:

Constant Field Values

QUEUE_PERSISTENT

public static final String QUEUE_PERSISTENT

See Also:

Constant Field Values

THREADS_PER_CONNECTION

public static final String THREADS_PER_CONNECTION

See Also:

Constant Field Values

CONNECTIONS_COUNT

public static final String CONNECTIONS_COUNT

See Also:

Constant Field Values

PUBLISH_TIMEOUT

public static final String PUBLISH_TIMEOUT

See Also:

Constant Field Values

MASKED_TAGS

public static final String MASKED_TAGS

See Also:

Constant Field Values

STORAGE_FLUSH_MODE

public static final String STORAGE_FLUSH_MODE

See Also:

Constant Field Values

ALLOW_REJECT_MESSAGES

public static final String ALLOW_REJECT_MESSAGES

See Also:

Constant Field Values

ALLOW_MEASURE_INCOMING_TIMESTAMP

public static final String ALLOW_MEASURE_INCOMING_TIMESTAMP

See Also:

Constant Field Values

Constructor Detail

SessionInfo

public SessionInfo(String sessionID)

SessionInfo

public SessionInfo(String sessionID,
                   String connectionName)

Method Detail

getSessionID

public String getSessionID()

setSessionID

public void setSessionID(String sessionID)

getConnectionName

public String getConnectionName()

setConnectionName

public void setConnectionName(String connectionName)

getSelector

public String getSelector()

setSelector

public void setSelector(String selector)

getBackUpConnectionName

public String getBackUpConnectionName()

setBackUpConnectionName

public void setBackUpConnectionName(String backUpConnectionName)

getSessionType

public SessionType getSessionType()

setSessionType

public void setSessionType(SessionType sessionType)

getMessagingMode

public MessagingMode getMessagingMode()

setMessagingMode

public void setMessagingMode(MessagingMode messagingMode)

getDestinationURL

public String getDestinationURL()

setDestinationURL

public void setDestinationURL(String destinationURL)

isTransacted

public boolean isTransacted()

setTransacted

public void setTransacted(boolean transacted)

getTransactionBatchSize

public int getTransactionBatchSize()

setTransactionBatchSize

public void setTransactionBatchSize(int transactionBatchSize)

getDeliveryMode

public DeliveryMode getDeliveryMode()

setDeliveryMode

public void setDeliveryMode(DeliveryMode deliveryMode)

getTimeToLive

public int getTimeToLive()

setTimeToLive

public void setTimeToLive(int timeToLive)

isDurableSubscription

public boolean isDurableSubscription()

setDurableSubscription

public void setDurableSubscription(boolean durableSubscription)

getDurableSubscriptionName

public String getDurableSubscriptionName()

setDurableSubscriptionName

public void setDurableSubscriptionName(String durableSubscriptionName)

getMessageType

public MessageType getMessageType()

setMessageType

public void setMessageType(MessageType messageType)

getCustomMessageType

public String getCustomMessageType()

setCustomMessageType

public void setCustomMessageType(String customMessageType)

getSessionAckMode

public SessionAckMode getSessionAckMode()

setSessionAckMode

public void setSessionAckMode(SessionAckMode sessionAckMode)

getStorageDir

public String getStorageDir()

setStorageDir

public void setStorageDir(String storageDir)

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

public Map<byte[],Set<Integer>> getMaskedTags()

setMaskedTags

public void setMaskedTags(Map<byte[],Set<Integer>> maskedTags)

isStorageForcedFlush

public boolean isStorageForcedFlush()

setStorageForcedFlush

public void setStorageForcedFlush(boolean isStorageForcedFlush)

isEnableRejectMessages

public boolean isEnableRejectMessages()

setEnableRejectMessages

public void setEnableRejectMessages(boolean enableRejectMessages)

isAllowMeasureIncomingTimestamp

public boolean isAllowMeasureIncomingTimestamp()

setAllowMeasureIncomingTimestamp

public void setAllowMeasureIncomingTimestamp(boolean allowMeasureIncomingTimestamp)

getAdditionalParams

public Map<String,Object> getAdditionalParams()

setAdditionalParams

public void setAdditionalParams(Map<String,Object> additionalParams)

parseSessionInfo

protected SessionInfo parseSessionInfo(String prefix,
                                       Properties properties)

Parses information about session.

Parameters:

prefix -

properties -

Returns:

SessionInfo

checkParameter

protected void checkParameter(String value,
                              String parameterName)

toString

public StringBuilder toString(StringBuilder stringBuffer)

toMap

public Map<String,String> toMap(Map<String,String> map)