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 @@ -165,7 +165,7 @@ public void startClient() {
165
165
doTransaction (session , senderOptions .getOption (ClientOptions .TX_ENDLOOP_ACTION ).getValue ());
166
166
}
167
167
} catch (JMSException | IllegalArgumentException jmse ) {
168
- LOG .error ("Error while sending a message!" , jmse .getMessage ());
168
+ LOG .error ("Error while sending a message! {} " , jmse .getMessage ());
169
169
jmse .printStackTrace ();
170
170
System .exit (1 );
171
171
} finally {
@@ -185,8 +185,7 @@ public void startClient() {
185
185
protected static void setMessageProducer (ClientOptions senderOptions , MessageProducer producer ) {
186
186
try {
187
187
// set delivery mode - durable/non-durable
188
- String deliveryModeArg = senderOptions .getOption (ClientOptions .MSG_DURABLE ).getValue ().toLowerCase ();
189
- int deliveryMode = (deliveryModeArg .equals ("true" ) || deliveryModeArg .equals ("yes" ))
188
+ int deliveryMode = Utils .convertOptionToBoolean (senderOptions .getOption (ClientOptions .MSG_DURABLE ).getValue ())
190
189
? DeliveryMode .PERSISTENT : DeliveryMode .NON_PERSISTENT ;
191
190
producer .setDeliveryMode (deliveryMode );
192
191
// set time to live of message if provided
Original file line number Diff line number Diff line change @@ -165,7 +165,7 @@ public void startClient() {
165
165
doTransaction (session , senderOptions .getOption (ClientOptions .TX_ENDLOOP_ACTION ).getValue ());
166
166
}
167
167
} catch (JMSException | IllegalArgumentException jmse ) {
168
- LOG .error ("Error while sending a message!" , jmse .getMessage ());
168
+ LOG .error ("Error while sending a message! {} " , jmse .getMessage ());
169
169
jmse .printStackTrace ();
170
170
System .exit (1 );
171
171
} finally {
@@ -185,8 +185,7 @@ public void startClient() {
185
185
protected static void setMessageProducer (ClientOptions senderOptions , MessageProducer producer ) {
186
186
try {
187
187
// set delivery mode - durable/non-durable
188
- String deliveryModeArg = senderOptions .getOption (ClientOptions .MSG_DURABLE ).getValue ().toLowerCase ();
189
- int deliveryMode = (deliveryModeArg .equals ("true" ) || deliveryModeArg .equals ("yes" ))
188
+ int deliveryMode = Utils .convertOptionToBoolean (senderOptions .getOption (ClientOptions .MSG_DURABLE ).getValue ())
190
189
? DeliveryMode .PERSISTENT : DeliveryMode .NON_PERSISTENT ;
191
190
producer .setDeliveryMode (deliveryMode );
192
191
// set time to live of message if provided
You can’t perform that action at this time.
0 commit comments