1 /*
2  * JBoss, Home of Professional Open Source.
3  * Copyright 2014 Red Hat, Inc., and individual contributors
4  * as indicated by the @author tags.
5  *
6  * Licensed under the Apache License, Version 2.0 (the "License");
7  * you may not use this file except in compliance with the License.
8  * You may obtain a copy of the License at
9  *
10  *     http://www.apache.org/licenses/LICENSE-2.0
11  *
12  *  Unless required by applicable law or agreed to in writing, software
13  *  distributed under the License is distributed on an "AS IS" BASIS,
14  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  *  See the License for the specific language governing permissions and
16  *  limitations under the License.
17  */
18
19 package io.undertow.servlet.core;
20
21 import java.util.EventListener;
22
23 import javax.servlet.ServletException;
24
25 import io.undertow.servlet.UndertowServletMessages;
26 import io.undertow.servlet.api.InstanceHandle;
27 import io.undertow.servlet.api.ListenerInfo;
28
29 /**
30  * @author Stuart Douglas
31  */
32 public class ManagedListener implements Lifecycle {
33
34     private final ListenerInfo listenerInfo;
35     private final boolean programatic;
36
37     private volatile boolean started = false;
38     private volatile InstanceHandle<? extends EventListener> handle;
39
40     public ManagedListener(final ListenerInfo listenerInfo, final boolean programatic) {
41         this.listenerInfo = listenerInfo;
42         this.programatic = programatic;
43     }
44
45     public synchronized void start() throws ServletException {
46         if (!started) {
47             try {
48                 handle = listenerInfo.getInstanceFactory().createInstance();
49             } catch (Exception e) {
50                 throw UndertowServletMessages.MESSAGES.couldNotInstantiateComponent(listenerInfo.getListenerClass().getName(), e);
51             }
52             started = true;
53         }
54     }
55
56     public synchronized void stop() {
57         started = false;
58         if (handle != null) {
59             handle.release();
60         }
61     }
62
63     public ListenerInfo getListenerInfo() {
64         return listenerInfo;
65     }
66
67     @Override
68     public boolean isStarted() {
69         return started;
70     }
71
72     public EventListener instance() {
73         if (!started) {
74             throw UndertowServletMessages.MESSAGES.listenerIsNotStarted();
75         }
76         return handle.getInstance();
77     }
78
79     public boolean isProgramatic() {
80         return programatic;
81     }
82
83     @Override
84     public String toString() {
85         return "ManagedListener{" +
86                 "listenerInfo=" + listenerInfo +
87                 '}';
88     }
89 }
90