listener.java

jsr-180 (SIP) 实现源码。可以在真实手机上使用

package com.micromethod.sipstack.ri;

import java.io.IOException;
import java.util.Hashtable;

import com.micromethod.sipstack.i.SipAddress;
import com.micromethod.sipstack.i.SipHeader;

/**
 * Listener
 */
public class Listener {
  /**
   * m_port
   */
  private int m_port = 0;

  /**
   * m_datagramController
   */
  private DatagramController m_datagramController = null;

  /**
   * m_sipAddress
   */
  private SipAddress m_sipAddress = null;

  /**
   * m_sharedListeners
   */
  private Hashtable m_sharedListeners = null;

  /**
   * m_hasShared
   */
  private boolean m_hasShared = false;

  /**
   * m_txHandler
   */
  private TxHandler m_txHandler = null;

  /**
   * Listener Constructor
   * 
   * @param txHandler
   * @param i
   * @param flag
   * @throws IOException
   */
  public Listener(TxHandler txHandler, int i, boolean flag) throws IOException {
    m_port = 0;
    m_datagramController = null;
    m_sipAddress = null;
    m_sharedListeners = null;
    m_hasShared = false;
    m_txHandler = txHandler;
    m_datagramController = new DatagramController(txHandler, i);
    m_port = m_datagramController.getLocalPort();
    m_sharedListeners = new Hashtable();
    m_hasShared = flag;
  }

  /**
   * getPort
   * 
   * @return port
   */
  public int getPort() {
    return m_port;
  }

  /**
   * getLocalAddress
   * 
   * @return localAddress
   */
  public String getLocalAddress() {
    return m_datagramController.getLocalAddress();
  }

  /**
   * getSipAddress
   * 
   * @return sipAddress
   */
  public SipAddress getSipAddress() {
    return m_sipAddress;
  }

  /**
   * setSipAddress
   * 
   * @param sipAddress
   */
  public void setSipAddress(SipAddress sipAddress) {
    m_sipAddress = sipAddress;
  }

  /**
   * getDatagramController
   * 
   * @return datagramController
   */
  public DatagramController getDatagramController() {
    return m_datagramController;
  }

  /**
   * addNotifier
   * 
   * @param sipConnectionNotifier
   * @return result
   */
  public synchronized boolean addNotifier(Notifier sipConnectionNotifier) {
    if (!m_hasShared) {
      String s = sipConnectionNotifier.getScheme();
      if (s == null)
        s = "";
      if (m_sharedListeners.isEmpty()) {
        m_sharedListeners.put(((Object) (s)),
            ((Object) (sipConnectionNotifier)));
        return true;
      }
      else {
        return false;
      }
    }
    String s1 = sipConnectionNotifier.getScheme();
    if (m_sharedListeners.containsKey(((Object) (s1)))) {
      return false;
    }
    else {
      m_sharedListeners
          .put(((Object) (s1)), ((Object) (sipConnectionNotifier)));
      return true;
    }
  }

  /**
   * removeNotifier
   * 
   * @param sipConnectionNotifier
   */
  public synchronized void removeNotifier(Notifier sipConnectionNotifier) {
    String s = sipConnectionNotifier.getScheme();
    if (!m_hasShared) {
      Protocol.echo("ListeningPoint.removeNotifier: port " + m_port);
      m_datagramController.close();
      m_datagramController = null;
      m_txHandler.removeListener(m_port);
    }
    else {
      Protocol.echo("ListeningPoint.removeNotifier: shared " + s);
      m_sharedListeners.remove(((Object) (s)));
    }
  }

  /**
   * getNotifier
   * 
   * @param sipMessage
   * @return SipConnectionNotifier
   */
  public synchronized Notifier getNotifier(SipMessage sipMessage) {
    String s = sipMessage.getHeaderValue("Accept-Contact");
    SipHeader sipheader = null;
    String s1 = null;
    if (s != null) {
      sipheader = new SipHeader("Accept-Contact", s);
      if (sipheader != null)
        s1 = sipheader.getParameter("type");
    }
    if (s1 != null)
      Protocol.echo("ListeningPoint.getNotifierFor:\n\t\t" + sipheader
          + "\n\t\tsearch key = " + s1);
    else
      Protocol.echo("ListeningPoint.getNotifierFor port: " + m_port);
    if (!m_hasShared) {
      if (m_sharedListeners.containsKey(""))
        return (Notifier) m_sharedListeners.get("");
      if (s1 == null)
        return null;
      else
        return (Notifier) m_sharedListeners.get(((Object) (s1)));
    }
    if (s1 == null) {
      return null;
    }
    else {
      Notifier m1 = (Notifier) m_sharedListeners.get(((Object) (s1)));
      return m1;
    }
  }

  /**
   * hasNotifier
   * 
   * @return hasNotifier
   */
  public boolean hasNotifier() {
    return m_hasShared;
  }
}