{
private final EELFLogger LOG = EELFManager.getInstance().getLogger(EventSender.class);
public static final String PROPERTY_PREFIX = "dmaap.event";
{
private final EELFLogger LOG = EELFManager.getInstance().getLogger(EventSender.class);
public static final String PROPERTY_PREFIX = "dmaap.event";
public boolean sendEvent(MessageDestination destination, EventMessage msg) {
String jsonStr = msg.toJson();
String id = msg.getEventHeader().getEventId();
public boolean sendEvent(MessageDestination destination, EventMessage msg) {
String jsonStr = msg.toJson();
String id = msg.getEventHeader().getEventId();
public boolean sendEvent(MessageDestination destination, EventMessage msg, String eventTopicName) {
String jsonStr = msg.toJson();
String id = msg.getEventHeader().getEventId();
public boolean sendEvent(MessageDestination destination, EventMessage msg, String eventTopicName) {
String jsonStr = msg.toJson();
String id = msg.getEventHeader().getEventId();
return messagingConnector.publishMessage(propertyPrefix, id, eventTopicName, jsonStr);
}
return messagingConnector.publishMessage(propertyPrefix, id, eventTopicName, jsonStr);
}
public boolean sendEvent(MessageDestination destination, Map<String, String> params, SvcLogicContext ctx) throws APPCException {
if (params == null) {
public boolean sendEvent(MessageDestination destination, Map<String, String> params, SvcLogicContext ctx) throws APPCException {
if (params == null) {