RemoteConnectionCustomizer implements Customizer { @Override public void customize() { List<Server> servers = fraction.subresources().servers(); servers.stream() .filter(e -> e instanceof EnhancedServer) .forEach(server -> { ((EnhancedServer) server).remoteConnections() .forEach(connection -> { server.remoteConnector(connection.name(), connector -> { connector.socketBinding(connection.name()); }); server.pooledConnectionFactory(connection.name(), factory -> { factory.connectors(connection.name()); factory.entry(connection.jndiName()); }); }); }); }  @Override void customize();  }
@Test public void testIfNoRemoteConnections() { this.customizer.customize(); assertThat( this.fraction.subresources().servers()).isEmpty(); }
@Test public void testIfRemoteConnection() { this.fraction.server( "default", (server)->{ server.remoteConnection( "postoffice" ); }); this.customizer.customize(); EnhancedServer server = (EnhancedServer) this.fraction.subresources().servers().get(0); assertThat( server.remoteConnections()).hasSize(1); assertThat( server.subresources().pooledConnectionFactories()).hasSize(1); PooledConnectionFactory connectionFactory = server.subresources().pooledConnectionFactories().get(0); assertThat( connectionFactory.getKey() ).isEqualTo( "postoffice" ); assertThat( connectionFactory.entries() ).containsExactly( "java:/jms/postoffice" ); assertThat( server.subresources().remoteConnectors() ).hasSize(1); RemoteConnector remoteConnector = server.subresources().remoteConnectors().get(0); assertThat( remoteConnector.getKey() ).isEqualTo( "postoffice" ); assertThat( remoteConnector.socketBinding() ).isEqualTo( "postoffice" ); }