com.hp.ov.sdk.messaging.msmb.services

Class MsmbConnectionManager

java.lang.Object

com.hp.ov.sdk.messaging.msmb.services.MsmbConnectionManager

public class MsmbConnectionManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
ConcurrentMap<String,ExecutorService>	executorMap
ConcurrentMap<String,MsmbConnection>	map
ConcurrentMap<String,Thread>	msmbProcessThreadQueue

Constructor Summary

Constructors

Constructor and Description
MsmbConnectionManager(MessagingCertificateManager messagingCertificate)

Method Summary

Modifier and Type	Method and Description
Thread	createMsmbProcessThread(RestParams params, com.rabbitmq.client.Connection conn, com.rabbitmq.client.Channel channel, String routingKey, MsmbMessageExecutionQueue messageQueue)
ExecutorService	getExecutor(String key)
void	processConsumer(RestParams params, String routingKey, MsmbMessageExecutionQueue messageQueue)
void	removeMsmbConnection(RestParams params)
void	startMsmb(RestParams params)
void	stopMsmb(RestParams params)

Methods inherited from class java.lang.Object

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

Field Detail

map

public final ConcurrentMap<String,MsmbConnection> map

executorMap

public final ConcurrentMap<String,ExecutorService> executorMap

msmbProcessThreadQueue

public final ConcurrentMap<String,Thread> msmbProcessThreadQueue

Constructor Detail

MsmbConnectionManager

public MsmbConnectionManager(MessagingCertificateManager messagingCertificate)

Method Detail

startMsmb

public void startMsmb(RestParams params)

getExecutor

public ExecutorService getExecutor(String key)

createMsmbProcessThread

public Thread createMsmbProcessThread(RestParams params,
                                      com.rabbitmq.client.Connection conn,
                                      com.rabbitmq.client.Channel channel,
                                      String routingKey,
                                      MsmbMessageExecutionQueue messageQueue)

stopMsmb

public void stopMsmb(RestParams params)

removeMsmbConnection

public void removeMsmbConnection(RestParams params)
                          throws SDKInvalidArgumentException,
                                 SDKScmbConnectionNotFoundException

Throws:

SDKInvalidArgumentException

SDKScmbConnectionNotFoundException

processConsumer

public void processConsumer(RestParams params,
                            String routingKey,
                            MsmbMessageExecutionQueue messageQueue)