org.openecomp.policy.drools.event.comm.bus.internal

Class BusPublisher.CambriaPublisherWrapper

java.lang.Object

org.openecomp.policy.drools.event.comm.bus.internal.BusPublisher.CambriaPublisherWrapper

All Implemented Interfaces:

BusPublisher

Enclosing interface:

BusPublisher

public static class BusPublisher.CambriaPublisherWrapper
extends Object
implements BusPublisher

Cambria based library publisher

Nested Class Summary

Nested classes/interfaces inherited from interface org.openecomp.policy.drools.event.comm.bus.internal.BusPublisher

BusPublisher.CambriaPublisherWrapper, BusPublisher.DmaapPublisherWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected com.att.nsa.cambria.client.CambriaBatchingPublisher	publisher The actual Cambria publisher

Constructor Summary

Constructors

Constructor and Description
CambriaPublisherWrapper(List<String> servers, String topic, String apiKey, String apiSecret)

Method Summary

Modifier and Type	Method and Description
void	close() closes the publisher
boolean	send(String partitionId, String message) sends a message
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

publisher

protected volatile com.att.nsa.cambria.client.CambriaBatchingPublisher publisher

The actual Cambria publisher

Constructor Detail

CambriaPublisherWrapper

public CambriaPublisherWrapper(List<String> servers,
                               String topic,
                               String apiKey,
                               String apiSecret)
                        throws IllegalArgumentException

Throws:

IllegalArgumentException

Method Detail

send

public boolean send(String partitionId,
                    String message)
             throws IllegalArgumentException

sends a message

Specified by:

send in interface BusPublisher

message - the message

Returns:

true if success, false otherwise

Throws:

IllegalArgumentException - if no message provided

close

public void close()

closes the publisher

Specified by:

close in interface BusPublisher

toString

public String toString()

Overrides:

toString in class Object