Package io.mats3.test.broker
Class MatsTestBroker.MatsTestBroker_InVmActiveMq
java.lang.Object
io.mats3.test.broker.MatsTestBroker.MatsTestBroker_InVmActiveMq
- All Implemented Interfaces:
MatsTestBroker
- Enclosing interface:
- MatsTestBroker
public static class MatsTestBroker.MatsTestBroker_InVmActiveMq
extends Object
implements MatsTestBroker
Creates an in-vm ActiveMQ no matter what the properties says.
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.mats3.test.broker.MatsTestBroker
MatsTestBroker.ActiveMq, MatsTestBroker.MatsTestBroker_ActiveMq, MatsTestBroker.MatsTestBroker_Artemis, MatsTestBroker.MatsTestBroker_InVmActiveMq
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final org.apache.activemq.broker.BrokerService
protected final javax.jms.ConnectionFactory
Fields inherited from interface io.mats3.test.broker.MatsTestBroker
SYSPROP_MATS_TEST_BROKER, SYSPROP_MATS_TEST_BROKER_VALUE_ACTIVEMQ, SYSPROP_MATS_TEST_BROKER_VALUE_ARTEMIS, SYSPROP_MATS_TEST_BROKER_VALUE_RABBITMQ, SYSPROP_MATS_TEST_BROKERURL, SYSPROP_MATS_TEST_BROKERURL_VALUE_IN_VM, SYSPROP_MATS_TEST_BROKERURL_VALUE_LOCALHOST
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Stops the created in-vm broker, if it was created (readMatsTestBroker.SYSPROP_MATS_TEST_BROKERURL
).protected static void
closeBroker
(org.apache.activemq.broker.BrokerService _brokerService) protected static javax.jms.ConnectionFactory
createActiveMQConnectionFactory
(String brokerUrl) protected static org.apache.activemq.broker.BrokerService
javax.jms.ConnectionFactory
-
Field Details
-
_brokerService
protected final org.apache.activemq.broker.BrokerService _brokerService -
_connectionFactory
protected final javax.jms.ConnectionFactory _connectionFactory
-
-
Method Details
-
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()- Specified by:
getConnectionFactory
in interfaceMatsTestBroker
- Returns:
- the ConnectionFactory connecting to the broker.
-
close
public void close()Description copied from interface:MatsTestBroker
Stops the created in-vm broker, if it was created (readMatsTestBroker.SYSPROP_MATS_TEST_BROKERURL
). Called "close()" to hook into the default Spring lifecycle if it is instantiated as a Spring Bean.- Specified by:
close
in interfaceMatsTestBroker
-
createInVmActiveMqBroker
protected static org.apache.activemq.broker.BrokerService createInVmActiveMqBroker() -
createActiveMQConnectionFactory
-
closeBroker
protected static void closeBroker(org.apache.activemq.broker.BrokerService _brokerService)
-