Skip to content

Commit

Permalink
Fixed broker port and broker start timeout types
Browse files Browse the repository at this point in the history
- when I was running tests I have noticed this in logs; values were ignored
- verified on OpenMQ classes, so now it should be compatible with 6.3.0

Signed-off-by: David Matějček <david.matejcek@omnifish.ee>
  • Loading branch information
dmatej committed Nov 14, 2022
1 parent 8d84234 commit b326bec
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -892,7 +892,7 @@ private void setLifecycleProperties() throws Exception, ConnectorRuntimeExceptio
setProperty(cd, envProp2);
ConnectorConfigProperty envProp3 = new ConnectorConfigProperty (
BROKERPORT , brokerPort ,
"Broker Port", "java.lang.String");
"Broker Port", "java.lang.Integer");
setProperty(cd, envProp3);
ConnectorConfigProperty envProp4 = new ConnectorConfigProperty (
BROKERARGS , brokerArgs ,
Expand All @@ -916,7 +916,7 @@ private void setLifecycleProperties() throws Exception, ConnectorRuntimeExceptio
setProperty(cd, envProp7);
ConnectorConfigProperty envProp8 = new ConnectorConfigProperty (
BROKERSTARTTIMEOUT , "" + brokerTimeOut ,
"Broker Start Timeout", "java.lang.String");
"Broker Start Timeout", "java.lang.Integer");
setProperty(cd, envProp8);
ConnectorConfigProperty envProp9 = new ConnectorConfigProperty (
ADMINUSERNAME , adminUserName,
Expand Down

0 comments on commit b326bec

Please sign in to comment.