Compare commits
2 Commits
75621bd9ae
...
8fd2c427a4
Author | SHA1 | Date | |
---|---|---|---|
|
8fd2c427a4 | ||
|
41a4b28d0c |
24
src9/dorkbox/messageBus/EmptyClass.java
Normal file
24
src9/dorkbox/messageBus/EmptyClass.java
Normal file
@ -0,0 +1,24 @@
|
||||
/*
|
||||
* Copyright 2023 dorkbox, llc
|
||||
*
|
||||
* 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 dorkbox.messageBus;
|
||||
|
||||
/**
|
||||
* Required for intellij to not complain regarding `module-info` for a multi-release jar.
|
||||
* This file is completely ignored by the gradle build process
|
||||
*/
|
||||
public
|
||||
class EmptyClass {}
|
17
src9/module-info.java
Normal file
17
src9/module-info.java
Normal file
@ -0,0 +1,17 @@
|
||||
module dorkbox.MessageBus {
|
||||
exports dorkbox.messageBus;
|
||||
|
||||
requires transitive dorkbox.classUtils;
|
||||
requires transitive dorkbox.collections;
|
||||
requires transitive dorkbox.updates;
|
||||
requires transitive dorkbox.utilities;
|
||||
|
||||
requires transitive com.conversantmedia.disruptor;
|
||||
requires transitive com.lmax.disruptor;
|
||||
requires transitive org.objectweb.asm;
|
||||
requires transitive com.esotericsoftware.reflectasm;
|
||||
|
||||
requires transitive org.slf4j;
|
||||
|
||||
requires transitive kotlin.stdlib;
|
||||
}
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.Suite;
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
@ -29,7 +29,7 @@ import org.junit.Test;
|
||||
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
|
||||
/**
|
||||
* NOTE: the async publication is truly async. There is no guaranteed order to when it's handled.
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
@ -30,13 +30,13 @@ import org.junit.Test;
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.messageBus.error.DeadMessage;
|
||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.util.messagebus.common.TestUtil;
|
||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.util.messagebus.listeners.ObjectListener;
|
||||
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.messagebus.common.ListenerFactory;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.TestUtil;
|
||||
import dorkbox.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.messagebus.listeners.ObjectListener;
|
||||
|
||||
/**
|
||||
* Verify correct behaviour in case of message publications that do not have any matching subscriptions
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
@ -29,18 +29,18 @@ import org.junit.Test;
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
||||
import dorkbox.messageBus.error.PublicationError;
|
||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.util.messagebus.common.MessageManager;
|
||||
import dorkbox.util.messagebus.common.TestUtil;
|
||||
import dorkbox.util.messagebus.listeners.ExceptionThrowingListener;
|
||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.Listeners;
|
||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
||||
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.messagebus.common.ListenerFactory;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.MessageManager;
|
||||
import dorkbox.messagebus.common.TestUtil;
|
||||
import dorkbox.messagebus.listeners.ExceptionThrowingListener;
|
||||
import dorkbox.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.messagebus.listeners.Listeners;
|
||||
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.messagebus.messages.MessageTypes;
|
||||
import dorkbox.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.messagebus.messages.StandardMessage;
|
||||
|
||||
/**
|
||||
* Test synchronous and asynchronous dispatch in single and multi-threaded scenario.
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.io.BufferedReader;
|
||||
import java.util.Arrays;
|
||||
@ -33,7 +33,7 @@ import org.junit.Test;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.messageBus.common.MessageHandler;
|
||||
import dorkbox.util.messagebus.common.AssertSupport;
|
||||
import dorkbox.messagebus.common.AssertSupport;
|
||||
|
||||
/**
|
||||
*
|
@ -20,13 +20,13 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
|
||||
/**
|
||||
* Very simple test to verify dispatch to correct message handler
|
@ -1,7 +1,7 @@
|
||||
/*
|
||||
* Copyright 2015 dorkbox, llc
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
@ -11,7 +11,7 @@ import dorkbox.messageBus.DispatchMode;
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.SubscriptionMode;
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
|
||||
/**
|
||||
* @author dorkbox, llc
|
@ -13,13 +13,13 @@
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import dorkbox.messageBus.common.ClassTree;
|
||||
import dorkbox.messageBus.common.MultiClass;
|
||||
import dorkbox.util.messagebus.common.AssertSupport;
|
||||
import dorkbox.messagebus.common.AssertSupport;
|
||||
|
||||
public class MultiTreeTest extends AssertSupport {
|
||||
|
@ -20,32 +20,32 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import dorkbox.messageBus.SubscriptionMode;
|
||||
import dorkbox.messageBus.subscription.SubscriptionManager;
|
||||
import dorkbox.util.messagebus.common.AssertSupport;
|
||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
||||
import dorkbox.util.messagebus.common.SubscriptionValidator;
|
||||
import dorkbox.util.messagebus.common.TestUtil;
|
||||
import dorkbox.util.messagebus.listeners.AbstractMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.ICountableListener;
|
||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.IMultipartMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.util.messagebus.listeners.MultipartMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.Overloading;
|
||||
import dorkbox.util.messagebus.listeners.StandardMessageListener;
|
||||
import dorkbox.util.messagebus.messages.AbstractMessage;
|
||||
import dorkbox.util.messagebus.messages.ICountable;
|
||||
import dorkbox.util.messagebus.messages.IMessage;
|
||||
import dorkbox.util.messagebus.messages.IMultipartMessage;
|
||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
||||
import dorkbox.messagebus.messages.IMessage;
|
||||
import dorkbox.messagebus.common.AssertSupport;
|
||||
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.messagebus.common.ListenerFactory;
|
||||
import dorkbox.messagebus.common.SubscriptionValidator;
|
||||
import dorkbox.messagebus.common.TestUtil;
|
||||
import dorkbox.messagebus.listeners.AbstractMessageListener;
|
||||
import dorkbox.messagebus.listeners.ICountableListener;
|
||||
import dorkbox.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.messagebus.listeners.IMultipartMessageListener;
|
||||
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.messagebus.listeners.MultipartMessageListener;
|
||||
import dorkbox.messagebus.listeners.Overloading;
|
||||
import dorkbox.messagebus.listeners.StandardMessageListener;
|
||||
import dorkbox.messagebus.messages.AbstractMessage;
|
||||
import dorkbox.messagebus.messages.ICountable;
|
||||
import dorkbox.messagebus.messages.IMultipartMessage;
|
||||
import dorkbox.messagebus.messages.MessageTypes;
|
||||
import dorkbox.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.messagebus.messages.StandardMessage;
|
||||
|
||||
/**
|
||||
* Test the subscriptions as generated and organized by the subscription manager. Tests use different sets of listeners
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
@ -30,16 +30,16 @@ import org.junit.Test;
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
||||
import dorkbox.messageBus.error.PublicationError;
|
||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.util.messagebus.common.TestUtil;
|
||||
import dorkbox.util.messagebus.listeners.ExceptionThrowingListener;
|
||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
||||
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||
import dorkbox.messagebus.common.ListenerFactory;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.TestUtil;
|
||||
import dorkbox.messagebus.listeners.ExceptionThrowingListener;
|
||||
import dorkbox.messagebus.listeners.IMessageListener;
|
||||
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||
import dorkbox.messagebus.messages.MessageTypes;
|
||||
import dorkbox.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.messagebus.messages.StandardMessage;
|
||||
|
||||
/**
|
||||
* Test synchronous and asynchronous dispatch in single and multi-threaded scenario.
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus;
|
||||
package dorkbox.messagebus;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
@ -30,7 +30,7 @@ import org.junit.Test;
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.messageBus.annotations.Synchronized;
|
||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
||||
import dorkbox.messagebus.common.MessageBusTest;
|
||||
|
||||
/**
|
||||
* Todo: Add javadoc
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import org.junit.After;
|
||||
import org.junit.Assert;
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
@ -20,14 +20,14 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import org.junit.Before;
|
||||
|
||||
import dorkbox.messageBus.MessageBus;
|
||||
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
||||
import dorkbox.messageBus.error.PublicationError;
|
||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
||||
import dorkbox.messagebus.messages.MessageTypes;
|
||||
|
||||
/**
|
||||
* A base test that provides a factory for message bus that makes tests fail if any
|
@ -20,9 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import dorkbox.messagebus.messages.IMessage;
|
||||
|
||||
import dorkbox.util.messagebus.messages.IMessage;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import java.util.ArrayDeque;
|
||||
import java.util.Arrays;
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.common;
|
||||
package dorkbox.messagebus.common;
|
||||
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.AbstractMessage;
|
||||
import dorkbox.messagebus.messages.AbstractMessage;
|
||||
|
||||
/**
|
||||
* @author bennidi
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
||||
import dorkbox.messagebus.messages.StandardMessage;
|
||||
|
||||
/**
|
||||
* @author bennidi
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.ICountable;
|
||||
import dorkbox.messagebus.messages.ICountable;
|
||||
|
||||
/**
|
||||
*
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.IMessage;
|
||||
import dorkbox.messagebus.messages.IMessage;
|
||||
|
||||
/**
|
||||
*
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.IMultipartMessage;
|
||||
import dorkbox.messagebus.messages.IMultipartMessage;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Collection;
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
||||
import dorkbox.messagebus.messages.MessageTypes;
|
||||
|
||||
/**
|
||||
* @author bennidi
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
||||
import dorkbox.messagebus.messages.MultipartMessage;
|
||||
|
||||
/**
|
||||
* @author bennidi
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.LinkedList;
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.AbstractMessage;
|
||||
import dorkbox.messagebus.messages.AbstractMessage;
|
||||
|
||||
/**
|
||||
* Some handlers and message types to test correct functioning of overloaded message handlers
|
@ -20,10 +20,10 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.listeners;
|
||||
package dorkbox.messagebus.listeners;
|
||||
|
||||
import dorkbox.messageBus.annotations.Subscribe;
|
||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
||||
import dorkbox.messagebus.messages.StandardMessage;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
* Interface analogous to IMessage. Exists to test more complex class/interface hierarchies
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
* @author bennidi
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
/**
|
||||
*
|
@ -20,7 +20,7 @@
|
||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
*/
|
||||
package dorkbox.util.messagebus.messages;
|
||||
package dorkbox.messagebus.messages;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
Loading…
Reference in New Issue
Block a user