Skip to content

Commit 086d29a

Browse files
committed
Reformat code
1 parent 4024cfe commit 086d29a

File tree

1 file changed

+23
-23
lines changed

1 file changed

+23
-23
lines changed

gxqueue/src/main/java/com/genexus/messaging/queue/SimpleMessageQueue.java

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -106,39 +106,39 @@ public GXBaseCollection<SdtMessage> getMessages(SdtMessageOptions receiveOptions
106106
receivedMessagesResult.add(Convert.toSdtMessage(m));
107107
}
108108
success[0] = true;
109-
} catch (Exception ex) {
110-
queueErrorMessagesSetup(ex, errorMessages);
111-
logger.error(String.format("Could not get Messages from Queue"), ex);
112-
}
113-
return receivedMessagesResult;
109+
} catch (Exception ex) {
110+
queueErrorMessagesSetup(ex, errorMessages);
111+
logger.error(String.format("Could not get Messages from Queue"), ex);
112+
}
113+
return receivedMessagesResult;
114114
}
115115

116-
public SdtMessageResult deleteMessage(String messageHandleId, GXBaseCollection<SdtMessages_Message>[] errorMessagesArr, boolean[] success) {
117-
GXBaseCollection<SdtMessages_Message> errorMessages = errorMessagesArr[0];
118-
errorMessages.clear();
119-
SdtMessageResult sdtDelete = new SdtMessageResult();
120-
try {
121-
validQueue();
122-
DeleteMessageResult deletedMessage = queue.deleteMessage(messageHandleId);
123-
sdtDelete.setgxTv_SdtMessageResult_Messageid(deletedMessage.getMessageId());
124-
sdtDelete.setgxTv_SdtMessageResult_Servermessageid(deletedMessage.getMessageServerId());
125-
sdtDelete.setgxTv_SdtMessageResult_Messagestatus(deletedMessage.getMessageDeleteStatus());
126-
success[0] = true;
127-
} catch (Exception ex) {
128-
queueErrorMessagesSetup(ex, errorMessages);
129-
logger.error(String.format("Could not delete Message '%s' from Queue ", messageHandleId), ex);
130-
}
131-
return sdtDelete;
116+
public SdtMessageResult deleteMessage(String messageHandleId, GXBaseCollection<SdtMessages_Message>[] errorMessagesArr, boolean[] success) {
117+
GXBaseCollection<SdtMessages_Message> errorMessages = errorMessagesArr[0];
118+
errorMessages.clear();
119+
SdtMessageResult sdtDelete = new SdtMessageResult();
120+
try {
121+
validQueue();
122+
DeleteMessageResult deletedMessage = queue.deleteMessage(messageHandleId);
123+
sdtDelete.setgxTv_SdtMessageResult_Messageid(deletedMessage.getMessageId());
124+
sdtDelete.setgxTv_SdtMessageResult_Servermessageid(deletedMessage.getMessageServerId());
125+
sdtDelete.setgxTv_SdtMessageResult_Messagestatus(deletedMessage.getMessageDeleteStatus());
126+
success[0] = true;
127+
} catch (Exception ex) {
128+
queueErrorMessagesSetup(ex, errorMessages);
129+
logger.error(String.format("Could not delete Message '%s' from Queue ", messageHandleId), ex);
130+
}
131+
return sdtDelete;
132132
}
133133

134-
public GXBaseCollection<SdtMessageResult> deleteMessages(GXSimpleCollection<String> msgHandlesToDelete, GXBaseCollection<SdtMessages_Message>[] errorMessagesArr, boolean[] success) {
134+
public GXBaseCollection<SdtMessageResult> deleteMessages(GXSimpleCollection<String> msgHandlesToDelete, GXBaseCollection<SdtMessages_Message>[] errorMessagesArr, boolean[] success) {
135135
GXBaseCollection<SdtMessages_Message> errorMessages = errorMessagesArr[0];
136136
errorMessages.clear();
137137

138138
try {
139139
validQueue();
140140
List<String> handles = new ArrayList<>();
141-
for (String hnd:msgHandlesToDelete) {
141+
for (String hnd : msgHandlesToDelete) {
142142
handles.add(hnd);
143143
}
144144
List<DeleteMessageResult> deletedMessage = queue.deleteMessages(handles);

0 commit comments

Comments
 (0)