2 * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org
.argeo
.slc
.web
.mvc
;
19 import java
.io
.Serializable
;
20 import java
.util
.ArrayList
;
21 import java
.util
.List
;
22 import java
.util
.Vector
;
24 import org
.argeo
.slc
.msg
.event
.SlcEventListenerDescriptor
;
25 import org
.argeo
.slc
.msg
.event
.SlcEventListenerRegister
;
26 import org
.springframework
.web
.context
.request
.RequestContextHolder
;
28 public class WebSlcEventListenerRegister
implements SlcEventListenerRegister
,
30 public final static String ATTR_EVENT_LISTENER
= "slcEventListener";
32 static final long serialVersionUID
= 1l;
34 //private String clientId = UUID.randomUUID().toString();
37 private List
<SlcEventListenerDescriptor
> descriptors
= new Vector
<SlcEventListenerDescriptor
>();
39 public synchronized void addEventListenerDescriptor(
40 SlcEventListenerDescriptor eventListenerDescriptor
) {
41 if (descriptors
.contains(eventListenerDescriptor
))
42 descriptors
.remove(eventListenerDescriptor
);
43 descriptors
.add(eventListenerDescriptor
);
46 public synchronized void removeEventListenerDescriptor(
47 SlcEventListenerDescriptor eventListenerDescriptor
) {
48 descriptors
.remove(eventListenerDescriptor
);
51 public synchronized List
<SlcEventListenerDescriptor
> getDescriptorsCopy() {
52 return new ArrayList
<SlcEventListenerDescriptor
>(descriptors
);
55 // public SlcEvent listen(SlcEventListener eventListener, Long timeout) {
56 // return eventListener.listen(clientId, getDescriptorsCopy(), timeout);
59 // public void init() {
60 // clientId = getSessionId();
63 // if (log.isDebugEnabled())
64 // log.debug("Initialized web event listener " + clientId);
67 // public void close() {
69 // if (log.isDebugEnabled())
70 // log.debug("Closed web event listener " + clientId);
73 // protected void checkClientId() {
74 // String sessionId = getSessionId();
75 // if (clientId == null || !clientId.equals(sessionId))
76 // throw new SlcException("Client id " + clientId
77 // + " not consistent with web session id " + sessionId);
80 // protected String getSessionId() {
81 // return RequestContextHolder.currentRequestAttributes().getSessionId();
84 public String
getId() {
85 return RequestContextHolder
.currentRequestAttributes().getSessionId();