File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
src/main/java/com/ibm/mq/kafkaconnect Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 20
20
import com .ibm .mq .jms .*;
21
21
import com .ibm .mq .kafkaconnect .builders .RecordBuilder ;
22
22
import com .ibm .msg .client .wmq .WMQConstants ;
23
+
23
24
import java .util .Map ;
24
25
import java .util .concurrent .atomic .AtomicBoolean ;
25
26
@@ -134,11 +135,8 @@ public void configure(Map<String, String> props) {
134
135
135
136
/**
136
137
* Connects to MQ.
137
- *
138
- * @throws RetriableException Operation failed, but connector should continue to retry.
139
- * @throws ConnectException Operation failed and connector should stop.
140
138
*/
141
- public void connect () throws ConnectException , RetriableException {
139
+ public void connect () {
142
140
try {
143
141
if (userName != null ) {
144
142
jmsCtxt = mqConnFactory .createContext (userName , password , JMSContext .SESSION_TRANSACTED );
You can’t perform that action at this time.
0 commit comments