com.hp.ov.sdk.messaging.scmb.services

Class ScmbConnectionManager

java.lang.Object

com.hp.ov.sdk.messaging.scmb.services.ScmbConnectionManager

public class ScmbConnectionManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
ConcurrentMap<String,ExecutorService>	executorMap
ConcurrentMap<String,ScmbConnection>	map
ConcurrentMap<String,Thread>	scmbProcessThreadQueue

Constructor Summary

Constructors

Constructor and Description
ScmbConnectionManager(MessagingCertificateManager messagingCertificate)

Method Summary

Modifier and Type	Method and Description
Thread	createScmbProcessThread(RestParams params, com.rabbitmq.client.Connection conn, com.rabbitmq.client.Channel channel, String routingKey, ScmbMessageExecutionQueue messageQueue)
ExecutorService	getExecutor(String key)
void	processConsumer(RestParams params, String routingKey, ScmbMessageExecutionQueue messageQueue)
void	removeScmbConnection(RestParams params)
void	startScmb(RestParams params)
void	stopScmb(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,ScmbConnection> map

executorMap

public final ConcurrentMap<String,ExecutorService> executorMap

scmbProcessThreadQueue

public final ConcurrentMap<String,Thread> scmbProcessThreadQueue

Constructor Detail

ScmbConnectionManager

public ScmbConnectionManager(MessagingCertificateManager messagingCertificate)

Method Detail

startScmb

public void startScmb(RestParams params)

getExecutor

public ExecutorService getExecutor(String key)

createScmbProcessThread

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

stopScmb

public void stopScmb(RestParams params)

removeScmbConnection

public void removeScmbConnection(RestParams params)
                          throws SDKInvalidArgumentException,
                                 SDKScmbConnectionNotFoundException

Throws:

SDKInvalidArgumentException

SDKScmbConnectionNotFoundException

processConsumer

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