Skip to content

Commit b280c59

Browse files
committed
Assorted jmslib and jakartalib fixups
1 parent f3b1cf2 commit b280c59

File tree

3 files changed

+5
-7
lines changed

3 files changed

+5
-7
lines changed

jakartalib/src/main/java/com/redhat/mqe/lib/ReceiverClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ private void unsubscribe() {
155155
try {
156156
session.unsubscribe(durableSubscriberName);
157157
} catch (JMSException e) {
158-
LOG.error("Error while unsubscribing durable subscriptor " + durableSubscriberName);
158+
LOG.error("Error while unsubscribing durable subscriber " + durableSubscriberName);
159159
e.printStackTrace();
160160
} finally {
161161
close(session);

jakartalib/src/main/java/com/redhat/mqe/lib/SenderClient.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ public void startClient() {
171171
doTransaction(session, senderOptions.getOption(ClientOptions.TX_ENDLOOP_ACTION).getValue());
172172
}
173173
} catch (JMSException | IllegalArgumentException jmse) {
174-
LOG.error("Error while sending a message!", jmse.getMessage());
174+
LOG.error("Error while sending a message! {}", jmse.getMessage());
175175
jmse.printStackTrace();
176176
System.exit(1);
177177
} finally {
@@ -191,8 +191,7 @@ public void startClient() {
191191
protected static void setMessageProducer(ClientOptions senderOptions, MessageProducer producer) {
192192
try {
193193
// set delivery mode - durable/non-durable
194-
String deliveryModeArg = senderOptions.getOption(ClientOptions.MSG_DURABLE).getValue().toLowerCase();
195-
int deliveryMode = (deliveryModeArg.equals("true") || deliveryModeArg.equals("yes"))
194+
int deliveryMode = Utils.convertOptionToBoolean(senderOptions.getOption(ClientOptions.MSG_DURABLE).getValue())
196195
? DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT;
197196
producer.setDeliveryMode(deliveryMode);
198197
// set time to live of message if provided

jmslib/src/main/java/com/redhat/mqe/lib/SenderClient.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ public void startClient() {
171171
doTransaction(session, senderOptions.getOption(ClientOptions.TX_ENDLOOP_ACTION).getValue());
172172
}
173173
} catch (JMSException | IllegalArgumentException jmse) {
174-
LOG.error("Error while sending a message!", jmse.getMessage());
174+
LOG.error("Error while sending a message! {}", jmse.getMessage());
175175
jmse.printStackTrace();
176176
System.exit(1);
177177
} finally {
@@ -191,8 +191,7 @@ public void startClient() {
191191
protected static void setMessageProducer(ClientOptions senderOptions, MessageProducer producer) {
192192
try {
193193
// set delivery mode - durable/non-durable
194-
String deliveryModeArg = senderOptions.getOption(ClientOptions.MSG_DURABLE).getValue().toLowerCase();
195-
int deliveryMode = (deliveryModeArg.equals("true") || deliveryModeArg.equals("yes"))
194+
int deliveryMode = Utils.convertOptionToBoolean(senderOptions.getOption(ClientOptions.MSG_DURABLE).getValue())
196195
? DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT;
197196
producer.setDeliveryMode(deliveryMode);
198197
// set time to live of message if provided

0 commit comments

Comments
 (0)