static final long serialVersionUID = 1l;
- //private String clientId = UUID.randomUUID().toString();
+ // private String clientId = UUID.randomUUID().toString();
/** Synchronized */
private List<SlcEventListenerDescriptor> descriptors = new Vector<SlcEventListenerDescriptor>();
return new ArrayList<SlcEventListenerDescriptor>(descriptors);
}
+ public String getId() {
+ return RequestContextHolder.currentRequestAttributes().getSessionId();
+ }
+
// public SlcEvent listen(SlcEventListener eventListener, Long timeout) {
// return eventListener.listen(clientId, getDescriptorsCopy(), timeout);
// }
// return RequestContextHolder.currentRequestAttributes().getSessionId();
// }
//
- public String getId() {
- return RequestContextHolder.currentRequestAttributes().getSessionId();
- }
-
}
private Long defaultTimeout = 10000l;\r
\r
// IoC\r
- private SlcEventListenerRegister eventListenerRegister;\r
private SlcEventListener eventListener = null;\r
+ // the following bean as a Session scope.\r
+ private SlcEventListenerRegister eventListenerRegister;\r
\r
// Business Methods\r
@RequestMapping("/addEventListener.service")\r
eventListenerRegister\r
.addEventListenerDescriptor(new SlcEventListenerDescriptor(\r
eventType, eventFilter));\r
- if (log.isTraceEnabled())\r
+ if (log.isTraceEnabled()) {\r
log.trace("Registered listener on register "\r
+ eventListenerRegister.getId() + " for type " + eventType\r
+ ", filter=" + eventFilter);\r
+ log.trace("Nb of registered descriptors : "\r
+ + eventListenerRegister.getDescriptorsCopy().size());\r
+ }\r
return ExecutionAnswer.ok("Execution completed properly");\r
\r
}\r
eventListenerRegister\r
.removeEventListenerDescriptor(new SlcEventListenerDescriptor(\r
eventType, eventFilter));\r
- if (log.isTraceEnabled())\r
+ if (log.isTraceEnabled()) {\r
log.trace("Removed listener from register "\r
+ eventListenerRegister.getId() + " for type " + eventType\r
+ ", filter=" + eventFilter);\r
+ log.trace("Nb of registered descriptors : "\r
+ + eventListenerRegister.getDescriptorsCopy().size());\r
+ }\r
return ExecutionAnswer.ok("Execution completed properly");\r
}\r
\r
timeout = Long.parseLong(timeoutStr);\r
else\r
timeout = defaultTimeout;\r
-\r
+ if (log.isTraceEnabled()) {\r
+ log.trace("Begin poolEvent.service :"\r
+ + " Nb of registered descriptors : "\r
+ + eventListenerRegister.getDescriptorsCopy().size());\r
+ }\r
SlcEvent event = eventListener.listen(eventListenerRegister.getId(),\r
eventListenerRegister.getDescriptorsCopy(), timeout);\r
if (event != null) {\r
+ if (log.isTraceEnabled())\r
+ log.trace("Event heard : " + event.toString());\r
return event;\r
} else {\r
+ if (log.isTraceEnabled())\r
+ log.trace("No Event heard - Time out: ");\r
return ExecutionAnswer.ok("Execution completed properly");\r
}\r
+\r
}\r
\r
public void setEventListenerRegister(\r