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

Code polish

Browse Source
This commit is contained in:
nathan 2016-01-13 10:56:17 +01:00
parent 69701fbbd9
commit 712b0d8265
5 changed files with 56 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/dorkbox/util/messagebus/publication/PublisherAll_MultiArg.java
View File

@ -26,6 +26,7 @@ import dorkbox.util.messagebus.utils.VarArgUtils;
import java.lang.reflect.Array;
import java.util.concurrent.atomic.AtomicBoolean;
@SuppressWarnings("Duplicates")
public
class PublisherAll_MultiArg implements Publisher {
private final ErrorHandlingSupport errorHandler;
@ -135,8 +136,9 @@ class PublisherAll_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1));
}
}
@ -234,8 +236,9 @@ class PublisherAll_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2));
}
}
@ -339,8 +342,9 @@ class PublisherAll_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2, message3));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2, message3));
}
}

21
src/dorkbox/util/messagebus/publication/PublisherExactWithSuperTypes_FirstArg.java
View File

@ -24,6 +24,7 @@ import dorkbox.util.messagebus.subscription.Subscription;
import java.util.Arrays;
@SuppressWarnings("Duplicates")
public
class PublisherExactWithSuperTypes_FirstArg implements Publisher {
private final ErrorHandlingSupport errorHandler;
@ -78,8 +79,9 @@ class PublisherExactWithSuperTypes_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1));
}
}
@ -124,8 +126,9 @@ class PublisherExactWithSuperTypes_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2));
}
}
@ -170,8 +173,9 @@ class PublisherExactWithSuperTypes_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2, message3));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2, message3));
}
}
@ -219,8 +223,9 @@ class PublisherExactWithSuperTypes_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(messages));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(messages));
}
}
}

16
src/dorkbox/util/messagebus/publication/PublisherExactWithSuperTypes_MultiArg.java
View File

@ -22,6 +22,7 @@ import dorkbox.util.messagebus.error.PublicationError;
import dorkbox.util.messagebus.subscription.Subscriber;
import dorkbox.util.messagebus.subscription.Subscription;
@SuppressWarnings("Duplicates")
public
class PublisherExactWithSuperTypes_MultiArg implements Publisher {
private final ErrorHandlingSupport errorHandler;
@ -71,8 +72,9 @@ class PublisherExactWithSuperTypes_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1));
}
}
@ -113,8 +115,9 @@ class PublisherExactWithSuperTypes_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2));
}
}
@ -158,8 +161,9 @@ class PublisherExactWithSuperTypes_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2, message3));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2, message3));
}
}

21
src/dorkbox/util/messagebus/publication/PublisherExact_FirstArg.java
View File

@ -22,6 +22,7 @@ import dorkbox.util.messagebus.error.PublicationError;
import dorkbox.util.messagebus.subscription.Subscriber;
import dorkbox.util.messagebus.subscription.Subscription;
@SuppressWarnings("Duplicates")
public
class PublisherExact_FirstArg implements Publisher {
private final ErrorHandlingSupport errorHandler;
@ -76,8 +77,9 @@ class PublisherExact_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1));
}
}
@ -122,8 +124,9 @@ class PublisherExact_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2));
}
}
@ -168,8 +171,9 @@ class PublisherExact_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2, message3));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2, message3));
}
}
@ -215,8 +219,9 @@ class PublisherExact_FirstArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(messages));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(messages));
}
}
}

16
src/dorkbox/util/messagebus/publication/PublisherExact_MultiArg.java
View File

@ -22,6 +22,7 @@ import dorkbox.util.messagebus.error.PublicationError;
import dorkbox.util.messagebus.subscription.Subscriber;
import dorkbox.util.messagebus.subscription.Subscription;
@SuppressWarnings("Duplicates")
public
class PublisherExact_MultiArg implements Publisher {
private final ErrorHandlingSupport errorHandler;
@ -71,8 +72,9 @@ class PublisherExact_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1));
}
}
@ -113,8 +115,9 @@ class PublisherExact_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2));
}
}
@ -156,8 +159,9 @@ class PublisherExact_MultiArg implements Publisher {
}
}
} catch (Throwable e) {
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.").setCause(
e).setPublishedObject(message1, message2, message3));
errorHandler.handlePublicationError(new PublicationError().setMessage("Error during invocation of message handler.")
.setCause(e)
.setPublishedObject(message1, message2, message3));
}
}