File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed
com.ibm.streamsx.messagehub/impl/java/src/com/ibm/streamsx/messagehub/operators Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -88,13 +88,14 @@ protected void loadProperties() throws Exception {
88
88
89
89
@ Override
90
90
protected void loadFromAppConfig () throws Exception {
91
- final KafkaOperatorProperties appCfgProps = MessageHubOperatorUtil .loadMessageHubCredsFromAppConfig (getOperatorContext (), appConfigName );
91
+ final String appCfgName = appConfigName == null ? MessageHubOperatorUtil .DEFAULT_MESSAGE_HUB_APP_CONFIG_NAME : appConfigName ;
92
+ final KafkaOperatorProperties appCfgProps = MessageHubOperatorUtil .loadMessageHubCredsFromAppConfig (getOperatorContext (), appCfgName );
92
93
if (appConfigRequired && (appCfgProps == null || appCfgProps .isEmpty ())) {
93
94
final String msg = "Message Hub credentials not found in properties file nor in an Application Configuration" ;
94
95
logger .error (msg );
95
96
throw new RuntimeException (msg );
96
97
}
97
- logger .info ("kafka properties derived from App Config " + appConfigName + " ("
98
+ logger .info ("kafka properties derived from App Config " + appCfgName + " ("
98
99
+ MessageHubOperatorUtil .DEFAULT_MESSAGE_HUB_CREDS_PROPERTY_NAME + "): "
99
100
+ appCfgProps .keySet ());
100
101
Original file line number Diff line number Diff line change @@ -59,13 +59,14 @@ protected void loadProperties() throws Exception {
59
59
60
60
@ Override
61
61
protected void loadFromAppConfig () throws Exception {
62
- final KafkaOperatorProperties appCfgProps = MessageHubOperatorUtil .loadMessageHubCredsFromAppConfig (getOperatorContext (), appConfigName );
62
+ final String appCfgName = appConfigName == null ? MessageHubOperatorUtil .DEFAULT_MESSAGE_HUB_APP_CONFIG_NAME : appConfigName ;
63
+ final KafkaOperatorProperties appCfgProps = MessageHubOperatorUtil .loadMessageHubCredsFromAppConfig (getOperatorContext (), appCfgName );
63
64
if (appConfigRequired && (appCfgProps == null || appCfgProps .isEmpty ())) {
64
65
final String msg = "Message Hub credentials not found in properties file nor in an Application Configuration" ;
65
66
logger .error (msg );
66
67
throw new RuntimeException (msg );
67
68
}
68
- logger .info ("kafka properties derived from App Config " + appConfigName + " ("
69
+ logger .info ("kafka properties derived from App Config " + appCfgName + " ("
69
70
+ MessageHubOperatorUtil .DEFAULT_MESSAGE_HUB_CREDS_PROPERTY_NAME + "): "
70
71
+ appCfgProps .keySet ());
71
72
// When we are here, we might have read the properties derived from a JSON credentials file. In this case 'appConfigRequired' is false.
You can’t perform that action at this time.
0 commit comments