public interface IMessageQueuePush
Common interface to publish and receive messages from various message queue implementations
Modifier and Type | Interface and Description |
---|---|
static interface |
IMessageQueuePush.MessageListener |
Modifier and Type | Method and Description |
---|---|
void |
init(MessageQueueConfig config) |
void |
publish(byte[] msg) |
void |
registerListener(IMessageQueuePush.MessageListener listener) |
void |
start() |
void |
stop() |
void |
unregisterListener(IMessageQueuePush.MessageListener listener) |
void init(MessageQueueConfig config)
void publish(byte[] msg)
void registerListener(IMessageQueuePush.MessageListener listener)
void unregisterListener(IMessageQueuePush.MessageListener listener)
void start()
void stop()