Updated author tags
This commit is contained in:
parent
9946c74d49
commit
7cc484f8bc
|
@ -126,10 +126,6 @@ Message publication:
|
|||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
<h2>Installation</h2>
|
||||
The MessageBus is available from the Maven Central Repository using the following coordinates:
|
||||
```
|
||||
|
|
|
@ -31,7 +31,7 @@ import dorkbox.messagebus.synchrony.Synchrony;
|
|||
* The base class for all message bus implementations with support for asynchronous message dispatch.
|
||||
*
|
||||
* See this post for insight on how it operates: http://psy-lob-saw.blogspot.com/2012/12/atomiclazyset-is-performance-win-for.html
|
||||
* tldr; we use single-writer-principle + lazySet/get
|
||||
* TLDR: we use single-writer-principle + lazySet/get for major performance
|
||||
*
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/2/15
|
||||
|
|
|
@ -32,6 +32,8 @@ import java.lang.annotation.*;
|
|||
* depending on which reference type (@see References) is set
|
||||
*
|
||||
* @author bennidi
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/6/16
|
||||
*/
|
||||
@Retention(value = RetentionPolicy.RUNTIME)
|
||||
@Target(value = {ElementType.TYPE, ElementType.ANNOTATION_TYPE})
|
||||
|
|
|
@ -25,6 +25,8 @@ package dorkbox.messagebus.annotations;
|
|||
/**
|
||||
* @author bennidi
|
||||
* Date: 3/29/13
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/6/16
|
||||
*/
|
||||
public enum References {
|
||||
/** This is the default */
|
||||
|
|
|
@ -20,7 +20,6 @@ import com.esotericsoftware.kryo.util.IdentityMap;
|
|||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
|
||||
|
||||
/**
|
||||
* Simple tree structure that is a map that contains a chain of keys to publish to a value.
|
||||
*
|
||||
|
@ -30,7 +29,6 @@ import java.util.concurrent.atomic.AtomicReference;
|
|||
*
|
||||
* This data structure is used to keep track of multi-messages - where there is more that one parameter for publish().
|
||||
*
|
||||
*
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/2/15
|
||||
*/
|
||||
|
|
|
@ -15,6 +15,11 @@
|
|||
*/
|
||||
package dorkbox.messagebus.dispatch;
|
||||
|
||||
|
||||
/**
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/2/15
|
||||
*/
|
||||
public interface Dispatch {
|
||||
void publish(Object message1);
|
||||
void publish(Object message1, Object message2);
|
||||
|
|
|
@ -24,6 +24,9 @@ import dorkbox.messagebus.subscription.SubscriptionManager;
|
|||
* By default, it is the calling thread that has to get the subscriptions, which the sync/async logic then uses.
|
||||
*
|
||||
* The exception to this rule is when checking/calling DeadMessage publication.
|
||||
*
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/2/15
|
||||
*/
|
||||
@SuppressWarnings("Duplicates")
|
||||
public
|
||||
|
|
|
@ -20,6 +20,10 @@ import dorkbox.messagebus.error.ErrorHandler;
|
|||
import dorkbox.messagebus.subscription.Subscription;
|
||||
import dorkbox.messagebus.subscription.SubscriptionManager;
|
||||
|
||||
/**
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/2/15
|
||||
*/
|
||||
@SuppressWarnings("Duplicates")
|
||||
public
|
||||
class DispatchExactWithSuperTypes implements Dispatch {
|
||||
|
|
|
@ -18,6 +18,9 @@ package dorkbox.messagebus.error;
|
|||
import java.util.ArrayDeque;
|
||||
import java.util.Collection;
|
||||
|
||||
/**
|
||||
* @author bennidi
|
||||
*/
|
||||
@SuppressWarnings("Duplicates")
|
||||
public final
|
||||
class ErrorHandler {
|
||||
|
|
|
@ -47,7 +47,6 @@ import java.util.Arrays;
|
|||
*
|
||||
* @author bennidi
|
||||
* Date: 2/22/12
|
||||
* Time: 4:59 PM
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/2/15
|
||||
*/
|
||||
|
|
|
@ -19,6 +19,11 @@ package dorkbox.messagebus.subscription;
|
|||
// not thread-safe!!!
|
||||
//
|
||||
|
||||
|
||||
/**
|
||||
* @author bennidi
|
||||
* @author dorkbox, llc Date: 2/3/16
|
||||
*/
|
||||
public
|
||||
class Entry<T> {
|
||||
private final T value;
|
||||
|
|
|
@ -19,6 +19,10 @@ import dorkbox.messagebus.common.MessageHandler;
|
|||
import dorkbox.messagebus.subscription.Subscription;
|
||||
import dorkbox.messagebus.subscription.SubscriptionFactory;
|
||||
|
||||
/**
|
||||
* @author dorkbox, llc
|
||||
* Date: 2/3/16
|
||||
*/
|
||||
public
|
||||
class ReflectionFactory implements SubscriptionFactory {
|
||||
|
||||
|
|
|
@ -23,6 +23,10 @@ import java.util.ArrayList;
|
|||
import java.util.Iterator;
|
||||
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
|
||||
|
||||
/**
|
||||
* @author dorkbox
|
||||
* Date: 4/1/15
|
||||
*/
|
||||
public final
|
||||
class ClassUtils {
|
||||
|
||||
|
|
Loading…
Reference in New Issue
Block a user