Skip to content

Commit 287ff7b

Browse files
A S Adil MohammadA S Adil Mohammad
authored andcommitted
Removing unwanted lines and spaces
Signed-off-by: A S Adil Mohammad <asadilmohammad2020@gmail.com>
1 parent c49b06c commit 287ff7b

File tree

1 file changed

+8
-23
lines changed

1 file changed

+8
-23
lines changed

src/integration/java/com/ibm/eventstreams/connect/mqsink/MQSinkTaskIT.java

Lines changed: 8 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -127,40 +127,25 @@ public void verifyStringMessages() throws JMSException {
127127
assertEquals("world", messagesInMQ.get(1).getBody(String.class));
128128
}
129129

130-
@Test
131-
public void verifyCipherMappingsConfig() throws JMSException {
132-
final MQSinkTask newConnectTask = new MQSinkTask();
133-
134-
// configure a sink task for validating config
130+
@Test
131+
public void verifyMQSslUseIbmCipherMappings() {
135132
final Map<String, String> connectorConfigProps = createDefaultConnectorProperties();
136133
connectorConfigProps.put("mq.message.builder",
137134
DEFAULT_MESSAGE_BUILDER);
135+
connectorConfigProps.put("mq.ssl.use.ibm.cipher.mappings", "true");
138136

139-
connectorConfigProps.put("mq.ssl.use.ibm.cipher.mappings",
140-
"true");
141-
142-
// start the task so that it connects to MQ
137+
final MQSinkTask newConnectTask = new MQSinkTask();
143138
newConnectTask.start(connectorConfigProps);
144139

145140
// Check if the config reflects the change
146-
String cipherMappingProp = System.getProperty("com.ibm.mq.cfg.useIBMCipherMappings");
147-
assertEquals("true", cipherMappingProp);
148-
149-
// stop the task
150-
newConnectTask.stop();
151-
152-
// configure a sink task for validating config for failure case
153-
connectorConfigProps.put("mq.message.builder",
154-
DEFAULT_MESSAGE_BUILDER);
155-
156-
connectorConfigProps.put("mq.ssl.use.ibm.cipher.mappings",
157-
"hello");
158-
141+
assertEquals(System.getProperty("com.ibm.mq.cfg.useIBMCipherMappings"), "true");
142+
159143
// Verify the exception messages
144+
connectorConfigProps.put("mq.ssl.use.ibm.cipher.mappings", "Not a boolean");
160145
final ConfigException exc = assertThrows(ConfigException.class, () -> {
161146
newConnectTask.start(connectorConfigProps);
162147
});
163-
assertEquals("Invalid value hello for configuration mq.ssl.use.ibm.cipher.mappings: Expected value to be either true or false", exc.getMessage());
148+
assertEquals("Invalid value Not a boolean for configuration mq.ssl.use.ibm.cipher.mappings: Expected value to be either true or false", exc.getMessage());
164149
}
165150

166151
@Test

0 commit comments

Comments
 (0)