com.communote.plugins.mq.service.impl

Class ProviderMessageConsumerFactoryImpl

java.lang.Object

com.communote.plugins.mq.service.impl.ProviderMessageConsumerFactoryImpl

All Implemented Interfaces:

ProviderMessageConsumerFactory

public class ProviderMessageConsumerFactoryImpl
extends Object
implements ProviderMessageConsumerFactory

Factory of the CNT message consumers. Appropriate message consumer is created, as soon as a message handler component is registered in the OSGi context

Author:

Communote GmbH - http://www.communote.com/

Constructor Summary

Constructors

Constructor and Description
ProviderMessageConsumerFactoryImpl()

Method Summary

Modifier and Type	Method and Description
void	bindMessageHandler(CommunoteMessageHandler<? extends BaseMessage> messageHandler) Is invoked when new message handler is registered in the OSGi context.
Map<CommunoteMessageHandler<?>,org.apache.felix.ipojo.ComponentInstance>	getMessageConsumers() only for test purposes
void	unbindMessageHandler(CommunoteMessageHandler<? extends BaseMessage> messageHandler) Is invoked when a communote message handler is removed from the OSGi context.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProviderMessageConsumerFactoryImpl

public ProviderMessageConsumerFactoryImpl()

Method Detail

bindMessageHandler

public void bindMessageHandler(CommunoteMessageHandler<? extends BaseMessage> messageHandler)

Is invoked when new message handler is registered in the OSGi context. Instantiates appropriate provider message consumer

Specified by:

bindMessageHandler in interface ProviderMessageConsumerFactory

Parameters:

messageHandler - handler instance

getMessageConsumers

public Map<CommunoteMessageHandler<?>,org.apache.felix.ipojo.ComponentInstance> getMessageConsumers()

only for test purposes

Returns:

Handlers.

unbindMessageHandler

public void unbindMessageHandler(CommunoteMessageHandler<? extends BaseMessage> messageHandler)

Is invoked when a communote message handler is removed from the OSGi context. The method is responsible for stopping appropriate provider message consumer instance

Specified by:

unbindMessageHandler in interface ProviderMessageConsumerFactory

Parameters:

messageHandler - message handler, that was removed