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
|
/*******************************************************************************
* Copyright (c) 2007, 2009 IBM Corporation
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*******************************************************************************/
package org.eclipse.equinox.log.internal;
import java.util.Dictionary;
import java.util.Hashtable;
import org.eclipse.equinox.log.SynchronousLogListener;
import org.osgi.framework.Bundle;
import org.osgi.framework.ServiceReference;
import org.osgi.service.event.Event;
import org.osgi.service.event.EventAdmin;
import org.osgi.service.log.LogEntry;
import org.osgi.service.log.LogService;
public class EventAdminLogListener implements SynchronousLogListener {
// constants for Event topic substring
public static final String TOPIC = "org/osgi/service/log/LogEntry"; //$NON-NLS-1$
public static final char TOPIC_SEPARATOR = '/';
// constants for Event types
public static final String LOG_ERROR = "LOG_ERROR"; //$NON-NLS-1$
public static final String LOG_WARNING = "LOG_WARNING"; //$NON-NLS-1$
public static final String LOG_INFO = "LOG_INFO"; //$NON-NLS-1$
public static final String LOG_DEBUG = "LOG_DEBUG"; //$NON-NLS-1$
public static final String LOG_OTHER = "LOG_OTHER"; //$NON-NLS-1$
// constants for Event properties
public static final String TIMESTAMP = "timestamp"; //$NON-NLS-1$
public static final String MESSAGE = "message"; //$NON-NLS-1$
public static final String LOG_LEVEL = "log.level"; //$NON-NLS-1$
public static final String LOG_ENTRY = "log.entry"; //$NON-NLS-1$
public static final String SERVICE = "service"; //$NON-NLS-1$
public static final String SERVICE_ID = "service.id"; //$NON-NLS-1$
public static final String SERVICE_OBJECTCLASS = "service.objectClass"; //$NON-NLS-1$
public static final String SERVICE_PID = "service.pid"; //$NON-NLS-1$
public static final String BUNDLE = "bundle"; //$NON-NLS-1$
public static final String BUNDLE_ID = "bundle.id"; //$NON-NLS-1$
public static final String BUNDLE_SYMBOLICNAME = "bundle.symbolicName"; //$NON-NLS-1$
public static final String EVENT = "event"; //$NON-NLS-1$
public static final String EXCEPTION = "exception"; //$NON-NLS-1$
public static final String EXCEPTION_CLASS = "exception.class"; //$NON-NLS-1$
public static final String EXCEPTION_MESSAGE = "exception.message"; //$NON-NLS-1$
private EventAdmin eventAdmin;
public EventAdminLogListener(EventAdmin eventAdmin) {
this.eventAdmin = eventAdmin;
}
public void logged(LogEntry entry) {
Event convertedEvent = convertEvent(entry);
eventAdmin.postEvent(convertedEvent);
}
private static Event convertEvent(LogEntry entry) {
String topic = TOPIC;
int level = entry.getLevel();
switch (level) {
case LogService.LOG_ERROR :
topic += TOPIC_SEPARATOR + LOG_ERROR;
break;
case LogService.LOG_WARNING :
topic += TOPIC_SEPARATOR + LOG_WARNING;
break;
case LogService.LOG_INFO :
topic += TOPIC_SEPARATOR + LOG_INFO;
break;
case LogService.LOG_DEBUG :
topic += TOPIC_SEPARATOR + LOG_DEBUG;
break;
default : // other log levels are represented by LOG_OTHER
topic += TOPIC_SEPARATOR + LOG_OTHER;
}
Hashtable properties = new Hashtable();
Bundle bundle = entry.getBundle();
if (bundle == null) {
throw new RuntimeException("LogEntry.getBundle() returns null"); //$NON-NLS-1$
}
putBundleProperties(properties, bundle);
Throwable t = entry.getException();
if (t != null) {
putExceptionProperties(properties, t);
}
ServiceReference ref = entry.getServiceReference();
if (ref != null) {
putServiceReferenceProperties(properties, ref);
}
properties.put(LOG_ENTRY, entry);
properties.put(LOG_LEVEL, new Integer(entry.getLevel()));
if (entry.getMessage() != null)
properties.put(MESSAGE, entry.getMessage());
properties.put(TIMESTAMP, new Long(entry.getTime()));
return new Event(topic, (Dictionary) properties);
}
public static void putServiceReferenceProperties(Hashtable properties, ServiceReference ref) {
properties.put(SERVICE, ref);
properties.put(SERVICE_ID, ref.getProperty(org.osgi.framework.Constants.SERVICE_ID));
Object o = ref.getProperty(org.osgi.framework.Constants.SERVICE_PID);
if ((o != null) && (o instanceof String)) {
properties.put(SERVICE_PID, o);
}
Object o2 = ref.getProperty(org.osgi.framework.Constants.OBJECTCLASS);
if ((o2 != null) && (o2 instanceof String[])) {
properties.put(SERVICE_OBJECTCLASS, o2);
}
}
public static void putBundleProperties(Hashtable properties, Bundle bundle) {
properties.put(BUNDLE_ID, new Long(bundle.getBundleId()));
String symbolicName = bundle.getSymbolicName();
if (symbolicName != null) {
properties.put(BUNDLE_SYMBOLICNAME, symbolicName);
}
properties.put(BUNDLE, bundle);
}
public static void putExceptionProperties(Hashtable properties, Throwable t) {
properties.put(EXCEPTION, t);
properties.put(EXCEPTION_CLASS, t.getClass().getName());
String message = t.getMessage();
if (message != null) {
properties.put(EXCEPTION_MESSAGE, t.getMessage());
}
}
}
|
