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 */ 017package org.apache.activemq.broker.jmx; 018 019import org.apache.activemq.network.NetworkConnector; 020 021public class NetworkConnectorView implements NetworkConnectorViewMBean { 022 023 private final NetworkConnector connector; 024 025 public NetworkConnectorView(NetworkConnector connector) { 026 this.connector = connector; 027 } 028 029 @Override 030 public void start() throws Exception { 031 connector.start(); 032 } 033 034 @Override 035 public void stop() throws Exception { 036 connector.stop(); 037 } 038 039 @Override 040 public String getName() { 041 return connector.getName(); 042 } 043 044 @Override 045 public int getMessageTTL() { 046 return connector.getMessageTTL(); 047 } 048 049 @Override 050 public int getConsumerTTL() { 051 return connector.getConsumerTTL(); 052 } 053 054 @Override 055 public int getPrefetchSize() { 056 return connector.getPrefetchSize(); 057 } 058 059 @Override 060 public int getAdvisoryPrefetchSize() { 061 return connector.getAdvisoryPrefetchSize(); 062 } 063 064 @Override 065 public String getUserName() { 066 return connector.getUserName(); 067 } 068 069 @Override 070 public boolean isBridgeTempDestinations() { 071 return connector.isBridgeTempDestinations(); 072 } 073 074 @Override 075 public boolean isConduitSubscriptions() { 076 return connector.isConduitSubscriptions(); 077 } 078 079 @Override 080 public boolean isDecreaseNetworkConsumerPriority() { 081 return connector.isDecreaseNetworkConsumerPriority(); 082 } 083 084 @Override 085 public boolean isDispatchAsync() { 086 return connector.isDispatchAsync(); 087 } 088 089 @Override 090 public boolean isDynamicOnly() { 091 return connector.isDynamicOnly(); 092 } 093 094 @Override 095 public boolean isDuplex() { 096 return connector.isDuplex(); 097 } 098 099 @Override 100 public boolean isSuppressDuplicateQueueSubscriptions() { 101 return connector.isSuppressDuplicateQueueSubscriptions(); 102 } 103 104 @Override 105 public boolean isSuppressDuplicateTopicSubscriptions() { 106 return connector.isSuppressDuplicateTopicSubscriptions(); 107 } 108 109 @Override 110 public void setBridgeTempDestinations(boolean bridgeTempDestinations) { 111 connector.setBridgeTempDestinations(bridgeTempDestinations); 112 } 113 114 @Override 115 public void setConduitSubscriptions(boolean conduitSubscriptions) { 116 connector.setConduitSubscriptions(conduitSubscriptions); 117 } 118 119 @Override 120 public void setDispatchAsync(boolean dispatchAsync) { 121 connector.setDispatchAsync(dispatchAsync); 122 } 123 124 @Override 125 public void setDynamicOnly(boolean dynamicOnly) { 126 connector.setDynamicOnly(dynamicOnly); 127 } 128 129 @Override 130 public void setMessageTTL(int messageTTL) { 131 connector.setMessageTTL(messageTTL); 132 } 133 134 @Override 135 public void setConsumerTTL(int consumerTTL) { 136 connector.setConsumerTTL(consumerTTL); 137 } 138 139 @Override 140 public void setPassword(String password) { 141 connector.setPassword(password); 142 } 143 144 @Override 145 public void setPrefetchSize(int prefetchSize) { 146 connector.setPrefetchSize(prefetchSize); 147 } 148 149 @Override 150 public void setAdvisoryPrefetchSize(int advisoryPrefetchSize) { 151 connector.setAdvisoryPrefetchSize(advisoryPrefetchSize); 152 } 153 154 @Override 155 public void setUserName(String userName) { 156 connector.setUserName(userName); 157 } 158 159 @Override 160 public String getPassword() { 161 String pw = connector.getPassword(); 162 // Hide the password for security reasons. 163 if (pw != null) { 164 pw = pw.replaceAll(".", "*"); 165 } 166 return pw; 167 } 168 169 @Override 170 public void setDecreaseNetworkConsumerPriority(boolean decreaseNetworkConsumerPriority) { 171 connector.setDecreaseNetworkConsumerPriority(decreaseNetworkConsumerPriority); 172 } 173 174 @Override 175 public void setSuppressDuplicateQueueSubscriptions(boolean val) { 176 connector.setSuppressDuplicateQueueSubscriptions(val); 177 } 178 179 @Override 180 public void setSuppressDuplicateTopicSubscriptions(boolean val) { 181 connector.setSuppressDuplicateTopicSubscriptions(val); 182 } 183}