CloseableHttpClient closeableHttpClient) {\r
\r
this.publisherConfig = publisherConfig;\r
+ final int maxBatchSize = publisherConfig.getMaxBatchSize() > 0 ? publisherConfig.getMaxBatchSize() : 1;\r
this.publisherQueue = dMaaPMRPublisherQueueFactory.create(\r
- publisherConfig.getMaxBatchSize(), publisherConfig.getMaxRecoveryQueueSize());\r
+ maxBatchSize, publisherConfig.getMaxRecoveryQueueSize());\r
this.closeableHttpClient = closeableHttpClient;\r
this.publisherUri = createPublisherURI(publisherConfig);\r
this.publisherCreationTime = new Date();\r
\r
// Determine Policy Functional Roles\r
final TCAPolicy tcaPolicy = processorContext.getTCAPolicy();\r
- final List<String> policyFunctionalRoles = getPolicyEventNamesSupplier(tcaPolicy).get();\r
- final String policyFunctionalRolesString = Joiner.on(",").join(policyFunctionalRoles);\r
+ final List<String> policyEventNames = getPolicyEventNamesSupplier(tcaPolicy).get();\r
+ final String policyEventNamesString = Joiner.on(",").join(policyEventNames);\r
\r
- // If Policy functional Roles contains CEF message Functional Role then continue processing\r
- if (policyFunctionalRoles.contains(cefMessageEventName)) {\r
+ // If Policy event names contains CEF message event names then continue processing\r
+ if (policyEventNames.contains(cefMessageEventName)) {\r
final String finishMessage = String.format(\r
- "Policy Functional Roles and CEF Message Functional match successful." +\r
- "Message Functional Role: %s, Policy Functional Roles: %s",\r
- cefMessageEventName, policyFunctionalRolesString);\r
+ "Policy Event Name and CEF Message Event Name match successful." +\r
+ "Message EventName: %s, Policy Event Names: %s",\r
+ cefMessageEventName, policyEventNamesString);\r
setFinishedProcessingMessage(finishMessage, processorContext);\r
} else {\r
- // If Policy functional Roles does not contain CEF message Functiona Role then terminate processing\r
+ // If Policy event names does not contain CEF message event names then terminate processing\r
final String terminatingMessage = String.format(\r
- "Policy Domain and CEF Message Domain match unsuccessful." +\r
- "Message Functional Role: %s, Policy Functional Roles: %s",\r
- cefMessageEventName, policyFunctionalRolesString);\r
+ "Policy Event name and CEF Message Event name match unsuccessful." +\r
+ "Message EventName: %s, Policy Event Names: %s",\r
+ cefMessageEventName, policyEventNamesString);\r
setTerminatingProcessingMessage(terminatingMessage, processorContext);\r
}\r
\r