Package com.codeheadsystems.queue.impl

Class QueueRegister

java.lang.Object

com.codeheadsystems.queue.impl.QueueRegister

@Singleton
public class QueueRegister
extends Object

The type Queue register.

Constructor Summary

Constructors

Constructor	Description
QueueRegister(Map<String,MessageConsumer> map)	Instantiates a new Queue register.

Method Summary

Modifier and Type	Method	Description
void	deregister(String messageType)	Deregister.
void	deregisterAll()	Deregister all.
Optional<MessageConsumer>	getConsumer(String messageType)	Gets consumer.
List<String>	getRegisteredMessageTypes()	Gets registered message types.
void	register(String messageType, MessageConsumer consumer)	Register.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueueRegister

@Inject
public QueueRegister(Map<String,MessageConsumer> map)

Instantiates a new Queue register.

Parameters:

map - the map

Method Details

register

public void register(String messageType,
 MessageConsumer consumer)

Register.

Parameters:

messageType - the message type

consumer - the consumer

deregister

public void deregister(String messageType)

Deregister.

Parameters:

messageType - the message type

getConsumer

public Optional<MessageConsumer> getConsumer(String messageType)

Gets consumer.

Parameters:

messageType - the message type

Returns:

the consumer

deregisterAll

public void deregisterAll()

Deregister all.

getRegisteredMessageTypes

public List<String> getRegisteredMessageTypes()

Gets registered message types.

Returns:

the registered message types