diff --git a/pom.xml b/pom.xml index b0de8434..c7951f57 100644 --- a/pom.xml +++ b/pom.xml @@ -43,6 +43,7 @@ 1.0.0.CR4 7.0.1.Final 3.0.0.CR1 + 1.3.2.Final 5.0.6.CR1 1.0.0.CR3 4.15.1.Final @@ -53,7 +54,7 @@ 4.7 1.2.16 1.8.4 - 3.2.1.Final + 3.5.11.Final 4.2.0 1.5.10 1.6.1 @@ -184,6 +185,11 @@ jboss-logging ${version.jboss-logging} + + org.jboss.logmanager + jboss-logmanager + ${version.jboss-logmanager} + org.jboss.ironjacamar ironjacamar-common-impl-papaki @@ -210,7 +216,7 @@ ${version.ironjacamar} - org.jboss.netty + io.netty netty ${version.netty} diff --git a/stomp-api/pom.xml b/stomp-api/pom.xml index 66d7f228..7da8415f 100644 --- a/stomp-api/pom.xml +++ b/stomp-api/pom.xml @@ -19,7 +19,7 @@ - org.jboss.netty + io.netty netty diff --git a/stomp-client-js/src/test/java/org/projectodd/stilts/stomp/client/js/websockets/InstrumentedWebSocket.java b/stomp-client-js/src/test/java/org/projectodd/stilts/stomp/client/js/websockets/InstrumentedWebSocket.java index 6f05f648..e13632e2 100644 --- a/stomp-client-js/src/test/java/org/projectodd/stilts/stomp/client/js/websockets/InstrumentedWebSocket.java +++ b/stomp-client-js/src/test/java/org/projectodd/stilts/stomp/client/js/websockets/InstrumentedWebSocket.java @@ -55,7 +55,7 @@ public void connect() throws InterruptedException, URISyntaxException, Execution this.executor = Executors.newFixedThreadPool( 4 ); VirtualExecutorService bossExecutor = new VirtualExecutorService( this.executor ); VirtualExecutorService workerExecutor = new VirtualExecutorService( this.executor ); - bootstrap.setFactory( new NioClientSocketChannelFactory( bossExecutor, workerExecutor ) ); + bootstrap.setFactory( new NioClientSocketChannelFactory( bossExecutor, workerExecutor, 2 ) ); URI uri = new URI( this.url ); diff --git a/stomp-client/pom.xml b/stomp-client/pom.xml index c2f42e12..0fb895a6 100644 --- a/stomp-client/pom.xml +++ b/stomp-client/pom.xml @@ -29,7 +29,7 @@ ${project.version} - org.jboss.netty + io.netty netty diff --git a/stomp-client/src/main/java/org/projectodd/stilts/stomp/client/StompClient.java b/stomp-client/src/main/java/org/projectodd/stilts/stomp/client/StompClient.java index da5db7b6..e47369d8 100644 --- a/stomp-client/src/main/java/org/projectodd/stilts/stomp/client/StompClient.java +++ b/stomp-client/src/main/java/org/projectodd/stilts/stomp/client/StompClient.java @@ -408,7 +408,7 @@ protected ClientSocketChannelFactory createChannelFactory() { this.executor ); VirtualExecutorService workerExecutor = new VirtualExecutorService( this.executor ); - return new NioClientSocketChannelFactory( bossExecutor, workerExecutor ); + return new NioClientSocketChannelFactory( bossExecutor, workerExecutor, 2 ); } private static final Callable NOOP = new Callable() { diff --git a/stomp-common/pom.xml b/stomp-common/pom.xml index b2f25341..e5c14ed6 100644 --- a/stomp-common/pom.xml +++ b/stomp-common/pom.xml @@ -24,7 +24,7 @@ ${project.version} - org.jboss.netty + io.netty netty diff --git a/stomp-common/src/test/java/org/projectodd/stilts/stomp/protocol/HandlerEmbedder.java b/stomp-common/src/test/java/org/projectodd/stilts/stomp/protocol/HandlerEmbedder.java index a121208d..879f3402 100644 --- a/stomp-common/src/test/java/org/projectodd/stilts/stomp/protocol/HandlerEmbedder.java +++ b/stomp-common/src/test/java/org/projectodd/stilts/stomp/protocol/HandlerEmbedder.java @@ -15,6 +15,7 @@ import org.jboss.netty.buffer.ChannelBufferFactory; import org.jboss.netty.channel.Channel; import org.jboss.netty.channel.ChannelEvent; +import org.jboss.netty.channel.ChannelFuture; import org.jboss.netty.channel.ChannelHandler; import org.jboss.netty.channel.ChannelHandlerContext; import org.jboss.netty.channel.ChannelPipeline; @@ -230,6 +231,15 @@ public void exceptionCaught( throw new CodecEmbedderException( actualCause ); } + + public ChannelFuture execute(ChannelPipeline pipeline, Runnable task) { + try { + task.run(); + return Channels.succeededFuture(pipeline.getChannel()); + } catch (Throwable t) { + return Channels.failedFuture(pipeline.getChannel(), t); + } + } } private static final class EmbeddedChannelPipeline extends DefaultChannelPipeline { diff --git a/stomp-server-core/pom.xml b/stomp-server-core/pom.xml index f98ebfe7..d1affba9 100644 --- a/stomp-server-core/pom.xml +++ b/stomp-server-core/pom.xml @@ -52,13 +52,17 @@ 2.6 - org.jboss.netty + io.netty netty org.jboss.logging jboss-logging + + org.jboss.logmanager + jboss-logmanager + org.projectodd.stilts stilts-stomp-common diff --git a/stomp-server-spi/pom.xml b/stomp-server-spi/pom.xml index 7f8c91a6..285a3d52 100644 --- a/stomp-server-spi/pom.xml +++ b/stomp-server-spi/pom.xml @@ -30,7 +30,7 @@ - org.jboss.netty + io.netty netty