Skip to content

Commit 2aec86f

Browse files
author
Igor Polevoy
committed
#260 Add Netty configuration to Async
1 parent baa90a6 commit 2aec86f

File tree

1 file changed

+8
-0
lines changed
  • javalite-async/src/main/java/org/javalite/async

1 file changed

+8
-0
lines changed

javalite-async/src/main/java/org/javalite/async/Async.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525
import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
2626
import org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory;
2727
import org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnectorFactory;
28+
import org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory;
29+
import org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants;
2830
import org.apache.activemq.artemis.core.server.JournalType;
2931
import org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy;
3032
import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
@@ -46,6 +48,7 @@
4648
import java.util.*;
4749

4850
import static java.util.Collections.singletonList;
51+
import static org.javalite.common.Collections.map;
4952
import static org.javalite.common.Util.closeQuietly;
5053

5154
/**
@@ -219,6 +222,11 @@ private void configureListeners(Injector injector, List<QueueConfig> queueConfig
219222

220223
///******* PUBLIC METHODS BELOW ***********///
221224

225+
public void configureNetty(String host, int port){
226+
Map<String, Object> params = map(TransportConstants.HOST_PROP_NAME, host, TransportConstants.PORT_PROP_NAME, port);
227+
config.getAcceptorConfigurations().add(new TransportConfiguration(NettyAcceptorFactory.class.getName(), params));
228+
}
229+
222230
/**
223231
* Sends a command into a queue for processing
224232
*

0 commit comments

Comments
 (0)