We are using activemq 5.1 and running a broker embedded in our java
application (a standard one).
Currently we are configuring the broker using java code.
The problems we have are:
1.We don't seem to be able to make the broker use the temp storage (the
configuration is below)
2.When using persistent = true storage files seems to always grow and are
never being deleted.
3. We can't start the embedded broker using an external xml configuration
file. We tried understanding how to do it from
http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html
using the BrokerFactory with a url in the format of
file:foo/bar/activemq.xml but we get the following error:
Caused by: java.io.IOException: Could not find factory class for resource:
META-INF/services/org/apache/activemq/broker/file
at
org.apache.activemq.util.FactoryFinder.doFindFactoryProperies(FactoryFinder.java:92)
at
org.apache.activemq.util.FactoryFinder.newInstance(FactoryFinder.java:52)
at
org.apache.activemq.util.FactoryFinder.newInstance(FactoryFinder.java:42)
at
org.apache.activemq.broker.BrokerFactory.createBrokerFactoryHandler(BrokerFactory.java:41)
... 11 more
The java configuration of the broker is as follows:
URI serviceUrl = new URI( brokerUri + "?jms.prefetchPolicy.all=" +
jmsMaxMessages + "&wireFormat.maxInactivityDuration=0" + "?useJmx=true" );
broker = new BrokerService();
broker.setUseJmx( true );
broker.addConnector( serviceUrl );
broker.setPersistent( false );
ManagementContext managementContext = new ManagementContext();
managementContext.setConnectorPort( 1098 );
broker.setManagementContext( managementContext );
SystemUsage memoryManager = new SystemUsage();
MemoryUsage memoryUsage = new MemoryUsage();
memoryUsage.setLimit( 512000000 );
memoryManager.setMemoryUsage( memoryUsage );
TempUsage tempDiskUsage = new TempUsage();
tempDiskUsage.setLimit( 100000000);
memoryManager.setTempUsage( tempDiskUsage );
StoreUsage storeUsage = new StoreUsage();
storeUsage.setLimit( 999999999 );
storeUsage.setName( "foo" );
memoryManager.setStoreUsage( storeUsage );
broker.setSystemUsage( memoryManager );
broker.setTempDataStore( tempDataStore );
broker.setTmpDataDirectory( new File( dataDirectory ) );
{
PersistenceAdapter adapter = broker.getPersistenceAdapter();
adapter.setUsageManager( memoryManager );
if( adapter instanceof AMQPersistenceAdapter )
{
AMQPersistenceAdapter amqPersistenceAdapter = (AMQPersistenceAdapter)
adapter;
if( persistent )
amqPersistenceAdapter.setPersistentIndex( true );
else
amqPersistenceAdapter.setPersistentIndex( false );
}
}
broker.start();
We have tried to change the configuration in so many ways, none seems to
work ...
Thank you for your help
Ami
--
View this message in context:
http://old.nabble.com/Loading-embedded-broker-with-an-xml-configuration-tp27928619p27928619.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
