"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "testsuite/integration/clustering/src/test/java/org/jboss/as/test/clustering/cluster/web/expiration/RecordingWebListener.java" between
wildfly-21.0.0.Final-src.zip and wildfly-21.0.1.Final-src.zip

About: WildFly is an application server with a standards-compliant, fast and lightweight implementation of the Java Enterprise Edition 7 Platform specifications (formerly known as JBoss community version). Sources.

RecordingWebListener.java  (wildfly-21.0.0.Final-src):RecordingWebListener.java  (wildfly-21.0.1.Final-src)
skipping to change at line 38 skipping to change at line 38
import javax.servlet.annotation.WebListener; import javax.servlet.annotation.WebListener;
import javax.servlet.http.HttpSessionAttributeListener; import javax.servlet.http.HttpSessionAttributeListener;
import javax.servlet.http.HttpSessionBindingEvent; import javax.servlet.http.HttpSessionBindingEvent;
import javax.servlet.http.HttpSessionEvent; import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener; import javax.servlet.http.HttpSessionListener;
@WebListener @WebListener
public class RecordingWebListener implements HttpSessionListener, HttpSessionAtt ributeListener { public class RecordingWebListener implements HttpSessionListener, HttpSessionAtt ributeListener {
public static BlockingQueue<String> createdSessions = new LinkedBlockingQueu public static final BlockingQueue<String> createdSessions = new LinkedBlocki
e<>(); ngQueue<>();
public static BlockingQueue<String> destroyedSessions = new LinkedBlockingQu public static final BlockingQueue<String> destroyedSessions = new LinkedBloc
eue<>(); kingQueue<>();
public static ConcurrentMap<String, BlockingQueue<String>> addedAttributes = public static final ConcurrentMap<String, BlockingQueue<String>> addedAttrib
new ConcurrentHashMap<>(); utes = new ConcurrentHashMap<>();
public static ConcurrentMap<String, BlockingQueue<String>> removedAttributes public static final ConcurrentMap<String, BlockingQueue<String>> removedAttr
= new ConcurrentHashMap<>(); ibutes = new ConcurrentHashMap<>();
public static ConcurrentMap<String, BlockingQueue<String>> replacedAttribute public static final ConcurrentMap<String, BlockingQueue<String>> replacedAtt
s = new ConcurrentHashMap<>(); ributes = new ConcurrentHashMap<>();
private static void record(HttpSessionBindingEvent event, ConcurrentMap<Stri ng, BlockingQueue<String>> attributes) { private static void record(HttpSessionBindingEvent event, ConcurrentMap<Stri ng, BlockingQueue<String>> attributes) {
BlockingQueue<String> set = new LinkedBlockingQueue<>(); BlockingQueue<String> set = new LinkedBlockingQueue<>();
BlockingQueue<String> existing = attributes.putIfAbsent(event.getSession ().getId(), set); BlockingQueue<String> existing = attributes.putIfAbsent(event.getSession ().getId(), set);
((existing != null) ? existing : set).add(event.getName()); ((existing != null) ? existing : set).add(event.getName());
} }
@Override @Override
public void attributeAdded(HttpSessionBindingEvent event) { public void attributeAdded(HttpSessionBindingEvent event) {
record(event, addedAttributes); record(event, addedAttributes);
 End of changes. 1 change blocks. 
10 lines changed or deleted 10 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)