Project Detail

Description

need consulation how to do deliver_sm_resp after receive deliver_sm in async mode opensmpp . consultation usd10. below is the listener class


private class SMPPTestPDUEventListener extends SmppObject implements ServerPDUEventListener {
Session session;
Queue requestEvents = new Queue();

public SMPPTestPDUEventListener(Session session) {
this.session = session;
}

public void handleEvent(ServerPDUEvent event) {
PDU pdu = event.getPDU();
if (pdu.isRequest()) {
System.out.println("async request received, enqueuing " + pdu.debugString());

if( pdu instanceof DeliverSM ){



System.out.println("****" + " " + ((DeliverSM) pdu).debugString());



}





synchronized (requestEvents) {
requestEvents.enqueue(event);
requestEvents.notify();
}
} else if (pdu.isResponse()) {
System.out.println("async response received " + pdu.debugString());


if( pdu instanceof SubmitSMResp ){


System.out.println ( ">>>" + ((SubmitSMResp) pdu).getMessageId() +" "+ ((SubmitSMResp) pdu).debugString());


}



} else {
System.out.println(
"pdu of unknown class (not request nor " + "response) received, discarding " + pdu.debugString());
}
}

/**
* Returns received pdu from the queue. If the queue is empty,
* the method blocks for the specified timeout.
*/
public ServerPDUEvent getRequestEvent(long timeout) {
ServerPDUEvent pduEvent = null;
synchronized (requestEvents) {
if (requestEvents.isEmpty()) {
try {
requestEvents.wait(timeout);
} catch (InterruptedException e) {
// ignoring, actually this is what we're waiting for
}
}
if (!requestEvents.isEmpty()) {
pduEvent = (ServerPDUEvent) requestEvents.dequeue();
}
}
return pduEvent;
}
}