| Package | Description |
|---|---|
| psdi.iface.jms | |
| psdi.iface.mic |
| Modifier and Type | Method and Description |
|---|---|
QueueConfig |
MaxQueueCacheImpl.getQueueConfig(java.lang.String queueName) |
QueueConfig |
MaxQueueCache.getQueueConfig(java.lang.String queueName) |
| Modifier and Type | Method and Description |
|---|---|
static QueueEmailInfo |
MessageUtil.getQueueEmailInfo(QueueConfig queueConfig) |
boolean |
MIFMsgHubMXTransactable.sendEmail(QueueConfig config,
java.sql.Connection conn,
java.lang.Exception e)
Select status and deleteflag to process message
|
boolean |
JMSMXTransactable.sendEmail(QueueConfig config,
java.sql.Connection conn,
java.lang.Throwable e)
Select status and deleteflag to process message
|
| Modifier and Type | Method and Description |
|---|---|
int |
EntMicService.viewKafkaQueueData(QueueConfig config,
java.lang.String selector,
int count,
int start,
UserInfo userInfo,
int partition,
boolean countOnly,
boolean unprocessedOnly,
java.util.List viewFilesList) |
int |
MicService.viewKafkaQueueData(QueueConfig config,
java.lang.String selector,
int count,
int start,
UserInfo userInfo,
int partition,
boolean countOnly,
boolean activeOnly,
java.util.List viewFilesList) |