dorkbox/MessageBus
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #13 from KenFromNN/master

Browse Source 
Organized imports to reduce number of warnings in some IDEs/CodeCheckers
This commit is contained in:
bennidi 2012-12-15 07:17:49 -08:00
commit 39ec9019c2
14 changed files with 38 additions and 51 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/mbassy/MBassador.java
View File

@ -1,9 +1,9 @@
package org.mbassy; package org.mbassy;
import org.mbassy.subscription.*; import java.util.Collection;
import java.util.*; import org.mbassy.subscription.Subscription;
import java.util.concurrent.*; import org.mbassy.subscription.SubscriptionDeliveryRequest;
public class MBassador<T> extends AbstractMessageBus<T, SyncAsyncPostCommand<T>>{ public class MBassador<T> extends AbstractMessageBus<T, SyncAsyncPostCommand<T>>{

1
src/main/java/org/mbassy/common/ConcurrentSet.java
View File

@ -3,7 +3,6 @@ package org.mbassy.common;
import java.lang.ref.WeakReference; import java.lang.ref.WeakReference;
import java.util.Iterator; import java.util.Iterator;
import java.util.Set;
import java.util.WeakHashMap; import java.util.WeakHashMap;
/** /**

1
src/main/java/org/mbassy/common/ReflectionUtils.java
View File

@ -1,7 +1,6 @@
package org.mbassy.common; package org.mbassy.common;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.Collection; import java.util.Collection;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;

5
src/main/java/org/mbassy/dispatch/AsynchronousHandlerInvocation.java
View File

@ -1,11 +1,6 @@
package org.mbassy.dispatch; package org.mbassy.dispatch;
import org.mbassy.IPublicationErrorHandler;
import org.mbassy.PublicationError;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import java.util.Collection;
/** /**
* This invocation will schedule the wrapped (decorated) invocation to be executed asynchronously * This invocation will schedule the wrapped (decorated) invocation to be executed asynchronously

1
src/main/java/org/mbassy/dispatch/IMessageDispatcher.java
View File

@ -1,7 +1,6 @@
package org.mbassy.dispatch; package org.mbassy.dispatch;
import org.mbassy.common.ConcurrentSet; import org.mbassy.common.ConcurrentSet;
import org.mbassy.subscription.Subscription;
/** /**
* A message dispatcher provides the functionality to deliver a single message * A message dispatcher provides the functionality to deliver a single message

5
src/main/java/org/mbassy/dispatch/MessageDispatcher.java
View File

@ -1,10 +1,9 @@
package org.mbassy.dispatch; package org.mbassy.dispatch;
import org.mbassy.common.ConcurrentSet;
import org.mbassy.subscription.Subscription;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import org.mbassy.common.ConcurrentSet;
/** /**
* Standard implementation for direct, unfiltered message delivery. * Standard implementation for direct, unfiltered message delivery.
* *

1
src/main/java/org/mbassy/listener/MetadataReader.java
View File

@ -1,6 +1,5 @@
package org.mbassy.listener; package org.mbassy.listener;
import com.sun.xml.internal.messaging.saaj.soap.Envelope;
import org.mbassy.common.IPredicate; import org.mbassy.common.IPredicate;
import org.mbassy.common.ReflectionUtils; import org.mbassy.common.ReflectionUtils;
import org.mbassy.subscription.MessageEnvelope; import org.mbassy.subscription.MessageEnvelope;

16
src/main/java/org/mbassy/subscription/Subscription.java
View File

@ -1,20 +1,12 @@
package org.mbassy.subscription; package org.mbassy.subscription;
import org.mbassy.IMessageBus;
import org.mbassy.IPublicationErrorHandler;
import org.mbassy.common.ConcurrentSet;
import org.mbassy.PublicationError;
import org.mbassy.dispatch.IMessageDispatcher;
import org.mbassy.dispatch.MessagingContext;
import org.mbassy.listener.MessageHandlerMetadata;
import javax.xml.ws.handler.MessageContext;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.Collection;
import java.util.Comparator; import java.util.Comparator;
import java.util.UUID; import java.util.UUID;
import org.mbassy.common.ConcurrentSet;
import org.mbassy.dispatch.IMessageDispatcher;
import org.mbassy.dispatch.MessagingContext;
/** /**
* A subscription is a thread safe container for objects that contain message handlers * A subscription is a thread safe container for objects that contain message handlers
*/ */

1
src/main/java/org/mbassy/subscription/SubscriptionDeliveryRequest.java
View File

@ -1,7 +1,6 @@
package org.mbassy.subscription; package org.mbassy.subscription;
import java.util.Collection; import java.util.Collection;
import java.util.LinkedList;
/** /**
* @author bennidi * @author bennidi

14
src/main/java/org/mbassy/subscription/SubscriptionFactory.java
View File

@ -1,11 +1,13 @@
package org.mbassy.subscription; package org.mbassy.subscription;
import org.mbassy.IMessageBus; import org.mbassy.dispatch.AsynchronousHandlerInvocation;
import org.mbassy.IPublicationErrorHandler; import org.mbassy.dispatch.EnvelopedMessageDispatcher;
import org.mbassy.dispatch.*; import org.mbassy.dispatch.FilteredMessageDispatcher;
import org.mbassy.listener.MessageHandlerMetadata; import org.mbassy.dispatch.IHandlerInvocation;
import org.mbassy.dispatch.IMessageDispatcher;
import java.util.Collection; import org.mbassy.dispatch.MessageDispatcher;
import org.mbassy.dispatch.MessagingContext;
import org.mbassy.dispatch.ReflectiveHandlerInvocation;
/** /**
* Created with IntelliJ IDEA. * Created with IntelliJ IDEA.

8
src/test/java/org/mbassy/FilterTest.java
View File

@ -1,15 +1,15 @@
package org.mbassy; package org.mbassy;
import java.util.List;
import org.junit.Test; import org.junit.Test;
import org.mbassy.events.SubTestEvent; import org.mbassy.events.SubTestEvent;
import org.mbassy.events.TestEvent; import org.mbassy.events.TestEvent;
import org.mbassy.listener.Filter; import org.mbassy.listener.Filter;
import org.mbassy.listener.Filters; import org.mbassy.listener.Filters;
import org.mbassy.listener.IMessageFilter;
import org.mbassy.listener.Listener; import org.mbassy.listener.Listener;
import org.mbassy.listeners.*; import org.mbassy.listeners.ListenerFactory;
import org.mbassy.listeners.NonListeningBean;
import java.util.List;
/** /**
* Testing of filter functionality * Testing of filter functionality

21
src/test/java/org/mbassy/MBassadorTest.java
View File

@ -1,19 +1,22 @@
package org.mbassy; package org.mbassy;
import org.junit.Before;
import org.junit.Test;
import org.mbassy.events.SubTestEvent;
import org.mbassy.events.TestEvent;
import org.mbassy.events.TestEvent2;
import org.mbassy.listeners.*;
import org.mbassy.subscription.Subscription;
import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import org.junit.Test;
import org.mbassy.events.SubTestEvent;
import org.mbassy.events.TestEvent;
import org.mbassy.events.TestEvent2;
import org.mbassy.listeners.EventingTestBean;
import org.mbassy.listeners.EventingTestBean2;
import org.mbassy.listeners.EventingTestBean3;
import org.mbassy.listeners.ListenerFactory;
import org.mbassy.listeners.MultiEventHandler;
import org.mbassy.listeners.NonListeningBean;
import org.mbassy.subscription.Subscription;
/** /**
* Test synchronous and asynchronous dispatch in single and multi-threaded scenario. * Test synchronous and asynchronous dispatch in single and multi-threaded scenario.
* *

7
src/test/java/org/mbassy/listeners/MultiEventHandler.java
View File

@ -1,9 +1,12 @@
package org.mbassy.listeners; package org.mbassy.listeners;
import org.mbassy.events.SubTestEvent;
import org.mbassy.events.TestEvent; import org.mbassy.events.TestEvent;
import org.mbassy.events.TestEvent2; import org.mbassy.events.TestEvent2;
import org.mbassy.listener.*; import org.mbassy.listener.Enveloped;
import org.mbassy.listener.Filter;
import org.mbassy.listener.Filters;
import org.mbassy.listener.Listener;
import org.mbassy.listener.Mode;
import org.mbassy.subscription.MessageEnvelope; import org.mbassy.subscription.MessageEnvelope;
/** /**

2
src/test/java/org/mbassy/listeners/NonListeningBean.java
View File

@ -2,8 +2,6 @@ package org.mbassy.listeners;
import org.mbassy.events.SubTestEvent; import org.mbassy.events.SubTestEvent;
import org.mbassy.events.TestEvent; import org.mbassy.events.TestEvent;
import org.mbassy.listener.Listener;
import org.mbassy.listener.Mode;
/** /**
* This bean overrides all the handlers defined in its superclass. Since it does not specify any annotations * This bean overrides all the handlers defined in its superclass. Since it does not specify any annotations