summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
6993f46)
Update client library to use the controller type to set the DMaaP
cambria.partition
Change-Id: I7e3206309d99ba599d7d6785e63a76ec7c948896
Signed-off-by: Ryan Young <ry303t@att.com>
Issue-ID: APPC-934
(cherry picked from commit
61f4c8ce5e093db0b63d4030cbd3e6df499854a1)
* ============LICENSE_START=======================================================
* ONAP : APPC
* ================================================================================
* ============LICENSE_START=======================================================
* ONAP : APPC
* ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Copyright (C) 2017 Amdocs
* =============================================================================
* ================================================================================
* Copyright (C) 2017 Amdocs
* =============================================================================
* See the License for the specific language governing permissions and
* limitations under the License.
*
* See the License for the specific language governing permissions and
* limitations under the License.
*
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
* ============LICENSE_END=========================================================
*/
* ============LICENSE_END=========================================================
*/
private static final EELFLogger LOG = EELFManager.getInstance().getLogger(AsyncProtocolImpl.class);
private static final EELFLogger LOG = EELFManager.getInstance().getLogger(AsyncProtocolImpl.class);
+ private String controllerType = null;
throw new ProtocolException("Callback param should not be null!");
}
this.callback = callback;
throw new ProtocolException("Callback param should not be null!");
}
this.callback = callback;
+
+ controllerType = props.getProperty(UEBPropertiesKeys.CONTROLLER_TYPE);
+
+ try {
messageService.init(props);
//get message bus listener thread
//start the thread after initializing services
messageService.init(props);
//get message bus listener thread
//start the thread after initializing services
@Override
public void sendRequest(String payload, MessageContext context) throws ProtocolException {
@Override
public void sendRequest(String payload, MessageContext context) throws ProtocolException {
+ if (controllerType != null && controllerType.length()!= 0 && (!controllerType.equals("APPC")))
+ {
+ context.setPartiton(controllerType);
+ }
+
//get message to be sent to appc from payload and context
String message = messageWriter.write(payload, context);
try {
//get message to be sent to appc from payload and context
String message = messageWriter.write(payload, context);
try {