Class S4JAdapterUtil

java.lang.Object

io.nosqlbench.adapter.s4j.util.S4JAdapterUtil

public class S4JAdapterUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	S4JAdapterUtil.DOC_LEVEL_PARAMS
static enum	S4JAdapterUtil.JMS_DEFINED_MSG_PROPERTY
static enum	S4JAdapterUtil.JMS_DEST_TYPES
static enum	S4JAdapterUtil.JMS_MESSAGE_TYPES
static enum	S4JAdapterUtil.JMS_MSG_HEADER_STD
static enum	S4JAdapterUtil.JMS_MSG_PROP_TYPES
static enum	S4JAdapterUtil.JMS_SESSION_MODES
static enum	S4JAdapterUtil.MSG_COMPRESSION_TYPE_STR

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JMS_SPEC_VER_12	////
static final String	JMS_SPEC_VER_20
static final String	NB_MSG_SEQ_PROP
static final String	NB_MSG_SIZE_PROP

Constructor Summary

Constructors

Constructor	Description
S4JAdapterUtil()

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	convertJsonToMap(String jsonStr)	////
static List<Object>	convertJsonToObjList(String jsonStr)	////
static String	getCredentialPassword(S4JClientConf s4jClientConf)
static String	getCredentialUserName(S4JClientConf s4jClientConf)
static String	getDestinationName(javax.jms.Destination destination, String destType)	////
static int	getSessionModeFromStr(String sessionModeStr)	////
static String	getValidJmsMsgPropTypeList()
static String	getValidJmsSessionModeList()
static String	getValidMsgCompressionTypeList()
static boolean	isAuthNRequired(S4JClientConf s4jClientConf)
static boolean	isUseCredentialsEnabled(S4JClientConf s4jClientConf)
static boolean	isValidJmsMessageType(String type)
static boolean	isValidMsgCompressionTypeStr(String type)
static boolean	isValidStdJmsMsgHeader(String header)
static void	pauseCurThreadExec(int pauseInSec)	////
static void	processMsgErrorHandling(Exception exception, boolean strictErrorHandling, String errorMsg)	////

Methods inherited from class java.lang.Object

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

Field Details

JMS_SPEC_VER_12

public static final String JMS_SPEC_VER_12

////

See Also:

• Constant Field Values

JMS_SPEC_VER_20

public static final String JMS_SPEC_VER_20

See Also:

• Constant Field Values

NB_MSG_SEQ_PROP

public static final String NB_MSG_SEQ_PROP

See Also:

• Constant Field Values

NB_MSG_SIZE_PROP

public static final String NB_MSG_SIZE_PROP

See Also:

• Constant Field Values

Constructor Details

S4JAdapterUtil

public S4JAdapterUtil()

Method Details

isValidStdJmsMsgHeader

public static boolean isValidStdJmsMsgHeader(String header)

getValidJmsSessionModeList

public static String getValidJmsSessionModeList()

isValidJmsMessageType

public static boolean isValidJmsMessageType(String type)

getValidJmsMsgPropTypeList

public static String getValidJmsMsgPropTypeList()

getValidMsgCompressionTypeList

public static String getValidMsgCompressionTypeList()

isValidMsgCompressionTypeStr

public static boolean isValidMsgCompressionTypeStr(String type)

convertJsonToMap

public static Map<String,String> convertJsonToMap(String jsonStr)
                                           throws Exception

////

Throws:

Exception

convertJsonToObjList

public static List<Object> convertJsonToObjList(String jsonStr)
                                         throws Exception

////

Throws:

Exception

getDestinationName

public static String getDestinationName(javax.jms.Destination destination,
 String destType)
                                 throws javax.jms.JMSException

////

Throws:

javax.jms.JMSException

getSessionModeFromStr

public static int getSessionModeFromStr(String sessionModeStr)

////

isAuthNRequired

public static boolean isAuthNRequired(S4JClientConf s4jClientConf)

isUseCredentialsEnabled

public static boolean isUseCredentialsEnabled(S4JClientConf s4jClientConf)

getCredentialUserName

public static String getCredentialUserName(S4JClientConf s4jClientConf)

getCredentialPassword

public static String getCredentialPassword(S4JClientConf s4jClientConf)

pauseCurThreadExec

public static void pauseCurThreadExec(int pauseInSec)

////

processMsgErrorHandling

public static void processMsgErrorHandling(Exception exception,
 boolean strictErrorHandling,
 String errorMsg)

////