Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

fix max for reqOnly msg 380 byte

exclude slf4j deps from build
  • Loading branch information...
commit 8b51fcea2c3045e690c99193b03c6e13ff51da94 1 parent b8a1d33
@eitan101 eitan101 authored
View
41 build.gradle
@@ -20,37 +20,57 @@ if (!project.hasProperty("sonatypeUsername") || !project.hasProperty("sonatypePa
sonatypeUsername = ""
sonatypePassword = ""
}
+configurations {
+ all*.exclude group: 'javax.jms', module: 'jms'
+ all*.exclude group: 'com.sun.jdmk', module: 'jmxtools'
+ all*.exclude group: 'com.sun.jmx', module: 'jmxri'
+// published
+ javancssConf
+}
repositories {
flatDir { dirs 'baselib' }
- repositories { mavenCentral() }
+ repositories {
+ mavenCentral()
+ }
maven { url "http://download.oracle.com/maven/" }
}
dependencies {
- compile "com.google.guava:guava:11.0.1"
+ compile "com.google.guava:guava:11.0.1"
compile "net.sf.trove4j:trove4j:3.0.2"
compile "org.springframework:spring-beans:3.1.0.RELEASE"
compile "org.springframework:spring-context:3.1.0.RELEASE"
compile "com.yammer.metrics:metrics-core:2.0.3"
compile "io.netty:netty:3.5.0.Final"
compile "org.jgroups:jgroups:3.1.0.Beta"
- compile "org.apache.zookeeper:zookeeper:3.4.3"
- compile "com.netflix.curator:curator-client:1.1.9"
- compile "com.netflix.curator:curator-framework:1.1.9"
- compile "com.netflix.curator:curator-recipes:1.1.9"
compile "com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.3"
compile "com.sleepycat:je:5.0.34"
compile "co.parallelunivese:high-scale-lib:" // non-Maven
runtime "org.slf4j:slf4j-api:1.6.4"
- runtime "org.slf4j:slf4j-jdk14:1.6.4"
runtime "org.slf4j:jcl-over-slf4j:1.6.4"
- runtime "org.slf4j:log4j-over-slf4j:1.6.4"
+ runtime "org.slf4j:log4j-over-slf4j:1.6.4"
+ runtime "org.apache.logging.log4j:log4j-slf4j-impl:2.0-beta6"
+ runtime "org.apache.logging.log4j:log4j-api:2.0-beta6"
+ runtime "org.apache.logging.log4j:log4j-core:2.0-beta6"
+ runtime "com.lmax:disruptor:3.0.1" // required for log4j
testCompile "junit:junit:4.10"
testCompile "org.apache.ant:ant-junit4:1.8.4"
testCompile "org.hamcrest:hamcrest-core:1.3.RC2"
testCompile "org.hamcrest:hamcrest-library:1.3.RC2"
testCompile "org.mockito:mockito-all:1.9.0"
+ compile("com.netflix.curator:curator-recipes:1.1.9") {
+ exclude group: "org.slf4j"
+ }
+ compile("com.netflix.curator:curator-client:1.1.9") {
+ exclude group: "org.slf4j"
+ }
+ compile("com.netflix.curator:curator-framework:1.1.9") {
+ exclude group: "org.slf4j"
+ }
+ compile("org.apache.zookeeper:zookeeper:3.4.3") {
+ exclude group: "org.slf4j"
+ }
}
///////// Doduments
@@ -239,9 +259,6 @@ uploadArchives {
}
//////// Javancss
-configurations {
- javancssConf
-}
dependencies {
javancssConf 'javancss:javancss:29.50'
@@ -266,6 +283,8 @@ task javancss(dependsOn: 'classes') << {
}
/////// Others
tasks.withType(Test) {
+ systemProperty "log4j.configurationFile", "log4j.xml"
+ systemProperty "Log4jContextSelector", "org.apache.logging.log4j.core.async.AsyncLoggerContextSelector"
useJUnit()
doLast() {
println "file://" + testReportDir + "/index.html"
View
312 deps
@@ -0,0 +1,312 @@
+:dependencies
+
+------------------------------------------------------------
+Root project - A high-performance in-memory data-grid.
+------------------------------------------------------------
+
+archives - Configuration for archive artifacts.
+No dependencies
+
+compile - Classpath for compiling the main sources.
++--- com.google.guava:guava:11.0.1
+| \--- com.google.code.findbugs:jsr305:1.3.9
++--- net.sf.trove4j:trove4j:3.0.2
++--- org.springframework:spring-beans:3.1.0.RELEASE
+| \--- org.springframework:spring-core:3.1.0.RELEASE
+| +--- org.springframework:spring-asm:3.1.0.RELEASE
+| \--- commons-logging:commons-logging:1.1.1
++--- org.springframework:spring-context:3.1.0.RELEASE
+| +--- org.springframework:spring-aop:3.1.0.RELEASE
+| | +--- aopalliance:aopalliance:1.0
+| | +--- org.springframework:spring-asm:3.1.0.RELEASE
+| | +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-expression:3.1.0.RELEASE
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| \--- org.springframework:spring-asm:3.1.0.RELEASE
++--- com.yammer.metrics:metrics-core:2.0.3
+| \--- org.slf4j:slf4j-api:1.6.4
++--- io.netty:netty:3.5.0.Final
++--- org.jgroups:jgroups:3.1.0.Beta
++--- com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.3
++--- com.sleepycat:je:5.0.34
++--- co.parallelunivese:high-scale-lib:
++--- com.netflix.curator:curator-recipes:1.1.9
+| +--- com.netflix.curator:curator-framework:1.1.9
+| | +--- com.google.guava:guava:11.0.1 (*)
+| | +--- com.netflix.curator:curator-client:1.1.9
+| | | +--- com.google.guava:guava:11.0.1 (*)
+| | | \--- org.apache.zookeeper:zookeeper:3.4.3
+| | | +--- log4j:log4j:1.2.15
+| | | | \--- javax.mail:mail:1.4
+| | | | \--- javax.activation:activation:1.1
+| | | +--- jline:jline:0.9.94
+| | | | \--- junit:junit:3.8.1
+| | | \--- org.jboss.netty:netty:3.2.2.Final
+| | \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
+| +--- com.google.guava:guava:11.0.1 (*)
+| \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- com.netflix.curator:curator-client:1.1.9 (*)
++--- com.netflix.curator:curator-framework:1.1.9 (*)
+\--- org.apache.zookeeper:zookeeper:3.4.3 (*)
+
+default - Configuration for default artifacts.
++--- com.google.guava:guava:11.0.1
+| \--- com.google.code.findbugs:jsr305:1.3.9
++--- net.sf.trove4j:trove4j:3.0.2
++--- org.springframework:spring-beans:3.1.0.RELEASE
+| \--- org.springframework:spring-core:3.1.0.RELEASE
+| +--- org.springframework:spring-asm:3.1.0.RELEASE
+| \--- commons-logging:commons-logging:1.1.1
++--- org.springframework:spring-context:3.1.0.RELEASE
+| +--- org.springframework:spring-aop:3.1.0.RELEASE
+| | +--- aopalliance:aopalliance:1.0
+| | +--- org.springframework:spring-asm:3.1.0.RELEASE
+| | +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-expression:3.1.0.RELEASE
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| \--- org.springframework:spring-asm:3.1.0.RELEASE
++--- com.yammer.metrics:metrics-core:2.0.3
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- io.netty:netty:3.5.0.Final
++--- org.jgroups:jgroups:3.1.0.Beta
++--- com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.3
++--- com.sleepycat:je:5.0.34
++--- co.parallelunivese:high-scale-lib:
++--- com.netflix.curator:curator-recipes:1.1.9
+| +--- com.netflix.curator:curator-framework:1.1.9
+| | +--- com.google.guava:guava:11.0.1 (*)
+| | +--- com.netflix.curator:curator-client:1.1.9
+| | | +--- com.google.guava:guava:11.0.1 (*)
+| | | \--- org.apache.zookeeper:zookeeper:3.4.3
+| | | +--- log4j:log4j:1.2.15
+| | | | \--- javax.mail:mail:1.4
+| | | | \--- javax.activation:activation:1.1
+| | | +--- jline:jline:0.9.94
+| | | | \--- junit:junit:3.8.1
+| | | \--- org.jboss.netty:netty:3.2.2.Final
+| | \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
+| +--- com.google.guava:guava:11.0.1 (*)
+| \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- com.netflix.curator:curator-client:1.1.9 (*)
++--- com.netflix.curator:curator-framework:1.1.9 (*)
++--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.slf4j:jcl-over-slf4j:1.6.4
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.slf4j:log4j-over-slf4j:1.6.4
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.apache.logging.log4j:log4j-slf4j-impl:2.0-beta6
+| +--- org.slf4j:slf4j-api:1.7.2
+| +--- org.slf4j:slf4j-ext:1.7.2
+| | +--- org.slf4j:slf4j-api:1.7.2
+| | \--- ch.qos.cal10n:cal10n-api:0.7.4
+| \--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- org.apache.logging.log4j:log4j-core:2.0-beta6
+| \--- org.apache.logging.log4j:log4j-api:2.0-beta6
+\--- com.lmax:disruptor:3.0.1
+
+javancssConf
+\--- javancss:javancss:29.50
+ +--- javancss:ccl:29.50
+ \--- javancss:jhbasic:29.50
+
+runtime - Classpath for running the compiled main classes.
++--- com.google.guava:guava:11.0.1
+| \--- com.google.code.findbugs:jsr305:1.3.9
++--- net.sf.trove4j:trove4j:3.0.2
++--- org.springframework:spring-beans:3.1.0.RELEASE
+| \--- org.springframework:spring-core:3.1.0.RELEASE
+| +--- org.springframework:spring-asm:3.1.0.RELEASE
+| \--- commons-logging:commons-logging:1.1.1
++--- org.springframework:spring-context:3.1.0.RELEASE
+| +--- org.springframework:spring-aop:3.1.0.RELEASE
+| | +--- aopalliance:aopalliance:1.0
+| | +--- org.springframework:spring-asm:3.1.0.RELEASE
+| | +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-expression:3.1.0.RELEASE
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| \--- org.springframework:spring-asm:3.1.0.RELEASE
++--- com.yammer.metrics:metrics-core:2.0.3
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- io.netty:netty:3.5.0.Final
++--- org.jgroups:jgroups:3.1.0.Beta
++--- com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.3
++--- com.sleepycat:je:5.0.34
++--- co.parallelunivese:high-scale-lib:
++--- com.netflix.curator:curator-recipes:1.1.9
+| +--- com.netflix.curator:curator-framework:1.1.9
+| | +--- com.google.guava:guava:11.0.1 (*)
+| | +--- com.netflix.curator:curator-client:1.1.9
+| | | +--- com.google.guava:guava:11.0.1 (*)
+| | | \--- org.apache.zookeeper:zookeeper:3.4.3
+| | | +--- log4j:log4j:1.2.15
+| | | | \--- javax.mail:mail:1.4
+| | | | \--- javax.activation:activation:1.1
+| | | +--- jline:jline:0.9.94
+| | | | \--- junit:junit:3.8.1
+| | | \--- org.jboss.netty:netty:3.2.2.Final
+| | \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
+| +--- com.google.guava:guava:11.0.1 (*)
+| \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- com.netflix.curator:curator-client:1.1.9 (*)
++--- com.netflix.curator:curator-framework:1.1.9 (*)
++--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.slf4j:jcl-over-slf4j:1.6.4
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.slf4j:log4j-over-slf4j:1.6.4
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.apache.logging.log4j:log4j-slf4j-impl:2.0-beta6
+| +--- org.slf4j:slf4j-api:1.7.2
+| +--- org.slf4j:slf4j-ext:1.7.2
+| | +--- org.slf4j:slf4j-api:1.7.2
+| | \--- ch.qos.cal10n:cal10n-api:0.7.4
+| \--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- org.apache.logging.log4j:log4j-core:2.0-beta6
+| \--- org.apache.logging.log4j:log4j-api:2.0-beta6
+\--- com.lmax:disruptor:3.0.1
+
+signatures
+No dependencies
+
+testCompile - Classpath for compiling the test sources.
++--- com.google.guava:guava:11.0.1
+| \--- com.google.code.findbugs:jsr305:1.3.9
++--- net.sf.trove4j:trove4j:3.0.2
++--- org.springframework:spring-beans:3.1.0.RELEASE
+| \--- org.springframework:spring-core:3.1.0.RELEASE
+| +--- org.springframework:spring-asm:3.1.0.RELEASE
+| \--- commons-logging:commons-logging:1.1.1
++--- org.springframework:spring-context:3.1.0.RELEASE
+| +--- org.springframework:spring-aop:3.1.0.RELEASE
+| | +--- aopalliance:aopalliance:1.0
+| | +--- org.springframework:spring-asm:3.1.0.RELEASE
+| | +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-expression:3.1.0.RELEASE
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| \--- org.springframework:spring-asm:3.1.0.RELEASE
++--- com.yammer.metrics:metrics-core:2.0.3
+| \--- org.slf4j:slf4j-api:1.6.4
++--- io.netty:netty:3.5.0.Final
++--- org.jgroups:jgroups:3.1.0.Beta
++--- com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.3
++--- com.sleepycat:je:5.0.34
++--- co.parallelunivese:high-scale-lib:
++--- com.netflix.curator:curator-recipes:1.1.9
+| +--- com.netflix.curator:curator-framework:1.1.9
+| | +--- com.google.guava:guava:11.0.1 (*)
+| | +--- com.netflix.curator:curator-client:1.1.9
+| | | +--- com.google.guava:guava:11.0.1 (*)
+| | | \--- org.apache.zookeeper:zookeeper:3.4.3
+| | | +--- log4j:log4j:1.2.15
+| | | | \--- javax.mail:mail:1.4
+| | | | \--- javax.activation:activation:1.1
+| | | +--- jline:jline:0.9.94
+| | | | \--- junit:junit:3.8.1 -> 4.10
+| | | | \--- org.hamcrest:hamcrest-core:1.1 -> 1.3.RC2
+| | | \--- org.jboss.netty:netty:3.2.2.Final
+| | \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
+| +--- com.google.guava:guava:11.0.1 (*)
+| \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- com.netflix.curator:curator-client:1.1.9 (*)
++--- com.netflix.curator:curator-framework:1.1.9 (*)
++--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- junit:junit:4.10 (*)
++--- org.apache.ant:ant-junit4:1.8.4
+| +--- org.apache.ant:ant:1.8.4
+| | \--- org.apache.ant:ant-launcher:1.8.4
+| \--- junit:junit:4.8.1 -> 4.10 (*)
++--- org.hamcrest:hamcrest-core:1.3.RC2
++--- org.hamcrest:hamcrest-library:1.3.RC2
+| \--- org.hamcrest:hamcrest-core:1.3.RC2
+\--- org.mockito:mockito-all:1.9.0
+
+testRuntime - Classpath for running the compiled test classes.
++--- com.google.guava:guava:11.0.1
+| \--- com.google.code.findbugs:jsr305:1.3.9
++--- net.sf.trove4j:trove4j:3.0.2
++--- org.springframework:spring-beans:3.1.0.RELEASE
+| \--- org.springframework:spring-core:3.1.0.RELEASE
+| +--- org.springframework:spring-asm:3.1.0.RELEASE
+| \--- commons-logging:commons-logging:1.1.1
++--- org.springframework:spring-context:3.1.0.RELEASE
+| +--- org.springframework:spring-aop:3.1.0.RELEASE
+| | +--- aopalliance:aopalliance:1.0
+| | +--- org.springframework:spring-asm:3.1.0.RELEASE
+| | +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-beans:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| +--- org.springframework:spring-expression:3.1.0.RELEASE
+| | \--- org.springframework:spring-core:3.1.0.RELEASE (*)
+| \--- org.springframework:spring-asm:3.1.0.RELEASE
++--- com.yammer.metrics:metrics-core:2.0.3
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- io.netty:netty:3.5.0.Final
++--- org.jgroups:jgroups:3.1.0.Beta
++--- com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.3
++--- com.sleepycat:je:5.0.34
++--- co.parallelunivese:high-scale-lib:
++--- com.netflix.curator:curator-recipes:1.1.9
+| +--- com.netflix.curator:curator-framework:1.1.9
+| | +--- com.google.guava:guava:11.0.1 (*)
+| | +--- com.netflix.curator:curator-client:1.1.9
+| | | +--- com.google.guava:guava:11.0.1 (*)
+| | | \--- org.apache.zookeeper:zookeeper:3.4.3
+| | | +--- log4j:log4j:1.2.15
+| | | | \--- javax.mail:mail:1.4
+| | | | \--- javax.activation:activation:1.1
+| | | +--- jline:jline:0.9.94
+| | | | \--- junit:junit:3.8.1 -> 4.10
+| | | | \--- org.hamcrest:hamcrest-core:1.1 -> 1.3.RC2
+| | | \--- org.jboss.netty:netty:3.2.2.Final
+| | \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
+| +--- com.google.guava:guava:11.0.1 (*)
+| \--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- com.netflix.curator:curator-client:1.1.9 (*)
++--- com.netflix.curator:curator-framework:1.1.9 (*)
++--- org.apache.zookeeper:zookeeper:3.4.3 (*)
++--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.slf4j:jcl-over-slf4j:1.6.4
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.slf4j:log4j-over-slf4j:1.6.4
+| \--- org.slf4j:slf4j-api:1.6.4 -> 1.7.2
++--- org.apache.logging.log4j:log4j-slf4j-impl:2.0-beta6
+| +--- org.slf4j:slf4j-api:1.7.2
+| +--- org.slf4j:slf4j-ext:1.7.2
+| | +--- org.slf4j:slf4j-api:1.7.2
+| | \--- ch.qos.cal10n:cal10n-api:0.7.4
+| \--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- org.apache.logging.log4j:log4j-core:2.0-beta6
+| \--- org.apache.logging.log4j:log4j-api:2.0-beta6
++--- com.lmax:disruptor:3.0.1
++--- junit:junit:4.10 (*)
++--- org.apache.ant:ant-junit4:1.8.4
+| +--- org.apache.ant:ant:1.8.4
+| | \--- org.apache.ant:ant-launcher:1.8.4
+| \--- junit:junit:4.8.1 -> 4.10 (*)
++--- org.hamcrest:hamcrest-core:1.3.RC2
++--- org.hamcrest:hamcrest-library:1.3.RC2
+| \--- org.hamcrest:hamcrest-core:1.3.RC2
+\--- org.mockito:mockito-all:1.9.0
+
+(*) - dependencies omitted (listed previously)
+
+BUILD SUCCESSFUL
+
+Total time: 10.461 secs
View
27 src/main/java/co/paralleluniverse/common/util/Exceptions.java
@@ -1,21 +1,14 @@
/*
- * Galaxy
- * Copyright (C) 2012 Parallel Universe Software Co.
+ * Copyright (C) 2013, Parallel Universe Software Co. All rights reserved.
*
- * This file is part of Galaxy.
- *
- * Galaxy is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation, either version 3 of
- * the License, or (at your option) any later version.
- *
- * Galaxy is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with Galaxy. If not, see <http://www.gnu.org/licenses/>.
+ * This program and the accompanying materials are dual-licensed under
+ * either the terms of the Eclipse Public License v1.0 as published by
+ * the Eclipse Foundation
+ *
+ * or (per the licensee's choosing)
+ *
+ * under the terms of the GNU Lesser General Public License version 3.0
+ * as published by the Free Software Foundation.
*/
package co.paralleluniverse.common.util;
@@ -24,7 +17,7 @@
* @author pron
*/
public final class Exceptions {
- public static void rethrow(Throwable t) {
+ public static RuntimeException rethrow(Throwable t) {
if(t instanceof RuntimeException)
throw ((RuntimeException)t);
if(t instanceof Error)
View
7 src/main/java/co/paralleluniverse/galaxy/netty/UDPComm.java
@@ -895,8 +895,11 @@ private synchronized void handleQueue(long start) throws InterruptedException {
}
if (!next.isResponse()) {
- if (requestsOnly && next.size() + sentPacketSizeInBytes() > maxRequestOnlyPacketSize)
- break;
+ if (requestsOnly && next.size() + sentPacketSizeInBytes() > maxRequestOnlyPacketSize && sentPacketSizeInBytes() > 0) {
+ // check if packet consists of requestOnly message unless it is only one message.
+ LOG.warn("NOT Sending requests only {}. can't add to packet {} bytes long.", next, sentPacketSizeInBytes());
+ break;
+ }
hasRequests = true;
} else
requestsOnly = false;
Please sign in to comment.
Something went wrong with that request. Please try again.