manualackexample.java

控制手机发送短信程序

package sms;

import java.io.File;
import java.io.IOException;

import com.objectxp.msg.Cimd2SmsService;
import com.objectxp.msg.ManualAck;
import com.objectxp.msg.Message;
import com.objectxp.msg.MessageEvent;
import com.objectxp.msg.MessageEventListener;
import com.objectxp.msg.MessageException;
import com.objectxp.msg.SmsService;

/**
 * This example demonstrates how to use the ManualAck interface.
 */
public class ManualAckExample implements MessageEventListener
{
  private SmsService service;

  public ManualAckExample(SmsService service)
  {
    this.service=service;
  }

  public static void main(String[] args) throws IOException, MessageException
  {
    if(args.length != 1 ) {
      System.err.println("Usage: ManualAckExample <config-file>");
      System.exit(1);
    }

    File configuration = new File(args[0]);
    Cimd2SmsService service = new Cimd2SmsService();
    ManualAckExample mack = new ManualAckExample(service); // Used as Event Listener

    try {
      service.init(configuration);
      service.addMessageEventListener(mack);
      service.enableManualAck();
      service.connect();
      service.startReceiving();
      System.out.print("Hit any key to stop receiving");
      System.in.read();
      service.stopReceiving();
      service.disconnect();
    } finally {
      service.destroy();
    }
  }

  public void handleMessageEvent(MessageEvent evt)
  {
    if( evt.getType() == MessageEvent.MESSAGE_RECEIVED ) {
      Message msg = evt.getMessage();

      // Process the message here
      System.out.println("Message received: "+msg);

      // Acknowledge message?
      if( service instanceof ManualAck ) {
        ManualAck m = (ManualAck) service;
        if( m.isManualAckEnabled() ) {
          try {
            m.acknowledge(msg);
          } catch (Exception unknown) {
            System.err.println("ACK failed.");
            unknown.printStackTrace(System.err);
          }
        }
      }
    }
  }
}