1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
|
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
package org.apache.qpid.management.ui;
import java.io.File;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import org.eclipse.jface.resource.FontRegistry;
import org.eclipse.jface.resource.ImageRegistry;
import org.eclipse.swt.SWT;
import org.eclipse.swt.graphics.Font;
import org.eclipse.swt.graphics.FontData;
import org.eclipse.swt.graphics.Image;
import org.eclipse.ui.ISharedImages;
import org.eclipse.ui.PlatformUI;
/**
* Main Application Registry, which contains shared resources and map to all connected servers.
* @author Bhupendra Bhardwaj
*/
public abstract class ApplicationRegistry
{
private static ImageRegistry imageRegistry = new ImageRegistry();
private static FontRegistry fontRegistry = new FontRegistry();
public static final boolean debug = Boolean.getBoolean("eclipse.consoleLog");
public static final long timeout = Long.parseLong(System.getProperty("timeout", "15000"));
//max supported broker management interface supported by this release of the management console
public static final int SUPPORTED_QPID_JMX_API_MAJOR_VERSION = 2;
public static final int SUPPORTED_QPID_JMX_API_MINOR_VERSION = 3;
public static final String DATA_DIR = System.getProperty("user.home") + File.separator + ".qpidmc";
static
{
imageRegistry.put(Constants.SUCCESS_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/success.gif"));
imageRegistry.put(Constants.FAILURE_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/failure.gif"));
imageRegistry.put(Constants.CONSOLE_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/qpidmc.gif"));
imageRegistry.put(Constants.CLOSED_FOLDER_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/icon_ClosedFolder.gif"));
imageRegistry.put(Constants.OPEN_FOLDER_IMAGE,
PlatformUI.getWorkbench().getSharedImages().getImage(ISharedImages.IMG_OBJ_FOLDER));
imageRegistry.put(Constants.MBEAN_IMAGE,
PlatformUI.getWorkbench().getSharedImages().getImage(ISharedImages.IMG_OBJ_ELEMENT));
imageRegistry.put(Constants.NOTIFICATION_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/notifications.gif"));
imageRegistry.put(Constants.LOGGING_MANAGEMENT_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/logging_management.gif"));
imageRegistry.put(Constants.USER_MANAGEMENT_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/user_management.gif"));
imageRegistry.put(Constants.CONFIGURATION_MANAGEMENT_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/configuration_management.gif"));
imageRegistry.put(Constants.SERVER_INFO_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/server_information.gif"));
imageRegistry.put(Constants.VHOST_MANAGER_IMAGE,
org.apache.qpid.management.ui.Activator.getImageDescriptor("/icons/virtualhost_manager.gif"));
}
static
{
fontRegistry.put(Constants.FONT_BUTTON, new FontData[]{new FontData("Arial", 8, SWT.BOLD)} );
fontRegistry.put(Constants.FONT_BOLD, new FontData[]{new FontData("Bold", 9, SWT.BOLD)} );
fontRegistry.put(Constants.FONT_ITALIC, new FontData[]{new FontData("Italic", 9, SWT.ITALIC)} );
fontRegistry.put(Constants.FONT_TABLE_CELL, new FontData[]{new FontData("Tablecell", 8, SWT.NORMAL)} );
fontRegistry.put(Constants.FONT_NORMAL, new FontData[]{new FontData("Normal", 9, SWT.NORMAL)} );
}
/*
* This maps all the managed servers to the respective server registry.
*/
private static ConcurrentHashMap<ManagedServer, ServerRegistry> _serverRegistryMap = new ConcurrentHashMap<ManagedServer, ServerRegistry>();
// This map gets updated when a server connection closes.
private static List<ManagedServer> _closedServerList = new CopyOnWriteArrayList<ManagedServer>();
public static Image getImage(String key)
{
return imageRegistry.get(key);
}
public static Font getFont(String key)
{
return fontRegistry.get(key);
}
public static void addServer(ManagedServer server, ServerRegistry registry)
{
_serverRegistryMap.put(server, registry);
}
public static void removeServer(ManagedServer server)
{
_serverRegistryMap.remove(server);
}
public static ServerRegistry getServerRegistry(ManagedServer server)
{
return _serverRegistryMap.get(server);
}
public static ServerRegistry getServerRegistry(ManagedBean mbean)
{
ManagedServer server = mbean.getServer();
return getServerRegistry(server);
}
public static boolean isServerConnected(ManagedServer server)
{
if(server == null)
{
//checking for null is not permitted in a CHM
return false;
}
ServerRegistry reg = _serverRegistryMap.get(server);
if(reg !=null)
{
return !reg.isServerConnectionClosed();
}
return false;
}
// remove the server from the registry
public static void serverConnectionClosed(ManagedServer server)
{
_closedServerList.add(server);
removeServer(server);
}
// remove the server from the registry
public static void serverConnectionClosedRemotely(ManagedServer server)
{
ServerRegistry reg = _serverRegistryMap.get(server);
if(reg !=null)
{
synchronized(server)
{
if(reg.isServerConnectionClosed())
{
//the connection closure was already processed
return;
}
reg.serverConnectionClosed();
}
}
serverConnectionClosed(server);
}
/*
* Returns the lis of closed servers. The Thread in GUI, which keeps checking for closed connection
* will check this and will remove the server links from the GUI.
*/
public static List<ManagedServer> getClosedServers()
{
if (_closedServerList.isEmpty())
return null;
List<ManagedServer> list = new CopyOnWriteArrayList<ManagedServer>(_closedServerList);
_closedServerList.clear();
return list;
}
}
|
