root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Remove EventBus

This commit is contained in:
Rossen Stoyanchev 2013-06-13 01:36:55 -04:00
parent 3e0aac08dc
commit 3712f73f38
4 changed files with 0 additions and 164 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
spring-websocket/src/main/java/org/springframework/web/messaging/event/EventBus.java
View File

@ -1,30 +0,0 @@
/*
* Copyright 2002-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.web.messaging.event;
/**
*
*/
public interface EventBus {
void send(String key, Object data);
EventRegistration registerConsumer(String key, EventConsumer consumer);
}

29
spring-websocket/src/main/java/org/springframework/web/messaging/event/EventConsumer.java
View File

@ -1,29 +0,0 @@
/*
* Copyright 2002-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.web.messaging.event;
/**
*
*/
public interface EventConsumer<T> {
void accept(T data);
}

29
spring-websocket/src/main/java/org/springframework/web/messaging/event/EventRegistration.java
View File

@ -1,29 +0,0 @@
/*
* Copyright 2002-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.web.messaging.event;
/**
*
*/
public interface EventRegistration {
String getRegistrationKey();
void cancel();
}

76
spring-websocket/src/main/java/org/springframework/web/messaging/event/ReactorEventBus.java
View File

@ -1,76 +0,0 @@
/*
* Copyright 2002-2013 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.web.messaging.event;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import reactor.core.Reactor;
import reactor.fn.Consumer;
import reactor.fn.Event;
import reactor.fn.registry.Registration;
import reactor.fn.selector.ObjectSelector;
/**
*
*/
public class ReactorEventBus implements EventBus {
private static Log logger = LogFactory.getLog(ReactorEventBus.class);
private final Reactor reactor;
public ReactorEventBus(Reactor reactor) {
this.reactor = reactor;
}
@Override
public void send(String key, Object data) {
if (logger.isTraceEnabled()) {
logger.trace("Sending notification key=" + key + ", data=" + data);
}
this.reactor.notify(key, Event.wrap(data));
}
@Override
public EventRegistration registerConsumer(final String key, final EventConsumer consumer) {
ObjectSelector<String> selector = new ObjectSelector<String>(key);
final Registration<Consumer<Event<Object>>> registration = this.reactor.on(selector,
new Consumer<Event<Object>>() {
@Override
public void accept(Event<Object> event) {
consumer.accept(event.getData());
}
});
return new EventRegistration() {
@Override
public String getRegistrationKey() {
return key;
}
@Override
public void cancel() {
registration.cancel();
}
};
}
}