Searched refs:subscribe (Results 1 - 25 of 137) sorted by relevance

123456

/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/
H A DNotificationBroker.java53 Subscription subscribe(Consumer consumer); method in interface:NotificationBroker
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/session/blacklist/
H A DSessionBlacklist.java57 void subscribe(Listener listener); method in interface:SessionBlacklist
H A DNoOpSessionBlacklist.java46 public void subscribe(final Listener listener) { method in class:NoOpSessionBlacklist
H A DCachingSessionBlacklist.java91 public void subscribe(final Listener listener) { method in class:CachingSessionBlacklist
93 delegate.subscribe(listener);
H A DBloomFilterSessionBlacklist.java66 delegate.subscribe(new Listener() {
83 * negatives), this implementation will subscribe to blacklist notifications from the delegate.
118 public void subscribe(final Listener listener) { method in class:BloomFilterSessionBlacklist
119 delegate.subscribe(listener);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/blacklist/
H A DBlacklist.java53 void subscribe(Listener listener); method in interface:Blacklist
H A DNoOpBlacklist.java43 public void subscribe(Listener listener) { method in class:NoOpBlacklist
H A DConfigurableSessionBlacklist.java73 public void subscribe(Listener listener) { method in class:ConfigurableSessionBlacklist
74 delegate.subscribe(listener);
H A DCachingBlacklist.java90 public void subscribe(Listener listener) { method in class:CachingBlacklist
92 delegate.subscribe(listener);
H A DBloomFilterBlacklist.java61 delegate.subscribe(new Listener() {
78 * negatives), this implementation will subscribe to blacklist notifications from the delegate.
111 public void subscribe(Listener listener) { method in class:BloomFilterBlacklist
112 delegate.subscribe(listener);
/forgerock/openam/openam-notifications/src/test/java/org/forgerock/openam/notifications/
H A DInMemoryNotificationBrokerTest.java74 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
98 broker.subscribe(badConsumer).bindTo(Topic.of("test_topic"));
99 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
118 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
141 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
185 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
200 broker.subscribe(consumer)
222 broker.subscribe(consumer)
243 broker.subscribe(consumer)
270 broker.subscribe(consume
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/utils/
H A DNullNotificationBroker.java26 * A notification broker which performs no operation. This can be used in places where notification publish/subscribe
44 public Subscription subscribe(Consumer consumer) { method in class:NullNotificationBroker
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/session/blacklist/
H A DBloomFilterSessionBlacklistTest.java63 verify(mockDelegate).subscribe(any(SessionBlacklist.Listener.class));
71 willDoNothing().given(mockDelegate).subscribe(listenerArgumentCaptor.capture());
132 testBlacklist.subscribe(listener);
134 mockDelegate.subscribe(listener);
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/blacklist/
H A DBloomFilterBlacklistTest.java55 verify(mockDelegate).subscribe(any(Blacklist.Listener.class));
63 willDoNothing().given(mockDelegate).subscribe(listenerArgumentCaptor.capture());
124 testBlacklist.subscribe(listener);
126 mockDelegate.subscribe(listener);
/forgerock/openam-v13/openam-server-only/src/main/webapp/assets/js/
H A DApp.js91 this.dataTable.subscribe("initEvent", this.initPaginator, this, true);
92 this.dataTable.subscribe("refreshEvent", this.destroyDragDrops, this, true);
93 this.dataTable.subscribe("refreshEvent", this.createDragDrops, this, true);
239 this.dataTable.subscribe("rowMouseoverEvent", this.dataTable.onEventHighlightRow);
240 this.dataTable.subscribe("rowMouseoutEvent", this.dataTable.onEventUnhighlightRow);
241 this.dataTable.subscribe("rowClickEvent", this.dataTable.onEventSelectRow);
285 endDragMotion.onComplete.subscribe(function() {
/forgerock/openam/openam-server-only/src/main/webapp/assets/js/
H A DApp.js91 this.dataTable.subscribe("initEvent", this.initPaginator, this, true);
92 this.dataTable.subscribe("refreshEvent", this.destroyDragDrops, this, true);
93 this.dataTable.subscribe("refreshEvent", this.createDragDrops, this, true);
239 this.dataTable.subscribe("rowMouseoverEvent", this.dataTable.onEventHighlightRow);
240 this.dataTable.subscribe("rowMouseoutEvent", this.dataTable.onEventUnhighlightRow);
241 this.dataTable.subscribe("rowClickEvent", this.dataTable.onEventSelectRow);
285 endDragMotion.onComplete.subscribe(function() {
/forgerock/openam-v13/openam-server-only/src/main/webapp/assets/lib/yui/container/
H A Dcontainer-debug.js188 propertyObject.event.subscribe(propertyObject.handler,
552 * @param {Function} handler The handler function to use subscribe to
569 property.event.subscribe(handler, obj, override);
588 * @param {Function} handler The handler function to use subscribe to
1387 this.renderEvent.subscribe(this.cfg.fireQueue, this.cfg, true);
1482 Module.textResizeEvent.subscribe(this.onDomResize,
2244 this.showEvent.subscribe(this.showMacGeckoScrollbars,
2252 this.hideEvent.subscribe(this.hideMacGeckoScrollbars,
2618 ei.animateInCompleteEvent.subscribe(
2675 h.animateOutCompleteEvent.subscribe(
[all...]
H A Dcontainer-min.js9 if(!owner){}};var Lang=YAHOO.lang,CustomEvent=YAHOO.util.CustomEvent,Config=YAHOO.util.Config;Config.CONFIG_CHANGED_EVENT="configChanged";Config.BOOLEAN_TYPE="boolean";Config.prototype={owner:null,queueInProgress:false,config:null,initialConfig:null,eventQueue:null,configChangedEvent:null,init:function(owner){this.owner=owner;this.configChangedEvent=this.createEvent(Config.CONFIG_CHANGED_EVENT);this.configChangedEvent.signature=CustomEvent.LIST;this.queueInProgress=false;this.config={};this.initialConfig={};this.eventQueue=[];},checkBoolean:function(val){return(typeof val==Config.BOOLEAN_TYPE);},checkNumber:function(val){return(!isNaN(val));},fireEvent:function(key,value){var property=this.config[key];if(property&&property.event){property.event.fire(value);}},addProperty:function(key,propertyObject){key=key.toLowerCase();this.config[key]=propertyObject;propertyObject.event=this.createEvent(key,{scope:this.owner});propertyObject.event.signature=CustomEvent.LIST;propertyObject.key=key;if(propertyObject.handler){propertyObject.event.subscribe(propertyObject.handler,this.owner);}
19 this.queueInProgress=false;this.eventQueue=[];},subscribeToConfigEvent:function(key,handler,obj,override){var property=this.config[key.toLowerCase()];if(property&&property.event){if(!Config.alreadySubscribed(property.event,handler,obj)){property.event.subscribe(handler,obj,override);}
41 if(!Config.alreadySubscribed(this.renderEvent,this.cfg.fireQueue,this.cfg)){this.renderEvent.subscribe(this.cfg.fireQueue,this.cfg,true);}
47 if(oIFrame&&oIFrame.contentWindow){Module.textResizeEvent.subscribe(this.onDomResize,this,true);if(!Module.textResizeInitialized){if(!Event.on(oIFrame.contentWindow,"resize",fireTextResize)){Event.on(oIFrame,"resize",fireTextResize);}
65 if(this.platform=="mac"&&YAHOO.env.ua.gecko){if(!Config.alreadySubscribed(this.showEvent,this.showMacGeckoScrollbars,this)){this.showEvent.subscribe(this.showMacGeckoScrollbars,this,true);}
66 if(!Config.alreadySubscribed(this.hideEvent,this.hideMacGeckoScrollbars,this)){this.hideEvent.subscribe(this.hideMacGeckoScrollbars,this,true);}}
72 if(effect){if(visible){if(currentVis!="visible"||currentVis===""){this.beforeShowEvent.fire();nEffectInstances=effectInstances.length;for(j=0;j<nEffectInstances;j++){ei=effectInstances[j];if(j===0&&!alreadySubscribed(ei.animateInCompleteEvent,this.showEvent.fire,this.showEvent)){ei.animateInCompleteEvent.subscribe(this.showEvent.fire,this.showEvent,true);}
74 if(effect){if(currentVis=="visible"){this.beforeHideEvent.fire();nEffectInstances=effectInstances.length;for(k=0;k<nEffectInstances;k++){h=effectInstances[k];if(k===0&&!alreadySubscribed(h.animateOutCompleteEvent,this.hideEvent.fire,this.hideEvent)){h.animateOutCompleteEvent.subscribe(this.hideEvent.fire,this.hideEvent,true);}
75 h.animateOut();}}else if(currentVis===""){Dom.setStyle(this.element,"visibility","hidden");}}else{if(currentVis=="visible"||currentVis===""){this.beforeHideEvent.fire();Dom.setStyle(this.element,"visibility","hidden");this.hideEvent.fire();}}}},doCenterOnDOMEvent:function(){if(this.cfg.getProperty("visible")){this.center();}},configFixedCenter:function(type,args,obj){var val=args[0],alreadySubscribed=Config.alreadySubscribed,windowResizeEvent=Overlay.windowResizeEvent,windowScrollEvent=Overlay.windowScrollEvent;if(val){this.center();if(!alreadySubscribed(this.beforeShowEvent,this.center,this)){this.beforeShowEvent.subscribe(this.center);}
76 if(!alreadySubscribed(windowResizeEvent,this.doCenterOnDOMEvent,this)){windowResizeEvent.subscribe(thi
[all...]
H A Dcontainer.js185 propertyObject.event.subscribe(propertyObject.handler,
546 * @param {Function} handler The handler function to use subscribe to
563 property.event.subscribe(handler, obj, override);
582 * @param {Function} handler The handler function to use subscribe to
1379 this.renderEvent.subscribe(this.cfg.fireQueue, this.cfg, true);
1474 Module.textResizeEvent.subscribe(this.onDomResize,
2234 this.showEvent.subscribe(this.showMacGeckoScrollbars,
2242 this.hideEvent.subscribe(this.hideMacGeckoScrollbars,
2608 ei.animateInCompleteEvent.subscribe(
2665 h.animateOutCompleteEvent.subscribe(
[all...]
H A Dcontainer_core-debug.js188 propertyObject.event.subscribe(propertyObject.handler,
552 * @param {Function} handler The handler function to use subscribe to
569 property.event.subscribe(handler, obj, override);
588 * @param {Function} handler The handler function to use subscribe to
1387 this.renderEvent.subscribe(this.cfg.fireQueue, this.cfg, true);
1482 Module.textResizeEvent.subscribe(this.onDomResize,
2244 this.showEvent.subscribe(this.showMacGeckoScrollbars,
2252 this.hideEvent.subscribe(this.hideMacGeckoScrollbars,
2618 ei.animateInCompleteEvent.subscribe(
2675 h.animateOutCompleteEvent.subscribe(
[all...]
H A Dcontainer_core-min.js9 if(!owner){}};var Lang=YAHOO.lang,CustomEvent=YAHOO.util.CustomEvent,Config=YAHOO.util.Config;Config.CONFIG_CHANGED_EVENT="configChanged";Config.BOOLEAN_TYPE="boolean";Config.prototype={owner:null,queueInProgress:false,config:null,initialConfig:null,eventQueue:null,configChangedEvent:null,init:function(owner){this.owner=owner;this.configChangedEvent=this.createEvent(Config.CONFIG_CHANGED_EVENT);this.configChangedEvent.signature=CustomEvent.LIST;this.queueInProgress=false;this.config={};this.initialConfig={};this.eventQueue=[];},checkBoolean:function(val){return(typeof val==Config.BOOLEAN_TYPE);},checkNumber:function(val){return(!isNaN(val));},fireEvent:function(key,value){var property=this.config[key];if(property&&property.event){property.event.fire(value);}},addProperty:function(key,propertyObject){key=key.toLowerCase();this.config[key]=propertyObject;propertyObject.event=this.createEvent(key,{scope:this.owner});propertyObject.event.signature=CustomEvent.LIST;propertyObject.key=key;if(propertyObject.handler){propertyObject.event.subscribe(propertyObject.handler,this.owner);}
19 this.queueInProgress=false;this.eventQueue=[];},subscribeToConfigEvent:function(key,handler,obj,override){var property=this.config[key.toLowerCase()];if(property&&property.event){if(!Config.alreadySubscribed(property.event,handler,obj)){property.event.subscribe(handler,obj,override);}
41 if(!Config.alreadySubscribed(this.renderEvent,this.cfg.fireQueue,this.cfg)){this.renderEvent.subscribe(this.cfg.fireQueue,this.cfg,true);}
47 if(oIFrame&&oIFrame.contentWindow){Module.textResizeEvent.subscribe(this.onDomResize,this,true);if(!Module.textResizeInitialized){if(!Event.on(oIFrame.contentWindow,"resize",fireTextResize)){Event.on(oIFrame,"resize",fireTextResize);}
65 if(this.platform=="mac"&&YAHOO.env.ua.gecko){if(!Config.alreadySubscribed(this.showEvent,this.showMacGeckoScrollbars,this)){this.showEvent.subscribe(this.showMacGeckoScrollbars,this,true);}
66 if(!Config.alreadySubscribed(this.hideEvent,this.hideMacGeckoScrollbars,this)){this.hideEvent.subscribe(this.hideMacGeckoScrollbars,this,true);}}
72 if(effect){if(visible){if(currentVis!="visible"||currentVis===""){this.beforeShowEvent.fire();nEffectInstances=effectInstances.length;for(j=0;j<nEffectInstances;j++){ei=effectInstances[j];if(j===0&&!alreadySubscribed(ei.animateInCompleteEvent,this.showEvent.fire,this.showEvent)){ei.animateInCompleteEvent.subscribe(this.showEvent.fire,this.showEvent,true);}
74 if(effect){if(currentVis=="visible"){this.beforeHideEvent.fire();nEffectInstances=effectInstances.length;for(k=0;k<nEffectInstances;k++){h=effectInstances[k];if(k===0&&!alreadySubscribed(h.animateOutCompleteEvent,this.hideEvent.fire,this.hideEvent)){h.animateOutCompleteEvent.subscribe(this.hideEvent.fire,this.hideEvent,true);}
75 h.animateOut();}}else if(currentVis===""){Dom.setStyle(this.element,"visibility","hidden");}}else{if(currentVis=="visible"||currentVis===""){this.beforeHideEvent.fire();Dom.setStyle(this.element,"visibility","hidden");this.hideEvent.fire();}}}},doCenterOnDOMEvent:function(){if(this.cfg.getProperty("visible")){this.center();}},configFixedCenter:function(type,args,obj){var val=args[0],alreadySubscribed=Config.alreadySubscribed,windowResizeEvent=Overlay.windowResizeEvent,windowScrollEvent=Overlay.windowScrollEvent;if(val){this.center();if(!alreadySubscribed(this.beforeShowEvent,this.center,this)){this.beforeShowEvent.subscribe(this.center);}
76 if(!alreadySubscribed(windowResizeEvent,this.doCenterOnDOMEvent,this)){windowResizeEvent.subscribe(thi
[all...]
H A Dcontainer_core.js185 propertyObject.event.subscribe(propertyObject.handler,
546 * @param {Function} handler The handler function to use subscribe to
563 property.event.subscribe(handler, obj, override);
582 * @param {Function} handler The handler function to use subscribe to
1379 this.renderEvent.subscribe(this.cfg.fireQueue, this.cfg, true);
1474 Module.textResizeEvent.subscribe(this.onDomResize,
2234 this.showEvent.subscribe(this.showMacGeckoScrollbars,
2242 this.hideEvent.subscribe(this.hideMacGeckoScrollbars,
2608 ei.animateInCompleteEvent.subscribe(
2665 h.animateOutCompleteEvent.subscribe(
[all...]
/forgerock/openam/openam-server-only/src/main/webapp/assets/lib/yui/container/
H A Dcontainer-debug.js188 propertyObject.event.subscribe(propertyObject.handler,
552 * @param {Function} handler The handler function to use subscribe to
569 property.event.subscribe(handler, obj, override);
588 * @param {Function} handler The handler function to use subscribe to
1387 this.renderEvent.subscribe(this.cfg.fireQueue, this.cfg, true);
1482 Module.textResizeEvent.subscribe(this.onDomResize,
2244 this.showEvent.subscribe(this.showMacGeckoScrollbars,
2252 this.hideEvent.subscribe(this.hideMacGeckoScrollbars,
2618 ei.animateInCompleteEvent.subscribe(
2675 h.animateOutCompleteEvent.subscribe(
[all...]
H A Dcontainer-min.js9 if(!owner){}};var Lang=YAHOO.lang,CustomEvent=YAHOO.util.CustomEvent,Config=YAHOO.util.Config;Config.CONFIG_CHANGED_EVENT="configChanged";Config.BOOLEAN_TYPE="boolean";Config.prototype={owner:null,queueInProgress:false,config:null,initialConfig:null,eventQueue:null,configChangedEvent:null,init:function(owner){this.owner=owner;this.configChangedEvent=this.createEvent(Config.CONFIG_CHANGED_EVENT);this.configChangedEvent.signature=CustomEvent.LIST;this.queueInProgress=false;this.config={};this.initialConfig={};this.eventQueue=[];},checkBoolean:function(val){return(typeof val==Config.BOOLEAN_TYPE);},checkNumber:function(val){return(!isNaN(val));},fireEvent:function(key,value){var property=this.config[key];if(property&&property.event){property.event.fire(value);}},addProperty:function(key,propertyObject){key=key.toLowerCase();this.config[key]=propertyObject;propertyObject.event=this.createEvent(key,{scope:this.owner});propertyObject.event.signature=CustomEvent.LIST;propertyObject.key=key;if(propertyObject.handler){propertyObject.event.subscribe(propertyObject.handler,this.owner);}
19 this.queueInProgress=false;this.eventQueue=[];},subscribeToConfigEvent:function(key,handler,obj,override){var property=this.config[key.toLowerCase()];if(property&&property.event){if(!Config.alreadySubscribed(property.event,handler,obj)){property.event.subscribe(handler,obj,override);}
41 if(!Config.alreadySubscribed(this.renderEvent,this.cfg.fireQueue,this.cfg)){this.renderEvent.subscribe(this.cfg.fireQueue,this.cfg,true);}
47 if(oIFrame&&oIFrame.contentWindow){Module.textResizeEvent.subscribe(this.onDomResize,this,true);if(!Module.textResizeInitialized){if(!Event.on(oIFrame.contentWindow,"resize",fireTextResize)){Event.on(oIFrame,"resize",fireTextResize);}
65 if(this.platform=="mac"&&YAHOO.env.ua.gecko){if(!Config.alreadySubscribed(this.showEvent,this.showMacGeckoScrollbars,this)){this.showEvent.subscribe(this.showMacGeckoScrollbars,this,true);}
66 if(!Config.alreadySubscribed(this.hideEvent,this.hideMacGeckoScrollbars,this)){this.hideEvent.subscribe(this.hideMacGeckoScrollbars,this,true);}}
72 if(effect){if(visible){if(currentVis!="visible"||currentVis===""){this.beforeShowEvent.fire();nEffectInstances=effectInstances.length;for(j=0;j<nEffectInstances;j++){ei=effectInstances[j];if(j===0&&!alreadySubscribed(ei.animateInCompleteEvent,this.showEvent.fire,this.showEvent)){ei.animateInCompleteEvent.subscribe(this.showEvent.fire,this.showEvent,true);}
74 if(effect){if(currentVis=="visible"){this.beforeHideEvent.fire();nEffectInstances=effectInstances.length;for(k=0;k<nEffectInstances;k++){h=effectInstances[k];if(k===0&&!alreadySubscribed(h.animateOutCompleteEvent,this.hideEvent.fire,this.hideEvent)){h.animateOutCompleteEvent.subscribe(this.hideEvent.fire,this.hideEvent,true);}
75 h.animateOut();}}else if(currentVis===""){Dom.setStyle(this.element,"visibility","hidden");}}else{if(currentVis=="visible"||currentVis===""){this.beforeHideEvent.fire();Dom.setStyle(this.element,"visibility","hidden");this.hideEvent.fire();}}}},doCenterOnDOMEvent:function(){if(this.cfg.getProperty("visible")){this.center();}},configFixedCenter:function(type,args,obj){var val=args[0],alreadySubscribed=Config.alreadySubscribed,windowResizeEvent=Overlay.windowResizeEvent,windowScrollEvent=Overlay.windowScrollEvent;if(val){this.center();if(!alreadySubscribed(this.beforeShowEvent,this.center,this)){this.beforeShowEvent.subscribe(this.center);}
76 if(!alreadySubscribed(windowResizeEvent,this.doCenterOnDOMEvent,this)){windowResizeEvent.subscribe(thi
[all...]
H A Dcontainer.js185 propertyObject.event.subscribe(propertyObject.handler,
546 * @param {Function} handler The handler function to use subscribe to
563 property.event.subscribe(handler, obj, override);
582 * @param {Function} handler The handler function to use subscribe to
1379 this.renderEvent.subscribe(this.cfg.fireQueue, this.cfg, true);
1474 Module.textResizeEvent.subscribe(this.onDomResize,
2234 this.showEvent.subscribe(this.showMacGeckoScrollbars,
2242 this.hideEvent.subscribe(this.hideMacGeckoScrollbars,
2608 ei.animateInCompleteEvent.subscribe(
2665 h.animateOutCompleteEvent.subscribe(
[all...]

Completed in 106 milliseconds

123456