import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Override
public void processRequest(SmppConnectionHandler handler, SMPPPacket request) throws IOException {
    log.info("User " + handler.getUser().getName() + " unbinding from server");
    UnbindResp unbindResp = new UnbindResp(convertRequest(request));
    handler.sendResponse(unbindResp);
    getSmppConnectionPool().close(handler);
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Test
public void testUnbind_Ok() throws Exception {
    Unbind ubd = new Unbind();
    Connection source = mock(Connection.class);
    smppEventListener.unbind(source, ubd);
    verify(source, times(1)).unbind(any(UnbindResp.class));
    verify(smsSendersManager, times(1)).closeSender(same(channel));
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Test
public void testUnbind_SMPPRuntimeException() throws Exception {
    Unbind ubd = new Unbind();
    Connection source = mock(Connection.class);
    doThrow(new SMPPRuntimeException()).when(source).unbind(any(UnbindResp.class));
    smppEventListener.unbind(source, ubd);
    verify(source, times(1)).unbind(any(UnbindResp.class));
    verify(smsSendersManager, times(1)).closeSender(same(channel));
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Test
public void testUnbind_IOException() throws Exception {
    Unbind ubd = new Unbind();
    Connection source = mock(Connection.class);
    doThrow(new IOException()).when(source).unbind(any(UnbindResp.class));
    smppEventListener.unbind(source, ubd);
    verify(source, times(1)).unbind(any(UnbindResp.class));
    verify(smsSendersManager, times(1)).closeSender(same(channel));
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Test
public void testUnbind_SMPPException() throws Exception {
    Unbind ubd = new Unbind();
    Connection source = mock(Connection.class);
    doThrow(new SMPPException()).when(source).unbind(any(UnbindResp.class));
    smppEventListener.unbind(source, ubd);
    verify(source, times(1)).unbind(any(UnbindResp.class));
    verify(smsSendersManager, times(1)).closeSender(same(channel));
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Test
public void testToString_SMPPResponse() {
    UnbindResp ur = new UnbindResp();
    ur.setMessageId("000100");
    ur.setMessageStatus(3);
    ur.setFinalDate(new GregorianCalendar(2012, 4, 5).getTime());
    String result = SmppPacketUtils.toString(ur);
    assertEquals("unbind_resp[MessageId: 000100; MessageStatus: 3; FinalDate: 5/5/12 0:0:0]", result);
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Override
public void unbindResponse(Connection source, UnbindResp ubr) {
    log.debug("UnbindResponse has been received:\n" + SmppPacketUtils.toString(ubr));
    smsSendersManager.closeSender(channel);
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
@Test
public void testUnbindResponse() {
    smppEventListener.unbindResponse(null, new UnbindResp());
    verify(smsSendersManager, times(1)).closeSender(same(channel));
}
 

import ie.omk.smpp.message.UnbindResp; //导入依赖的package包/类
public void packetReceived(Connection myConnection, SMPPPacket pak) {
    switch (pak.getCommandId()) {

    // Bind transmitter response. Check it's status for success...
    case SMPPPacket.BIND_RECEIVER_RESP:
        if (pak.getCommandStatus() != 0) {
            System.out.println("Error binding to the SMSC. Error = "
                    + pak.getCommandStatus());
        } else {
            this.start = System.currentTimeMillis();
            System.out.println("Successfully bound. Waiting for message"
                    + " delivery..");
            System.out.println("(Each dot printed is 500 deliver_sm's!)");
        }
        break;

    // Submit message response...
    case SMPPPacket.DELIVER_SM:
        if (pak.getCommandStatus() != 0) {
            System.out.println("Deliver SM with an error! "
                    + pak.getCommandStatus());

        } else {
            ++msgCount;
            if (showMsgs) {
                System.out.println(Integer.toString(pak.getSequenceNum())
                        + ": \"" + ((DeliverSM) pak).getMessageText()
                        + "\"");
            } else if ((msgCount % 500) == 0) {
                System.out.print("."); // Give some feedback
            }
        }
        break;

    // Unbind request received from server..
    case SMPPPacket.UNBIND:
        this.end = System.currentTimeMillis();
        System.out.println("\nSMSC has requested unbind! Responding..");
        try {
            UnbindResp ubr = new UnbindResp((Unbind) pak);
            myConnection.sendResponse(ubr);
        } catch (IOException x) {
            x.printStackTrace(System.err);
        } finally {
            endReport();
        }
        break;

    // Unbind response..
    case SMPPPacket.UNBIND_RESP:
        this.end = System.currentTimeMillis();
        System.out.println("\nUnbound.");
        endReport();
        break;

    default:
        System.out.println("\nUnexpected packet received! Id = "
                + Integer.toHexString(pak.getCommandId()));
    }
}