File tree Expand file tree Collapse file tree 3 files changed +5
-7
lines changed
jakartalib/src/main/java/com/redhat/mqe/lib
jmslib/src/main/java/com/redhat/mqe/lib Expand file tree Collapse file tree 3 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -155,7 +155,7 @@ private void unsubscribe() {
155
155
try {
156
156
session .unsubscribe (durableSubscriberName );
157
157
} catch (JMSException e ) {
158
- LOG .error ("Error while unsubscribing durable subscriptor " + durableSubscriberName );
158
+ LOG .error ("Error while unsubscribing durable subscriber " + durableSubscriberName );
159
159
e .printStackTrace ();
160
160
} finally {
161
161
close (session );
Original file line number Diff line number Diff line change @@ -171,7 +171,7 @@ public void startClient() {
171
171
doTransaction (session , senderOptions .getOption (ClientOptions .TX_ENDLOOP_ACTION ).getValue ());
172
172
}
173
173
} catch (JMSException | IllegalArgumentException jmse ) {
174
- LOG .error ("Error while sending a message!" , jmse .getMessage ());
174
+ LOG .error ("Error while sending a message! {} " , jmse .getMessage ());
175
175
jmse .printStackTrace ();
176
176
System .exit (1 );
177
177
} finally {
@@ -191,8 +191,7 @@ public void startClient() {
191
191
protected static void setMessageProducer (ClientOptions senderOptions , MessageProducer producer ) {
192
192
try {
193
193
// 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 ())
196
195
? DeliveryMode .PERSISTENT : DeliveryMode .NON_PERSISTENT ;
197
196
producer .setDeliveryMode (deliveryMode );
198
197
// set time to live of message if provided
Original file line number Diff line number Diff line change @@ -171,7 +171,7 @@ public void startClient() {
171
171
doTransaction (session , senderOptions .getOption (ClientOptions .TX_ENDLOOP_ACTION ).getValue ());
172
172
}
173
173
} catch (JMSException | IllegalArgumentException jmse ) {
174
- LOG .error ("Error while sending a message!" , jmse .getMessage ());
174
+ LOG .error ("Error while sending a message! {} " , jmse .getMessage ());
175
175
jmse .printStackTrace ();
176
176
System .exit (1 );
177
177
} finally {
@@ -191,8 +191,7 @@ public void startClient() {
191
191
protected static void setMessageProducer (ClientOptions senderOptions , MessageProducer producer ) {
192
192
try {
193
193
// 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 ())
196
195
? DeliveryMode .PERSISTENT : DeliveryMode .NON_PERSISTENT ;
197
196
producer .setDeliveryMode (deliveryMode );
198
197
// set time to live of message if provided
You can’t perform that action at this time.
0 commit comments