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}