syukri/osb-jms-queue-mdb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

merge into: syukri:main
Branches Tags
syukri:main
syukri:devel
...
pull from: syukri:devel
Branches Tags
syukri:main
syukri:devel

1 Commits
main ... devel

Author SHA1 Message Date
syukri-radius
c71a8c6a73 remove some system out 2024-11-04 17:26:42 +07:00
4 changed files with 6 additions and 6 deletions
Show Stats Expand all files Collapse all files

BIN
classes/.data/LogProcessorMdb.cdi
View File

Binary file not shown.

BIN
classes/org/soakemenkeu/MessageDrivenEJBBean.class
View File

Binary file not shown.

BIN
deploy/OsbLogProcessor_LogProcessorMdb_ejb.jar
View File

Binary file not shown.

12
src/org/soakemenkeu/MessageDrivenEJBBean.java
View File

@ -93,13 +93,13 @@ public class MessageDrivenEJBBean implements MessageDrivenBean, MessageListener
postPayload += " </soapenv:Body></soapenv:Envelope>"; postPayload += " </soapenv:Body></soapenv:Envelope>";
System.out.println("[myMessageDrivenBean] Received message: " + msgPayload ); // System.out.println("[myMessageDrivenBean] Received message: " + msgPayload );
System.out.println("[myMessageDrivenBean] postPayload message: " + postPayload ); // System.out.println("[myMessageDrivenBean] postPayload message: " + postPayload );
sendHttpPost(postPayload); sendHttpPost(postPayload);
} catch(JMSException ex) { } catch(JMSException ex) {
System.out.println("Caught JMSException: " + ex ); // System.out.println("Caught JMSException: " + ex );
} }
} }
@ -207,7 +207,7 @@ public class MessageDrivenEJBBean implements MessageDrivenBean, MessageListener
// output.flush(); // output.flush();
int responseCode = conn.getResponseCode(); int responseCode = conn.getResponseCode();
// System.out.println("POST Response Code :: " + responseCode); System.out.println("[logJmsMessageDrivenBean]:POST Response Code :: " + responseCode);
if (responseCode == HttpURLConnection.HTTP_OK) { // success if (responseCode == HttpURLConnection.HTTP_OK) { // success
try (BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()))) { try (BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()))) {
@ -216,10 +216,10 @@ public class MessageDrivenEJBBean implements MessageDrivenBean, MessageListener
while ((inputLine = in.readLine()) != null) { while ((inputLine = in.readLine()) != null) {
response.append(inputLine); response.append(inputLine);
} }
System.out.println("Response :: " + response.toString()); // System.out.println("Response :: " + response.toString());
} }
} else { } else {
System.out.println("POST request failed"); System.out.println("[logJmsMessageDrivenBean]:POST request failed");
} }
conn.disconnect(); conn.disconnect();
} catch (IOException e) { } catch (IOException e) {