This closes #65 ActiveMQ test fixes
This commit is contained in:
commit
e07c526f0b
|
@ -431,7 +431,7 @@ public class BrokerService implements Service
|
|||
|
||||
public TransportConnector addConnector(String bindAddress) throws Exception
|
||||
{
|
||||
return null;
|
||||
return addConnector(new URI(bindAddress));
|
||||
}
|
||||
|
||||
public void setIoExceptionHandler(IOExceptionHandler ioExceptionHandler)
|
||||
|
@ -653,6 +653,8 @@ public class BrokerService implements Service
|
|||
|
||||
public TransportConnector addConnector(URI bindAddress) throws Exception
|
||||
{
|
||||
Integer port = bindAddress.getPort();
|
||||
this.extraConnectors.add(port);
|
||||
return null;
|
||||
}
|
||||
|
||||
|
|
|
@ -64,11 +64,6 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase
|
|||
Set<TransportConfiguration> acceptors0 = serverConfig.getAcceptorConfigurations();
|
||||
Iterator<TransportConfiguration> iter0 = acceptors0.iterator();
|
||||
|
||||
while (iter0.hasNext())
|
||||
{
|
||||
System.out.println("===>: " + iter0.next());
|
||||
}
|
||||
|
||||
Map<String, AddressSettings> addressSettings = serverConfig.getAddressesSettings();
|
||||
String match = "jms.queue.#";
|
||||
AddressSettings dlaSettings = new AddressSettings();
|
||||
|
@ -168,7 +163,7 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase
|
|||
|
||||
while (iter.hasNext())
|
||||
{
|
||||
System.out.println(">: " + iter.next());
|
||||
System.out.println("acceptor =>: " + iter.next());
|
||||
}
|
||||
server.start();
|
||||
|
||||
|
|
|
@ -107,7 +107,7 @@ public class JmsTestSupport extends CombinationTestSupport {
|
|||
}
|
||||
|
||||
protected ConnectionFactory createConnectionFactory() throws Exception {
|
||||
return new ActiveMQConnectionFactory("vm://localhost");
|
||||
return new ActiveMQConnectionFactory("tcp://localhost:61616");
|
||||
}
|
||||
|
||||
protected BrokerService createBroker() throws Exception {
|
||||
|
|
Loading…
Reference in New Issue