Skip to content

Commit

Permalink
Missed exceptions that were thrown here too
Browse files Browse the repository at this point in the history
  • Loading branch information
simmel committed Jun 26, 2013
1 parent b13fc74 commit 566680d
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
3 changes: 2 additions & 1 deletion src/main/com/zeroclue/jmeter/protocol/amqp/AMQPConsumer.java
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package com.zeroclue.jmeter.protocol.amqp;

import java.io.IOException;
import java.security.*;

import org.apache.jmeter.samplers.Entry;
import org.apache.jmeter.samplers.Interruptible;
Expand Down Expand Up @@ -299,7 +300,7 @@ private void trace(String s) {
log.debug(tn + " " + tl + " " + s + " " + th);
}

protected boolean initChannel() throws IOException {
protected boolean initChannel() throws IOException, NoSuchAlgorithmException, KeyManagementException {
boolean ret = super.initChannel();
channel.basicQos(getPrefetchCountAsInt());
return ret;
Expand Down
5 changes: 3 additions & 2 deletions src/main/com/zeroclue/jmeter/protocol/amqp/AMQPPublisher.java
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@

import com.rabbitmq.client.AMQP;
import java.io.IOException;
import java.security.*;

import com.rabbitmq.client.MessageProperties;
import org.apache.jmeter.samplers.Entry;
Expand Down Expand Up @@ -224,11 +225,11 @@ protected AMQP.BasicProperties getProperties() {
return publishProperties;
}

protected boolean initChannel() throws IOException{
protected boolean initChannel() throws IOException, NoSuchAlgorithmException, KeyManagementException {
boolean ret = super.initChannel();
if (getUseTx()) {
channel.txSelect();
}
return ret;
}
}
}

0 comments on commit 566680d

Please sign in to comment.