bamskeleton.java

来自「RESIN 3.2 最新源码」· Java 代码 · 共 562 行 · 第 1/2 页

  public void dispatchMessage(C target, String to, String from,
                              Serializable value)
  {
    Method messageHandler = _messageHandlers.get(value.getClass());

    if (messageHandler == null)
      return;
    
    try {
      messageHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchMessageError(C target, String to, String from,
                                   Serializable value, BamError error)
  {
    Method messageErrorHandler = _messageErrorHandlers.get(value.getClass());

    if (messageErrorHandler == null)
      return;
    
    try {
      messageErrorHandler.invoke(target, to, from, value, error);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public boolean dispatchQueryGet(C target, long id, String to, String from,
                                  Serializable value)
  {
    Method queryHandler = _queryGetHandlers.get(value.getClass());

    if (queryHandler == null)
      return false;
    
    try {
      return (Boolean) queryHandler.invoke(target, id, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
      return false;
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
      return false;
    }
  }

  public boolean dispatchQuerySet(C target, long id, String to, String from,
                                  Serializable value)
  {
    Method queryHandler = _querySetHandlers.get(value.getClass());

    if (queryHandler == null)
      return false;
    
    try {
      return (Boolean) queryHandler.invoke(target, id, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
      return false;
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
      return false;
    }
  }

  public void dispatchQueryResult(C target, long id, String to, String from,
                                  Serializable value)
  {
    Method queryHandler = _queryResultHandlers.get(value.getClass());

    if (queryHandler == null)
      return;
    
    try {
      queryHandler.invoke(target, id, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchQueryError(C target, long id, String to, String from,
                                 Serializable value, BamError error)
  {
    Method queryErrorHandler = _queryErrorHandlers.get(value.getClass());

    if (queryErrorHandler == null)
      return;
    
    try {
      queryErrorHandler.invoke(target, id, to, from, value, error);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresence(C target, String to, String from,
                               Serializable value)
  {
    Method presenceHandler = _presenceHandlers.get(value.getClass());

    if (presenceHandler == null)
      return;
    
    try {
      presenceHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceProbe(C target, String to, String from,
                                    Serializable value)
  {
    Method presenceProbeHandler = _presenceProbeHandlers.get(value.getClass());

    if (presenceProbeHandler == null)
      return;
    
    try {
      presenceProbeHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceSubscribe(C target, String to, String from,
                                    Serializable value)
  {
    Method presenceSubscribeHandler = 
      _presenceSubscribeHandlers.get(value.getClass());

    if (presenceSubscribeHandler == null)
      return;
    
    try {
      presenceSubscribeHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceSubscribed(C target, String to, String from,
                                    Serializable value)
  {
    Method presenceSubscribedHandler = 
      _presenceSubscribedHandlers.get(value.getClass());

    if (presenceSubscribedHandler == null)
      return;
    
    try {
      presenceSubscribedHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceUnsubscribe(C target, String to, String from,
                                    Serializable value)
  {
    Method presenceUnsubscribeHandler = 
      _presenceUnsubscribeHandlers.get(value.getClass());

    if (presenceUnsubscribeHandler == null)
      return;
    
    try {
      presenceUnsubscribeHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceUnsubscribed(C target, String to, String from,
                                    Serializable value)
  {
    Method presenceUnsubscribedHandler = 
      _presenceUnsubscribedHandlers.get(value.getClass());

    if (presenceUnsubscribedHandler == null)
      return;
    
    try {
      presenceUnsubscribedHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceUnavailable(C target, String to, String from,
                                    Serializable value)
  {
    Method presenceUnavailableHandler = 
      _presenceUnavailableHandlers.get(value.getClass());

    if (presenceUnavailableHandler == null)
      return;
    
    try {
      presenceUnavailableHandler.invoke(target, to, from, value);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public void dispatchPresenceError(C target, String to, String from,
                                    Serializable value, BamError error)
  {
    Method presenceErrorHandler = _presenceErrorHandlers.get(value.getClass());

    if (presenceErrorHandler == null)
      return;
    
    try {
      presenceErrorHandler.invoke(target, to, from, value, error);
    }
    catch (IllegalAccessException e) {
      log.log(Level.FINE, e.toString(), e);
    }
    catch (InvocationTargetException e) {
      log.log(Level.FINE, e.toString(), e);
    }
  }

  public String toString()
  {
    return getClass().getSimpleName() + "[" + _cl.getName() + "]";
  }
}