001 /** 002 * Licensed to the Apache Software Foundation (ASF) under one or more 003 * contributor license agreements. See the NOTICE file distributed with 004 * this work for additional information regarding copyright ownership. 005 * The ASF licenses this file to You under the Apache License, Version 2.0 006 * (the "License"); you may not use this file except in compliance with 007 * the License. You may obtain a copy of the License at 008 * 009 * http://www.apache.org/licenses/LICENSE-2.0 010 * 011 * Unless required by applicable law or agreed to in writing, software 012 * distributed under the License is distributed on an "AS IS" BASIS, 013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 014 * See the License for the specific language governing permissions and 015 * limitations under the License. 016 */ 017 package org.apache.camel.management.mbean; 018 019 import java.util.List; 020 021 import org.apache.camel.CamelContext; 022 import org.apache.camel.api.management.ManagedResource; 023 import org.apache.camel.api.management.mbean.BacklogTracerEventMessage; 024 import org.apache.camel.api.management.mbean.ManagedBacklogTracerMBean; 025 import org.apache.camel.processor.interceptor.BacklogTracer; 026 import org.apache.camel.spi.ManagementStrategy; 027 028 /** 029 * @version 030 */ 031 @ManagedResource(description = "Managed BacklogTracer") 032 public class ManagedBacklogTracer implements ManagedBacklogTracerMBean { 033 private final CamelContext camelContext; 034 private final BacklogTracer backlogTracer; 035 036 public ManagedBacklogTracer(CamelContext camelContext, BacklogTracer backlogTracer) { 037 this.camelContext = camelContext; 038 this.backlogTracer = backlogTracer; 039 } 040 041 public void init(ManagementStrategy strategy) { 042 // do nothing 043 } 044 045 public CamelContext getContext() { 046 return camelContext; 047 } 048 049 public BacklogTracer getBacklogTracer() { 050 return backlogTracer; 051 } 052 053 public boolean getEnabled() { 054 return backlogTracer.isEnabled(); 055 } 056 057 public void setEnabled(boolean enabled) { 058 backlogTracer.setEnabled(enabled); 059 } 060 061 public boolean isEnabled() { 062 return backlogTracer.isEnabled(); 063 } 064 065 public int getBacklogSize() { 066 return backlogTracer.getBacklogSize(); 067 } 068 069 public void setBacklogSize(int backlogSize) { 070 backlogTracer.setBacklogSize(backlogSize); 071 } 072 073 public boolean isRemoveOnDump() { 074 return backlogTracer.isRemoveOnDump(); 075 } 076 077 public void setRemoveOnDump(boolean removeOnDump) { 078 backlogTracer.setRemoveOnDump(removeOnDump); 079 } 080 081 public void setTracePattern(String pattern) { 082 backlogTracer.setTracePattern(pattern); 083 } 084 085 public String getTracePattern() { 086 return backlogTracer.getTracePattern(); 087 } 088 089 public void setTraceFilter(String predicate) { 090 backlogTracer.setTraceFilter(predicate); 091 } 092 093 public String getTraceFilter() { 094 return backlogTracer.getTraceFilter(); 095 } 096 097 public long getTraceCounter() { 098 return backlogTracer.getTraceCounter(); 099 } 100 101 public void resetTraceCounter() { 102 backlogTracer.resetTraceCounter(); 103 } 104 105 public int getBodyMaxChars() { 106 return backlogTracer.getBodyMaxChars(); 107 } 108 109 public void setBodyMaxChars(int bodyMaxChars) { 110 backlogTracer.setBodyMaxChars(bodyMaxChars); 111 } 112 113 public boolean isBodyIncludeStreams() { 114 return backlogTracer.isBodyIncludeStreams(); 115 } 116 117 public void setBodyIncludeStreams(boolean bodyIncludeStreams) { 118 backlogTracer.setBodyIncludeStreams(bodyIncludeStreams); 119 } 120 121 public boolean isBodyIncludeFiles() { 122 return backlogTracer.isBodyIncludeFiles(); 123 } 124 125 public void setBodyIncludeFiles(boolean bodyIncludeFiles) { 126 backlogTracer.setBodyIncludeFiles(bodyIncludeFiles); 127 } 128 129 public List<BacklogTracerEventMessage> dumpTracedMessages(String nodeOrRouteId) { 130 return backlogTracer.dumpTracedMessages(nodeOrRouteId); 131 } 132 133 public List<BacklogTracerEventMessage> dumpAllTracedMessages() { 134 return backlogTracer.dumpAllTracedMessages(); 135 } 136 137 public String dumpTracedMessagesAsXml(String nodeOrRouteId) { 138 return backlogTracer.dumpTracedMessagesAsXml(nodeOrRouteId); 139 } 140 141 public String dumpAllTracedMessagesAsXml() { 142 return backlogTracer.dumpAllTracedMessagesAsXml(); 143 } 144 145 public void clear() { 146 backlogTracer.clear(); 147 } 148 }