Compare commits
2 Commits
75621bd9ae
...
8fd2c427a4
Author | SHA1 | Date |
---|---|---|
Robinson | 8fd2c427a4 | |
Robinson | 41a4b28d0c |
|
@ -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 {}
|
|
@ -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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.runner.RunWith;
|
||||||
import org.junit.runners.Suite;
|
import org.junit.runners.Suite;
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.LinkedList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
@ -29,7 +29,7 @@ import org.junit.Test;
|
||||||
|
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.annotations.Subscribe;
|
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.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
|
@ -30,13 +30,13 @@ import org.junit.Test;
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.annotations.Subscribe;
|
import dorkbox.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.messageBus.error.DeadMessage;
|
import dorkbox.messageBus.error.DeadMessage;
|
||||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
import dorkbox.messagebus.common.ListenerFactory;
|
||||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
import dorkbox.messagebus.common.MessageBusTest;
|
||||||
import dorkbox.util.messagebus.common.TestUtil;
|
import dorkbox.messagebus.common.TestUtil;
|
||||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
import dorkbox.messagebus.listeners.IMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||||
import dorkbox.util.messagebus.listeners.ObjectListener;
|
import dorkbox.messagebus.listeners.ObjectListener;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Verify correct behaviour in case of message publications that do not have any matching subscriptions
|
* Verify correct behaviour in case of message publications that do not have any matching subscriptions
|
||||||
|
@ -44,7 +44,7 @@ import dorkbox.util.messagebus.listeners.ObjectListener;
|
||||||
* @author bennidi
|
* @author bennidi
|
||||||
* Date: 1/18/13
|
* Date: 1/18/13
|
||||||
*/
|
*/
|
||||||
public class DeadMessageTest extends MessageBusTest{
|
public class DeadMessageTest extends MessageBusTest {
|
||||||
|
|
||||||
private static final AtomicInteger deadMessages = new AtomicInteger(0);
|
private static final AtomicInteger deadMessages = new AtomicInteger(0);
|
||||||
|
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
|
@ -29,18 +29,18 @@ import org.junit.Test;
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
||||||
import dorkbox.messageBus.error.PublicationError;
|
import dorkbox.messageBus.error.PublicationError;
|
||||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
import dorkbox.messagebus.common.ListenerFactory;
|
||||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
import dorkbox.messagebus.common.MessageBusTest;
|
||||||
import dorkbox.util.messagebus.common.MessageManager;
|
import dorkbox.messagebus.common.MessageManager;
|
||||||
import dorkbox.util.messagebus.common.TestUtil;
|
import dorkbox.messagebus.common.TestUtil;
|
||||||
import dorkbox.util.messagebus.listeners.ExceptionThrowingListener;
|
import dorkbox.messagebus.listeners.ExceptionThrowingListener;
|
||||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
import dorkbox.messagebus.listeners.IMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.Listeners;
|
import dorkbox.messagebus.listeners.Listeners;
|
||||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
import dorkbox.messagebus.messages.MessageTypes;
|
||||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
import dorkbox.messagebus.messages.MultipartMessage;
|
||||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
import dorkbox.messagebus.messages.StandardMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Test synchronous and asynchronous dispatch in single and multi-threaded scenario.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.io.BufferedReader;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
|
@ -33,7 +33,7 @@ import org.junit.Test;
|
||||||
|
|
||||||
import dorkbox.messageBus.annotations.Subscribe;
|
import dorkbox.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.messageBus.common.MessageHandler;
|
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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
*/
|
*/
|
||||||
package dorkbox.util.messagebus;
|
package dorkbox.messagebus;
|
||||||
|
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.annotations.Subscribe;
|
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
|
* Very simple test to verify dispatch to correct message handler
|
||||||
|
@ -34,7 +34,7 @@ import dorkbox.util.messagebus.common.MessageBusTest;
|
||||||
* @author bennidi
|
* @author bennidi
|
||||||
* Date: 1/17/13
|
* Date: 1/17/13
|
||||||
*/
|
*/
|
||||||
public class MethodDispatchTest extends MessageBusTest{
|
public class MethodDispatchTest extends MessageBusTest {
|
||||||
|
|
||||||
private boolean listener1Called = false;
|
private boolean listener1Called = false;
|
||||||
private boolean listener2Called = false;
|
private boolean listener2Called = false;
|
|
@ -1,7 +1,7 @@
|
||||||
/*
|
/*
|
||||||
* Copyright 2015 dorkbox, llc
|
* Copyright 2015 dorkbox, llc
|
||||||
*/
|
*/
|
||||||
package dorkbox.util.messagebus;
|
package dorkbox.messagebus;
|
||||||
|
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
|
@ -11,7 +11,7 @@ import dorkbox.messageBus.DispatchMode;
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.SubscriptionMode;
|
import dorkbox.messageBus.SubscriptionMode;
|
||||||
import dorkbox.messageBus.annotations.Subscribe;
|
import dorkbox.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
import dorkbox.messagebus.common.MessageBusTest;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author dorkbox, llc
|
* @author dorkbox, llc
|
|
@ -13,13 +13,13 @@
|
||||||
* See the License for the specific language governing permissions and
|
* See the License for the specific language governing permissions and
|
||||||
* limitations under the License.
|
* limitations under the License.
|
||||||
*/
|
*/
|
||||||
package dorkbox.util.messagebus;
|
package dorkbox.messagebus;
|
||||||
|
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
import dorkbox.messageBus.common.ClassTree;
|
import dorkbox.messageBus.common.ClassTree;
|
||||||
import dorkbox.messageBus.common.MultiClass;
|
import dorkbox.messageBus.common.MultiClass;
|
||||||
import dorkbox.util.messagebus.common.AssertSupport;
|
import dorkbox.messagebus.common.AssertSupport;
|
||||||
|
|
||||||
public class MultiTreeTest extends AssertSupport {
|
public class MultiTreeTest extends AssertSupport {
|
||||||
|
|
|
@ -20,32 +20,32 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
*/
|
*/
|
||||||
package dorkbox.util.messagebus;
|
package dorkbox.messagebus;
|
||||||
|
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
import dorkbox.messageBus.SubscriptionMode;
|
import dorkbox.messageBus.SubscriptionMode;
|
||||||
import dorkbox.messageBus.subscription.SubscriptionManager;
|
import dorkbox.messageBus.subscription.SubscriptionManager;
|
||||||
import dorkbox.util.messagebus.common.AssertSupport;
|
import dorkbox.messagebus.messages.IMessage;
|
||||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
import dorkbox.messagebus.common.AssertSupport;
|
||||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||||
import dorkbox.util.messagebus.common.SubscriptionValidator;
|
import dorkbox.messagebus.common.ListenerFactory;
|
||||||
import dorkbox.util.messagebus.common.TestUtil;
|
import dorkbox.messagebus.common.SubscriptionValidator;
|
||||||
import dorkbox.util.messagebus.listeners.AbstractMessageListener;
|
import dorkbox.messagebus.common.TestUtil;
|
||||||
import dorkbox.util.messagebus.listeners.ICountableListener;
|
import dorkbox.messagebus.listeners.AbstractMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
import dorkbox.messagebus.listeners.ICountableListener;
|
||||||
import dorkbox.util.messagebus.listeners.IMultipartMessageListener;
|
import dorkbox.messagebus.listeners.IMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
import dorkbox.messagebus.listeners.IMultipartMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.MultipartMessageListener;
|
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||||
import dorkbox.util.messagebus.listeners.Overloading;
|
import dorkbox.messagebus.listeners.MultipartMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.StandardMessageListener;
|
import dorkbox.messagebus.listeners.Overloading;
|
||||||
import dorkbox.util.messagebus.messages.AbstractMessage;
|
import dorkbox.messagebus.listeners.StandardMessageListener;
|
||||||
import dorkbox.util.messagebus.messages.ICountable;
|
import dorkbox.messagebus.messages.AbstractMessage;
|
||||||
import dorkbox.util.messagebus.messages.IMessage;
|
import dorkbox.messagebus.messages.ICountable;
|
||||||
import dorkbox.util.messagebus.messages.IMultipartMessage;
|
import dorkbox.messagebus.messages.IMultipartMessage;
|
||||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
import dorkbox.messagebus.messages.MessageTypes;
|
||||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
import dorkbox.messagebus.messages.MultipartMessage;
|
||||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
import dorkbox.messagebus.messages.StandardMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Test the subscriptions as generated and organized by the subscription manager. Tests use different sets of listeners
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
|
@ -30,16 +30,16 @@ import org.junit.Test;
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
||||||
import dorkbox.messageBus.error.PublicationError;
|
import dorkbox.messageBus.error.PublicationError;
|
||||||
import dorkbox.util.messagebus.common.ConcurrentExecutor;
|
import dorkbox.messagebus.common.ConcurrentExecutor;
|
||||||
import dorkbox.util.messagebus.common.ListenerFactory;
|
import dorkbox.messagebus.common.ListenerFactory;
|
||||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
import dorkbox.messagebus.common.MessageBusTest;
|
||||||
import dorkbox.util.messagebus.common.TestUtil;
|
import dorkbox.messagebus.common.TestUtil;
|
||||||
import dorkbox.util.messagebus.listeners.ExceptionThrowingListener;
|
import dorkbox.messagebus.listeners.ExceptionThrowingListener;
|
||||||
import dorkbox.util.messagebus.listeners.IMessageListener;
|
import dorkbox.messagebus.listeners.IMessageListener;
|
||||||
import dorkbox.util.messagebus.listeners.MessageTypesListener;
|
import dorkbox.messagebus.listeners.MessageTypesListener;
|
||||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
import dorkbox.messagebus.messages.MessageTypes;
|
||||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
import dorkbox.messagebus.messages.MultipartMessage;
|
||||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
import dorkbox.messagebus.messages.StandardMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Test synchronous and asynchronous dispatch in single and multi-threaded scenario.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
|
@ -30,7 +30,7 @@ import org.junit.Test;
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.annotations.Subscribe;
|
import dorkbox.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.messageBus.annotations.Synchronized;
|
import dorkbox.messageBus.annotations.Synchronized;
|
||||||
import dorkbox.util.messagebus.common.MessageBusTest;
|
import dorkbox.messagebus.common.MessageBusTest;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Todo: Add javadoc
|
* Todo: Add javadoc
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.After;
|
||||||
import org.junit.Assert;
|
import org.junit.Assert;
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.*;
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
@ -20,14 +20,14 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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 org.junit.Before;
|
||||||
|
|
||||||
import dorkbox.messageBus.MessageBus;
|
import dorkbox.messageBus.MessageBus;
|
||||||
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
import dorkbox.messageBus.error.IPublicationErrorHandler;
|
||||||
import dorkbox.messageBus.error.PublicationError;
|
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
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.ArrayDeque;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.Iterator;
|
||||||
import java.util.List;
|
import java.util.List;
|
|
@ -20,10 +20,10 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.util.messagebus.messages.AbstractMessage;
|
import dorkbox.messagebus.messages.AbstractMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author bennidi
|
* @author bennidi
|
|
@ -20,10 +20,10 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.util.messagebus.messages.StandardMessage;
|
import dorkbox.messagebus.messages.StandardMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author bennidi
|
* @author bennidi
|
|
@ -20,10 +20,10 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.Arrays;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
|
@ -20,10 +20,10 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.util.messagebus.messages.MessageTypes;
|
import dorkbox.messagebus.messages.MessageTypes;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author bennidi
|
* @author bennidi
|
|
@ -20,10 +20,10 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.messageBus.annotations.Subscribe;
|
||||||
import dorkbox.util.messagebus.messages.MultipartMessage;
|
import dorkbox.messagebus.messages.MultipartMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author bennidi
|
* @author bennidi
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.Collections;
|
||||||
import java.util.LinkedList;
|
import java.util.LinkedList;
|
|
@ -20,10 +20,10 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.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
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.HashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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.HashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
*/
|
*/
|
||||||
package dorkbox.util.messagebus.messages;
|
package dorkbox.messagebus.messages;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author bennidi
|
* @author bennidi
|
|
@ -20,7 +20,7 @@
|
||||||
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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
|
* OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
* WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
* 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;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
Loading…
Reference in New Issue