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<java.lang.String,java.lang.String> props,
byte[] reqBytes,
boolean compress)
Deprecated.
|
static byte[] |
createPayloadAsJSON(java.util.Map<java.lang.String,java.lang.String> props,
byte[] reqBytes,
boolean compress) |
static com.ibm.json.java.JSONObject |
resurrectJSONPayload(byte[] reqBytes) |
static java.util.Map<java.lang.String,java.lang.Object> |
resurrectPayload(byte[] reqBytes)
Deprecated.
|
static byte[] |
serializePayloadToBytes(java.util.HashMap<java.lang.String,java.lang.Object> 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
MXException
public static byte[] uncompressData(byte[] cdata) throws MXException
MXException
@Deprecated public static byte[] createPayload(java.util.Map<java.lang.String,java.lang.String> props, byte[] reqBytes, boolean compress) throws MXException
MXException
public static byte[] createPayloadAsJSON(java.util.Map<java.lang.String,java.lang.String> props, byte[] reqBytes, boolean compress) throws MXException
MXException
@Deprecated public static byte[] serializePayloadToBytes(java.util.HashMap<java.lang.String,java.lang.Object> req)
public static com.ibm.json.java.JSONObject resurrectJSONPayload(byte[] reqBytes) throws java.io.IOException, MXException
java.io.IOException
MXException
@Deprecated public static java.util.Map<java.lang.String,java.lang.Object> resurrectPayload(byte[] reqBytes) throws java.io.IOException, MXException
java.io.IOException
MXException