Package | Description |
---|---|
com.axemble.vdoc.sdk.interfaces |
Modifier and Type | Interface and Description |
---|---|
interface |
IJMSMessageProcessor<M extends IJMSMessage> |
interface |
IJMSQueueDeclaration<M extends IJMSMessage>
Implementation of this interface are looked up at application startup and used to create queue if doesnt exist and start consumers which
will process queue's messages.
|
Modifier and Type | Method and Description |
---|---|
void |
IJMSQueueController.putMessage(IJMSMessage message)
Enqueue a message into the queue
|
void |
IJMSQueueController.putMessage(IJMSMessage message,
List<IJMSMessageProperty<?>> properties)
Enqueue a message into the queue with properties
|
Modifier and Type | Method and Description |
---|---|
int |
IJMSController.checkConsumers(String contextPrefix,
String queueName,
IJMSMessageProcessor<? extends IJMSMessage> messageProcessor)
Return how many batch consumers are running for this message processor
|
void |
IJMSController.runConsumers(String contextPrefix,
String queueName,
IJMSMessageProcessor<? extends IJMSMessage> messageProcessor)
Run batch consumers for this message processor
|
void |
IJMSController.stopConsumers(String contextPrefix,
String queueName,
IJMSMessageProcessor<? extends IJMSMessage> messageProcessor)
Stop all batch consumers for this message processor
|
Copyright © 2021 Visiativ Software. All rights reserved.