org.openecomp.sdc.be.components.distribution.engine

Class CambriaHandler

java.lang.Object

org.openecomp.sdc.be.components.distribution.engine.CambriaHandler

public class CambriaHandler
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	PARTITION_KEY

Constructor Summary

Constructors

Constructor and Description
CambriaHandler()

Method Summary

Modifier and Type	Method and Description
void	closeConsumer(com.att.nsa.cambria.client.CambriaConsumer consumer)
com.att.nsa.cambria.client.CambriaConsumer	createConsumer(Collection<String> hostSet, String topicName, String apiKey, String secretKey, String consumerId, String consumerGroup, int timeoutMS) create and retrieve a Cambria Consumer for a specific topic
CambriaErrorResponse	createTopic(Collection<String> hostSet, String apiKey, String secretKey, String topicName, int partitionCount, int replicationCount) create a topic if it does not exists in the topicsList
fj.data.Either<Iterable<String>,CambriaErrorResponse>	fetchFromTopic(com.att.nsa.cambria.client.CambriaConsumer topicConsumer) use the topicConsumer to fetch messages from topic.
CambriaErrorResponse	getApiKey(String server, String apiKey)
fj.data.Either<Set<String>,CambriaErrorResponse>	getTopics(List<String> hostSet) retrieve all topics from U-EB server
CambriaErrorResponse	registerToTopic(Collection<String> hostSet, String topicName, String managerApiKey, String managerSecretKey, String subscriberApiKey, SubscriberTypeEnum subscriberTypeEnum) register a public key (subscriberId) to a given topic as a CONSUMER or PRODUCER
CambriaErrorResponse	sendNotification(String topicName, String uebPublicKey, String uebSecretKey, List<String> uebServers, INotificationData data) Publish notification message to a given queue
CambriaErrorResponse	sendNotificationAndClose(String topicName, String uebPublicKey, String uebSecretKey, List<String> uebServers, INotificationData data, long waitBeforeCloseTimeout)
CambriaErrorResponse	unRegisterFromTopic(Collection<String> hostSet, String topicName, String managerApiKey, String managerSecretKey, String subscriberApiKey, SubscriberTypeEnum subscriberTypeEnum)

Methods inherited from class java.lang.Object

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

Field Detail

PARTITION_KEY

public static String PARTITION_KEY

Constructor Detail

CambriaHandler

public CambriaHandler()

Method Detail

getTopics

public fj.data.Either<Set<String>,CambriaErrorResponse> getTopics(List<String> hostSet)

retrieve all topics from U-EB server

Parameters:

hostSet -

Returns:

createTopic

public CambriaErrorResponse createTopic(Collection<String> hostSet,
                                        String apiKey,
                                        String secretKey,
                                        String topicName,
                                        int partitionCount,
                                        int replicationCount)

create a topic if it does not exists in the topicsList

Parameters:

hostSet - - list of U-EB servers

apiKey -

secretKey -

topicsList - - list of exists topics

topicName - - topic to create

partitionCount -

replicationCount -

Returns:

unRegisterFromTopic

public CambriaErrorResponse unRegisterFromTopic(Collection<String> hostSet,
                                                String topicName,
                                                String managerApiKey,
                                                String managerSecretKey,
                                                String subscriberApiKey,
                                                SubscriberTypeEnum subscriberTypeEnum)

registerToTopic

public CambriaErrorResponse registerToTopic(Collection<String> hostSet,
                                            String topicName,
                                            String managerApiKey,
                                            String managerSecretKey,
                                            String subscriberApiKey,
                                            SubscriberTypeEnum subscriberTypeEnum)

register a public key (subscriberId) to a given topic as a CONSUMER or PRODUCER

Parameters:

hostSet -

topicName -

managerApiKey -

managerSecretKey -

subscriberApiKey -

subscriberTypeEnum -

Returns:

createConsumer

public com.att.nsa.cambria.client.CambriaConsumer createConsumer(Collection<String> hostSet,
                                                                 String topicName,
                                                                 String apiKey,
                                                                 String secretKey,
                                                                 String consumerId,
                                                                 String consumerGroup,
                                                                 int timeoutMS)
                                                          throws Exception

create and retrieve a Cambria Consumer for a specific topic

Parameters:

hostSet -

topicName -

apiKey -

secretKey -

consumerId -

consumerGroup -

timeoutMS -

Returns:

Throws:

Exception

closeConsumer

public void closeConsumer(com.att.nsa.cambria.client.CambriaConsumer consumer)

fetchFromTopic

public fj.data.Either<Iterable<String>,CambriaErrorResponse> fetchFromTopic(com.att.nsa.cambria.client.CambriaConsumer topicConsumer)

use the topicConsumer to fetch messages from topic. in case no messages were fetched, empty ArrayList will be returned (not error)

Parameters:

topicConsumer -

Returns:

sendNotification

public CambriaErrorResponse sendNotification(String topicName,
                                             String uebPublicKey,
                                             String uebSecretKey,
                                             List<String> uebServers,
                                             INotificationData data)

Publish notification message to a given queue

Parameters:

topicName -

uebPublicKey -

uebSecretKey -

uebServers -

data -

Returns:

sendNotificationAndClose

public CambriaErrorResponse sendNotificationAndClose(String topicName,
                                                     String uebPublicKey,
                                                     String uebSecretKey,
                                                     List<String> uebServers,
                                                     INotificationData data,
                                                     long waitBeforeCloseTimeout)

getApiKey

public CambriaErrorResponse getApiKey(String server,
                                      String apiKey)