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 java.lang.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

Fields

Modifier and Type	Field and Description
protected org.apache.activemq.broker.BrokerService	_brokerService
protected javax.jms.ConnectionFactory	_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 Type	Method and Description
void	close() Stops the created in-vm broker, if it was created (read MatsTestBroker.SYSPROP_MATS_TEST_BROKERURL).
protected static void	closeBroker(org.apache.activemq.broker.BrokerService _brokerService)
protected static javax.jms.ConnectionFactory	createActiveMQConnectionFactory(java.lang.String brokerUrl)
protected static org.apache.activemq.broker.BrokerService	createInVmActiveMqBroker()
javax.jms.ConnectionFactory	getConnectionFactory()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.mats3.test.broker.MatsTestBroker

create, createUniqueInVmActiveMq, newActiveMqBroker

Field Detail

_brokerService

protected final org.apache.activemq.broker.BrokerService _brokerService

_connectionFactory

protected final javax.jms.ConnectionFactory _connectionFactory

Method Detail

getConnectionFactory

public javax.jms.ConnectionFactory getConnectionFactory()

Specified by:

getConnectionFactory in interface MatsTestBroker

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 (read MatsTestBroker.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 interface MatsTestBroker

createInVmActiveMqBroker

protected static org.apache.activemq.broker.BrokerService createInVmActiveMqBroker()

createActiveMQConnectionFactory

protected static javax.jms.ConnectionFactory createActiveMQConnectionFactory(java.lang.String brokerUrl)

closeBroker

protected static void closeBroker(org.apache.activemq.broker.BrokerService _brokerService)