blob: 3916482a4b921bc583695e03678d23fdfcab797d (
plain)
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
|
/*
*
* 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.transport.vm;
import java.lang.reflect.Method;
import org.apache.qpid.BrokerOptions;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* This class is used to start an InVm broker instance.
*/
public class VmBroker
{
private static final String BROKER_INSTANCE = "org.apache.qpid.server.BrokerInstance";
private static final Logger _logger = LoggerFactory.getLogger(VmBroker.class);
private static Object _instance = null;
public static void createVMBroker() throws VMBrokerCreationException
{
if (_instance == null)
{
BrokerOptions options = new BrokerOptions();
options.setProtocol("vm");
options.setBind("localhost");
options.setPorts(1);
createVMBroker(options);
}
}
public static synchronized void createVMBroker(BrokerOptions options) throws VMBrokerCreationException
{
if (_instance == null)
{
try
{
Class<?> brokerClass = Class.forName(BROKER_INSTANCE);
Object brokerInstance = brokerClass.newInstance();
Class<?>[] types = { BrokerOptions.class };
Object[] args = { options };
Method startup = brokerClass.getMethod("startup", types);
startup.invoke(brokerInstance, args);
_instance = brokerInstance;
}
catch (Exception e)
{
String because;
if (e.getCause() == null)
{
because = e.toString();
}
else
{
because = e.getCause().toString();
}
_logger.warn("Unable to create InVM broker instance: " + because);
throw new VMBrokerCreationException(because + " Stopped InVM broker instance creation", e);
}
_logger.info("Created InVM broker instance.");
}
}
public static synchronized void killVMBroker()
{
_logger.info("Killing InVM broker instance");
if (_instance != null)
{
try
{
Class<?> brokerClass = Class.forName(BROKER_INSTANCE);
Method shutdown = brokerClass.getMethod("shutdown", new Class[0]);
shutdown.invoke(_instance);
_instance = null;
}
catch (Exception e)
{
String because;
if (e.getCause() == null)
{
because = e.toString();
}
else
{
because = e.getCause().toString();
}
_logger.warn("Error shutting down broker instance: " + because);
}
}
_logger.info("Stopped InVM broker instance");
}
}
|
