This commit is contained in:
Clebert Suconic 2018-06-04 10:07:20 -04:00
commit a79798532a
2 changed files with 17 additions and 3 deletions

View File

@ -141,6 +141,9 @@ public final class ConfigurationUtils {
public static List<TransportConfiguration> parseAcceptorURI(String name, String uri) {
try {
// remove all whitespace
uri = uri.replaceAll("\\s", "");
AcceptorTransportConfigurationParser parser = new AcceptorTransportConfigurationParser();
List<TransportConfiguration> configurations = parser.newObject(parser.expandURI(uri), name);
@ -165,8 +168,10 @@ public final class ConfigurationUtils {
}
public static List<TransportConfiguration> parseConnectorURI(String name, String uri) {
try {
// remove all whitespace
uri = uri.replaceAll("\\s", "");
ConnectorTransportConfigurationParser parser = new ConnectorTransportConfigurationParser();
List<TransportConfiguration> configurations = parser.newObject(parser.expandURI(uri), name);

View File

@ -71,11 +71,20 @@
</remoting-outgoing-interceptors>
<persist-delivery-count-before-delivery>true</persist-delivery-count-before-delivery>
<connectors>
<connector name="connector1">tcp://localhost1:5678?localAddress=mylocal;localPort=99</connector>
<connector name="connector1">
tcp://localhost1:5678?
localAddress=mylocal;
localPort=99
</connector>
<connector name="connector2">vm://5</connector>
</connectors>
<acceptors>
<acceptor>tcp://0.0.0.0:61616?tcpNoDelay=456;connectionTtl=44;connectionsAllowed=92</acceptor>
<acceptor>
tcp://0.0.0.0:61616?
tcpNoDelay=456;
connectionTtl=44;
connectionsAllowed=92
</acceptor>
<acceptor>vm://0?e1=z1;e2=567;connectionsAllowed=87</acceptor>
</acceptors>
<broadcast-groups>