Package org.sensorhub.api.comm

Interface IMessageQueuePush<T extends MessageQueueConfig>

All Superinterfaces:

IModuleBase<T>, ISubModule<T>

public interface IMessageQueuePush<T extends MessageQueueConfig>
extends ISubModule<T>

Common interface to publish and receive messages from various message queue implementations

Since:

Nov 29, 2017

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	IMessageQueuePush.MessageListener

Method Summary

Modifier and Type	Method	Description
void	publish(byte[] payload)
void	publish(Map<String,String> attrs, byte[] payload)
void	registerListener(IMessageQueuePush.MessageListener listener)
void	unregisterListener(IMessageQueuePush.MessageListener listener)

Methods inherited from interface org.sensorhub.api.module.IModuleBase

getConfiguration, getName, init, start, stop

Methods inherited from interface org.sensorhub.api.module.ISubModule

getParentModule, setParentModule

Method Details

publish

void publish(byte[] payload)

publish

void publish(Map<String,String> attrs,
 byte[] payload)

registerListener

void registerListener(IMessageQueuePush.MessageListener listener)

unregisterListener

void unregisterListener(IMessageQueuePush.MessageListener listener)