flex.messaging.log.Logger.debug()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(10.0k)|赞(0)|评价(0)|浏览(221)

本文整理了Java中flex.messaging.log.Logger.debug()方法的一些代码示例，展示了Logger.debug()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Logger.debug()方法的具体详情如下：
包路径：flex.messaging.log.Logger
类名称：Logger
方法名：debug

Logger.debug介绍

[英]Logs out a debug message.
[中]注销调试消息。

代码示例

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

private void reportStatusIfDebug(String message)
{
  String threadName = Thread.currentThread().getName();
  if (Log.isDebug())
    Log.getLogger(FLEX_CLIENT_LOG_CATEGORY).debug("Poll wait thread '" + threadName + "' for FlexClient with id '" + this.id + "' is " + message);
}

代码示例来源：origin: apache/flex-blazeds

private void reportStatusIfDebug(String message)
{
  String threadName = Thread.currentThread().getName();
  if (Log.isDebug())
    Log.getLogger(FLEX_CLIENT_LOG_CATEGORY).debug("Poll wait thread '" + threadName + "' for FlexClient with id '" + this.id + "' is " + message);
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

/**
 * Creates a new message receive thread.
 * Synchronized to uniquely identify each receive thread at construct time safely.
 *
 * @param worker The runnable to assign to the new thread.
 */
public synchronized Thread newThread(Runnable r)
{
  Thread t = new Thread(r);
  t.setName("MessageReceiveThread" + "-" + receiveThreadCount++);
  if (Log.isDebug())
    Log.getLogger(JMSAdapter.LOG_CATEGORY).debug("Created message receive thread: " + t.getName());
  return t;
}

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

/**
 * Creates a new message receive thread.
 * Synchronized to uniquely identify each receive thread at construct time safely.
 *
 * @param r The runnable to assign to the new thread.
 */
public synchronized Thread newThread(Runnable r)
{
  Thread t = new Thread(r);
  t.setName("MessageReceiveThread" + "-" + receiveThreadCount++);
  t.setDaemon(true);
  if (Log.isDebug())
    Log.getLogger(JMSAdapter.LOG_CATEGORY).debug("Created message receive thread: " + t.getName());
  return t;
}

代码示例来源：origin: apache/flex-blazeds

/**
 * Creates a new message receive thread.
 * Synchronized to uniquely identify each receive thread at construct time safely.
 *
 * @param r The runnable to assign to the new thread.
 */
public synchronized Thread newThread(Runnable r)
{
  Thread t = new Thread(r);
  t.setName("MessageReceiveThread" + "-" + receiveThreadCount++);
  t.setDaemon(true);
  if (Log.isDebug())
    Log.getLogger(JMSAdapter.LOG_CATEGORY).debug("Created message receive thread: " + t.getName());
  return t;
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

/**
 * This method is called in response to a ClusterMembershipListener's 
 * notification that an Address has joined the Cluster. 
 */
void addClusterNode(Address address)
{
  // we avoid adding the node until it has channel and endpoint 
  // information which interests us, but we log the fact that the
  // member was discovered
  if (Log.isDebug())
  {
    Log.getLogger(LOG_CATEGORY).debug("Cluster node from address " + address + 
        " joined the cluster for " + clusterId);
  }
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

/**
 * In response to a ClusterMembershipListener's notification that an
 * Address has abandoned the Cluster, remove the node and avoid using
 * its channel and endpoint information in the future.
 */
void removeClusterNode(Address address)
{
  clusterNodes.remove(address);
  sendRemoveNodeListener(address);
  
  if (Log.isDebug())
  {
    Log.getLogger(LOG_CATEGORY).debug("Cluster node from address " + address + 
        " abandoned the cluster for " + clusterId);
  }
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

public void addSubscriber(String flexClientId, Object clientId, String selector, String subtopic)
{
  synchronized (syncLock)
  {
    /*
     * Only process subscriptions for servers whose subscription state we have received
     * We may receive a subscribe/unsubscribe from a peer before we get their
     * subscription state... we ignore these since they will be included in the
     * state we receive later
     */
    if (allSubscriptions.get(clientId) != null)
      super.addSubscriber(clientId, selector, subtopic, null);
    else if (Log.isDebug())
      Log.getLogger(MessageService.LOG_CATEGORY).debug("Ignoring new remote subscription for server: " + clientId + " whose subscription state we have not yet received.  selector: " + selector + " subtopic: " + subtopic);
  }
}

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

public void addSubscriber(String flexClientId, Object clientId, String selector, String subtopic)
{
  synchronized (syncLock)
  {
    /*
     * Only process subscriptions for servers whose subscription state we have received
     * We may receive a subscribe/unsubscribe from a peer before we get their
     * subscription state... we ignore these since they will be included in the
     * state we receive later
     */
    if (allSubscriptions.get(clientId) != null)
      super.addSubscriber(clientId, selector, subtopic, null);
    else if (Log.isDebug())
      Log.getLogger(MessageService.LOG_CATEGORY).debug("Ignoring new remote subscription for server: " + clientId + " whose subscription state we have not yet received.  selector: " + selector + " subtopic: " + subtopic);
  }
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

/**
 * We don't need to do anything here other than log out some info about the session that's shutting down.
 */
protected void internalInvalidate()
{
  if (Log.isDebug())
    Log.getLogger(FLEX_SESSION_LOG_CATEGORY).debug("FlexSession with id '" + getId() + "' for an Http-based client connection has been invalidated.");
}

代码示例来源：origin: apache/flex-blazeds

/**
 * We don't need to do anything here other than log out some info about the session that's shutting down.
 */
protected void internalInvalidate()
{
  if (Log.isDebug())
    Log.getLogger(FLEX_SESSION_LOG_CATEGORY).debug("FlexSession with id '" + getId() + "' for an Http-based client connection has been invalidated.");
}

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

/**
 * We don't need to do anything here other than log out some info about the session that's shutting down.
 */
protected void internalInvalidate()
{
  if (Log.isDebug())
    Log.getLogger(FLEX_SESSION_LOG_CATEGORY).debug("FlexSession with id '" + getId() + "' for an Http-based client connection has been invalidated.");
}

代码示例来源：origin: apache/flex-blazeds

/**
 *
 * Constructs a new FlexClient instance having the specified Id.
 *
 * @param manager The FlexClientManager managing this instance.
 * @param id The Id for this instance.
 */
public FlexClient(FlexClientManager manager, String id)
{
  this.id = id;
  flexClientManager = manager;
  updateLastUse();
  valid = true;
  if (Log.isDebug())
    Log.getLogger(FLEX_CLIENT_LOG_CATEGORY).debug("FlexClient created with id '" + this.id + "'.");
}

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

/**
 *
 * Constructs a new FlexClient instance having the specified Id.
 *
 * @param manager The FlexClientManager managing this instance.
 * @param id The Id for this instance.
 */
public FlexClient(FlexClientManager manager, String id)
{
  this.id = id;
  flexClientManager = manager;
  updateLastUse();
  valid = true;
  if (Log.isDebug())
    Log.getLogger(FLEX_CLIENT_LOG_CATEGORY).debug("FlexClient created with id '" + this.id + "'.");
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

/**
 * @exclude
 * Constructs a new FlexClient instance having the specified Id.
 * 
 * @param manager The FlexClientManager managing this instance.
 * @param id The Id for this instance.
 */
public FlexClient(FlexClientManager manager, String id)
{
  this.id = id;
  flexClientManager = manager;
  updateLastUse();
  valid = true;
  
  if (Log.isDebug())
    Log.getLogger(FLEX_CLIENT_LOG_CATEGORY).debug("FlexClient created with id '" + this.id + "'.");
}

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

/**
   * Utility function to log the maxFrequency being used during subscription.
   *
   * @param maxFrequency The maxFrequency to log.
   */
  void logMaxFrequencyDuringRegistration(int maxFrequency, SubscriptionInfo si)
  {
    if (Log.isDebug())
      Log.getLogger(ThrottleManager.LOG_CATEGORY).debug("Outbound queue throttle manager for FlexClient '"
          + processor.getFlexClient().getId() + "' is using '" + maxFrequency
          + "' as the throttling limit for its subscription: "
          +  StringUtils.NEWLINE + si);
  }
}

代码示例来源：origin: apache/flex-blazeds

/**
   * Utility function to log the maxFrequency being used during subscription.
   *
   * @param maxFrequency The maxFrequency to log.
   */
  void logMaxFrequencyDuringRegistration(int maxFrequency, SubscriptionInfo si)
  {
    if (Log.isDebug())
      Log.getLogger(ThrottleManager.LOG_CATEGORY).debug("Outbound queue throttle manager for FlexClient '"
          + processor.getFlexClient().getId() + "' is using '" + maxFrequency
          + "' as the throttling limit for its subscription: "
          +  StringUtils.NEWLINE + si);
  }
}

代码示例来源：origin: com.adobe.flex/com.springsource.flex.messaging

/**
 * Broadcast this subscribe/unsubscribe message to the cluster so everyone is aware
 * of this server's interest in messages matching this selector and subtopic.
 */
protected void sendSubscriptionToPeer(boolean subscribe, String selector, String subtopic)
{
  if (Log.isDebug())
    Log.getLogger(MessageService.LOG_CATEGORY).debug("Sending subscription to peers for subscribe? " + subscribe + " selector: " + selector + " subtopic: " + subtopic);
  ((MessageService)destination.getService()).sendSubscribeFromPeer(destination.getId(),
                subscribe ? Boolean.TRUE : Boolean.FALSE, selector, subtopic);
}

代码示例来源：origin: org.apache.flex.blazeds/flex-messaging-core

/**
 * Broadcast this subscribe/unsubscribe message to the cluster so everyone is aware
 * of this server's interest in messages matching this selector and subtopic.
 *
 * @param subscribe are we subscribing?
 * @param selector the selector
 * @param subtopic the subtopic
 */
protected void sendSubscriptionToPeer(boolean subscribe, String selector, String subtopic)
{
  if (Log.isDebug())
    Log.getLogger(MessageService.LOG_CATEGORY).debug("Sending subscription to peers for subscribe? " + subscribe + " selector: " + selector + " subtopic: " + subtopic);
  ((MessageService)destination.getService()).sendSubscribeFromPeer(destination.getId(), subscribe, selector, subtopic);
}

代码示例来源：origin: apache/flex-blazeds

/**
 * Broadcast this subscribe/unsubscribe message to the cluster so everyone is aware
 * of this server's interest in messages matching this selector and subtopic.
 *
 * @param subscribe are we subscribing?
 * @param selector the selector
 * @param subtopic the subtopic
 */
protected void sendSubscriptionToPeer(boolean subscribe, String selector, String subtopic)
{
  if (Log.isDebug())
    Log.getLogger(MessageService.LOG_CATEGORY).debug("Sending subscription to peers for subscribe? " + subscribe + " selector: " + selector + " subtopic: " + subtopic);
  ((MessageService)destination.getService()).sendSubscribeFromPeer(destination.getId(), subscribe, selector, subtopic);
}

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com