org.teiid.logging.LogManager.isMessageToBeRecorded()方法的使用及代码示例

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

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

LogManager.isMessageToBeRecorded介绍

[英]Utility method to identify whether a log message with the specified context and level will be recorded in the LogManager's destinations.
[中]实用程序方法，用于标识具有指定上下文和级别的日志消息是否将记录在LogManager的目标中。

代码示例

代码示例来源：origin: org.teiid/teiid-engine

  1. public AnalysisRecord(boolean recordQueryPlan, boolean recordDebug) {
  2.   this.recordQueryPlan = recordQueryPlan || LogManager.isMessageToBeRecorded(LogConstants.CTX_QUERY_PLANNER, MessageLevel.DETAIL);
  3.   this.recordDebug = recordDebug || LogManager.isMessageToBeRecorded(LogConstants.CTX_QUERY_PLANNER, MessageLevel.TRACE);
  4.   
  5.   if(this.recordQueryPlan) {
  6.     this.annotations = new ArrayList<Annotation>();
  7.   }
  8.   
  9.   if(this.recordDebug) {
  10.     this.stringWriter = new StringWriter();
  11.     this.debugWriter = new PrintWriter(this.stringWriter); 
  12.   }
  13. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. public static BlockedException block(Object... msg) {
  2.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.DETAIL)) {
  3.     LogManager.logDetail(LogConstants.CTX_BUFFER_MGR, msg); 
  4.   }
  5.   return INSTANCE;
  6. }

代码示例来源：origin: teiid/teiid

  1. private static void logMessage(int level, String context, Object msgPart, Object msgPart1) {
  2.   if (msgPart == null || !isMessageToBeRecorded(context, level)) {
  3.     return;
  4.   } 
  5.   logListener.log(level, context, msgPart, msgPart1);
  6. }

代码示例来源：origin: teiid/teiid

  1. private static void logMessage(int level, String context, Object msgPart) {
  2.   if (msgPart == null || !isMessageToBeRecorded(context, level)) {
  3.     return;
  4.   } 
  5.   logListener.log(level, context, msgPart);
  6. }

代码示例来源：origin: teiid/teiid

  1. public static BlockedException block(Object... msg) {
  2.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.DETAIL)) {
  3.     LogManager.logDetail(LogConstants.CTX_BUFFER_MGR, msg); 
  4.   }
  5.   return INSTANCE;
  6. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. private void logRequest(Set<String> resources, Context context) {
  2.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_AUDITLOGGING, MessageLevel.DETAIL)) {
  3.     // Audit - request
  4.     AuditMessage msg = new AuditMessage(context.name(), "getInaccessibleResources-request", resources.toArray(new String[resources.size()]), commandContext); //$NON-NLS-1$
  5.     LogManager.logDetail(LogConstants.CTX_AUDITLOGGING, msg);
  6.   }
  7. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. public ThreadCpuTimer() {
  2.   active = threadMXBean.isThreadCpuTimeSupported() 
  3.       && threadMXBean.isThreadCpuTimeEnabled()
  4.       && LogManager.isMessageToBeRecorded(LogConstants.CTX_COMMANDLOGGING, MessageLevel.DETAIL);
  5. }

代码示例来源：origin: teiid/teiid

  1. private void freeDataBlock(int dataBlock) {
  2.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.TRACE)) {
  3.     LogManager.logTrace(LogConstants.CTX_BUFFER_MGR, "freeing data block", dataBlock, "for", gid, oid); //$NON-NLS-1$ //$NON-NLS-2$
  4.   }
  5.   blocksInuse.clear(dataBlock);
  6. }

代码示例来源：origin: org.teiid.connectors/translator-salesforce

  1. private void logFields(String sObjectName, List<XmlObject> fields) {
  2.   if (!LogManager.isMessageToBeRecorded(LogConstants.CTX_CONNECTOR, MessageLevel.DETAIL)) {
  3.     return;
  4.   }
  5.   LogManager.logDetail(LogConstants.CTX_CONNECTOR, "SalesForce Object Name = " + sObjectName); //$NON-NLS-1$
  6.   LogManager.logDetail(LogConstants.CTX_CONNECTOR, "FieldCount = " + fields.size()); //$NON-NLS-1$
  7.   for(int i = 0; i < fields.size(); i++) {
  8.     XmlObject element = fields.get(i);
  9.     LogManager.logDetail(LogConstants.CTX_CONNECTOR, "Field # " + i + " is " + element.getName().getLocalPart()); //$NON-NLS-1$ //$NON-NLS-2$
  10.   }
  11.   
  12. }

代码示例来源：origin: org.teiid/teiid-runtime

  1. private void writeExceptionCaught(Channel channel,
  2.     Throwable cause) {
  3.   ChannelListener listener = this.listeners.get(channel);
  4.   if (listener != null) {
  5.     listener.exceptionOccurred(cause);
  6.   } else {
  7.     int level = SocketClientInstance.getLevel(cause);
  8.     LogManager.log(level, LogConstants.CTX_TRANSPORT, LogManager.isMessageToBeRecorded(LogConstants.CTX_TRANSPORT, MessageLevel.DETAIL)||level<MessageLevel.WARNING?cause:null, RuntimePlugin.Util.gs(RuntimePlugin.Event.TEIID40114, cause.getMessage()));
  9.     channel.close();
  10.   }
  11. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. public void remove() {
  2.   if (!removed) {
  3.     if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.DETAIL)) {
  4.       LogManager.logDetail(LogConstants.CTX_BUFFER_MGR, "Removing TupleBuffer:", this.tupleSourceID); //$NON-NLS-1$
  5.     }
  6.     this.batchBuffer = null;
  7.     purge();
  8.     this.manager.remove();
  9.     removed = true;
  10.   }
  11. }

代码示例来源：origin: org.teiid/teiid-engine

  1. private TupleBuffer createTupleBuffer() throws TeiidComponentException {
  2.   TupleBuffer tb = bufferManager.createTupleBuffer(this.schema, this.groupName, TupleSourceType.PROCESSOR);
  3.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_DQP, MessageLevel.DETAIL)) {
  4.     LogManager.logDetail(LogConstants.CTX_DQP, "Created intermediate sort buffer", tb); //$NON-NLS-1$
  5.   }
  6.   tb.setForwardOnly(true);
  7.   return tb;
  8. }

代码示例来源：origin: teiid/teiid

  1. public void remove() {
  2.   if (!removed) {
  3.     if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.DETAIL)) {
  4.       LogManager.logDetail(LogConstants.CTX_BUFFER_MGR, "Removing TupleBuffer:", this.tupleSourceID); //$NON-NLS-1$
  5.     }
  6.     this.batchBuffer = null;
  7.     purge();
  8.     this.manager.remove();
  9.     removed = true;
  10.   }
  11. }

代码示例来源：origin: org.teiid/teiid-engine

  1. public void remove() {
  2.   if (!removed) {
  3.     if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.DETAIL)) {
  4.       LogManager.logDetail(LogConstants.CTX_BUFFER_MGR, "Removing TupleBuffer:", this.tupleSourceID); //$NON-NLS-1$
  5.     }
  6.     this.batchBuffer = null;
  7.     purge();
  8.     this.manager.remove();
  9.     removed = true;
  10.   }
  11. }

代码示例来源：origin: teiid/teiid

  1. public void testIsMessageToBeRecordedString() {
  2.   assertTrue(LogManager.isMessageToBeRecorded(CONTEXT, MessageLevel.CRITICAL) ); 
  3.   
  4.   ListLogger cfg = (ListLogger)LogManager.logListener;
  5.   cfg.setLogLevel(CONTEXT, MessageLevel.NONE);
  6.   assertFalse(LogManager.isMessageToBeRecorded(CONTEXT, MessageLevel.CRITICAL) );
  7. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. int getAndSetNextClearBit(PhysicalInfo info) {
  2.   int result = blocksInUse.getAndSetNextClearBit();
  3.   if (result == -1) {
  4.      throw new TeiidRuntimeException(QueryPlugin.Event.TEIID30059, QueryPlugin.Util.gs(QueryPlugin.Event.TEIID30059, blockSize));
  5.   }
  6.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_BUFFER_MGR, MessageLevel.DETAIL)) {
  7.     LogManager.logDetail(LogConstants.CTX_BUFFER_MGR, "Allocating storage data block", result, "of size", blockSize, "to", info); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ 
  8.   }
  9.   return result;
  10. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. public ResultsFuture<ResultsMessage> processCursorRequest(long reqID,
  2.     int batchFirst, int fetchSize) throws TeiidProcessingException {
  3.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_DQP, MessageLevel.DETAIL)) {
  4.     LogManager.logDetail(LogConstants.CTX_DQP, "DQP process cursor request", batchFirst, fetchSize);  //$NON-NLS-1$
  5.   }
  6.   DQPWorkContext workContext = DQPWorkContext.getWorkContext();
  7.   ResultsFuture<ResultsMessage> resultsFuture = new ResultsFuture<ResultsMessage>();
  8.   RequestWorkItem workItem = getRequestWorkItem(workContext.getRequestID(reqID));
  9.   workItem.requestMore(batchFirst, batchFirst + Math.min(fetchSize, this.config.getMaxRowsFetchSize()) - 1, resultsFuture.getResultsReceiver());
  10.   return resultsFuture;
  11. }

代码示例来源：origin: org.teiid/teiid-engine

  1. public ResultsFuture<ResultsMessage> processCursorRequest(long reqID,
  2.     int batchFirst, int fetchSize) throws TeiidProcessingException {
  3.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_DQP, MessageLevel.DETAIL)) {
  4.     LogManager.logDetail(LogConstants.CTX_DQP, "DQP process cursor request", batchFirst, fetchSize);  //$NON-NLS-1$
  5.   }
  6.   DQPWorkContext workContext = DQPWorkContext.getWorkContext();
  7.   ResultsFuture<ResultsMessage> resultsFuture = new ResultsFuture<ResultsMessage>();
  8.   RequestWorkItem workItem = getRequestWorkItem(workContext.getRequestID(reqID));
  9.   workItem.requestMore(batchFirst, batchFirst + Math.min(fetchSize, this.config.getMaxRowsFetchSize()) - 1, resultsFuture.getResultsReceiver());
  10.   return resultsFuture;
  11. }

代码示例来源：origin: org.jboss.teiid/teiid-engine

  1. public ResultsFuture<LobChunk> requestNextLobChunk(int lobRequestId,
  2.     long requestId, String streamId)
  3.     throws TeiidProcessingException {
  4.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_DQP, MessageLevel.DETAIL)) {
  5.     LogManager.logDetail(LogConstants.CTX_DQP, "Request for next Lob chunk with Stream id="+streamId+" instance id="+lobRequestId);  //$NON-NLS-1$//$NON-NLS-2$
  6.   }  
  7.   RequestWorkItem workItem = getRequestWorkItem(DQPWorkContext.getWorkContext().getRequestID(requestId));
  8.   ResultsFuture<LobChunk> resultsFuture = new ResultsFuture<LobChunk>();
  9.   workItem.processLobChunkRequest(streamId, lobRequestId, resultsFuture.getResultsReceiver());
  10.   return resultsFuture;
  11. }

代码示例来源：origin: org.teiid/teiid-engine

  1. public ResultsFuture<LobChunk> requestNextLobChunk(int lobRequestId,
  2.     long requestId, String streamId)
  3.     throws TeiidProcessingException {
  4.   if (LogManager.isMessageToBeRecorded(LogConstants.CTX_DQP, MessageLevel.DETAIL)) {
  5.     LogManager.logDetail(LogConstants.CTX_DQP, "Request for next Lob chunk with Stream id="+streamId+" instance id="+lobRequestId);  //$NON-NLS-1$//$NON-NLS-2$
  6.   }  
  7.   RequestWorkItem workItem = getRequestWorkItem(DQPWorkContext.getWorkContext().getRequestID(requestId));
  8.   ResultsFuture<LobChunk> resultsFuture = new ResultsFuture<LobChunk>();
  9.   workItem.processLobChunkRequest(streamId, lobRequestId, resultsFuture.getResultsReceiver());
  10.   return resultsFuture;
  11. }

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

LogManager

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com