public class IMHUtil
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
API_KEY |
static java.lang.String |
FAIL_SAFE |
static int |
GIVE_UPs |
static java.lang.String |
KAFKA_BROKER_SASL |
static java.lang.String |
NO_RECORDS |
static int |
NO_RECORDS_COUNT |
static java.lang.String |
PAYLOAD |
static java.lang.String |
STATUS |
static java.lang.String |
TOPIC_NAME |
static int |
ZERO |
| Constructor and Description |
|---|
IMHUtil() |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
compressData(byte[] data) |
static byte[] |
createPayload(java.util.Map props,
byte[] reqBytes,
boolean compress)
Deprecated.
|
static byte[] |
createPayloadAsJSON(java.util.Map props,
byte[] reqBytes,
boolean compress) |
static int |
getPollTimeOut() |
static com.ibm.json.java.JSONObject |
resurrectJSONPayload(byte[] reqBytes)
Deprecated.
|
static com.ibm.json.java.JSONObject |
resurrectJSONPayload(byte[] reqBytes,
boolean compressed) |
static java.util.Map |
resurrectPayload(byte[] reqBytes)
Deprecated.
|
static byte[] |
serializePayloadToBytes(java.util.HashMap req)
Deprecated.
|
static byte[] |
uncompressData(byte[] cdata) |
public static final java.lang.String NO_RECORDS
public static final java.lang.String STATUS
public static final int GIVE_UPs
public static final int NO_RECORDS_COUNT
public static final java.lang.String KAFKA_BROKER_SASL
public static final java.lang.String API_KEY
public static final java.lang.String FAIL_SAFE
public static final java.lang.String TOPIC_NAME
public static final int ZERO
public static final java.lang.String PAYLOAD
public static byte[] compressData(byte[] data)
throws MXException
MXExceptionpublic static int getPollTimeOut()
public static byte[] uncompressData(byte[] cdata)
throws MXException
MXException@Deprecated
public static byte[] createPayload(java.util.Map props,
byte[] reqBytes,
boolean compress)
throws MXException
MXExceptionpublic static byte[] createPayloadAsJSON(java.util.Map props,
byte[] reqBytes,
boolean compress)
throws MXException
MXException@Deprecated public static byte[] serializePayloadToBytes(java.util.HashMap req)
public static com.ibm.json.java.JSONObject resurrectJSONPayload(byte[] reqBytes,
boolean compressed)
throws java.io.IOException,
MXException
java.io.IOExceptionMXException@Deprecated
public static com.ibm.json.java.JSONObject resurrectJSONPayload(byte[] reqBytes)
throws java.io.IOException,
MXException
java.io.IOExceptionMXException@Deprecated
public static java.util.Map resurrectPayload(byte[] reqBytes)
throws java.io.IOException,
MXException
java.io.IOExceptionMXException