Re: ActiveMQ does not send some messages

[ipolevoy]

Hi, Justin. 

here is some compressed code that shows configuration: 
Configuration config = new ConfigurationImpl();
        JMSConfiguration jmsConfig = new JMSConfigurationImpl();
        config.setJournalType(JournalType.NIO);
        config.setPersistenceEnabled(true);
        config.setSecurityEnabled(false);
        config.getAcceptorConfigurations().add(new
TransportConfiguration(InVMAcceptorFactory.class.getName()));
        config.getConnectorConfigurations().put("connector", new
TransportConfiguration(InVMConnectorFactory.class.getName()));
        config.getAcceptorConfigurations().add(new
TransportConfiguration(NettyAcceptorFactory.class.getName(), params));
        ConnectionFactoryConfiguration cfConfig = new
ConnectionFactoryConfigurationImpl();
       
cfConfig.setName("cf").setHA(false).setConnectorNames(singletonList("connector")).setBindings("/cf");
        cfConfig.setClientFailureCheckPeriod(Long.MAX_VALUE);
        cfConfig.setConnectionTTL(-1);
        cfConfig.setReconnectAttempts(-1);
        cfConfig.setMinLargeMessageSize(250000);
        jmsConfig.getConnectionFactoryConfigurations().add(cfConfig);
        for (WorkQueue queue : WorkQueue.values()) {
            JMSQueueConfigurationImpl configuration = new
JMSQueueConfigurationImpl();
           
configuration.setName(queue.getName()).setSelector(null).setDurable(true).setBindings(queue.getQueuePath());
            jmsConfig.getQueueConfigurations().add(configuration);
        }

        AddressSettings addressSettings = new AddressSettings();
       
addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
        addressSettings.setMaxSizeBytes(30 * 1024 * 1024);
        addressSettings.setPageSizeBytes(10 * 1024 * 1024);
        addressSettings.setPageCacheMaxSize(20);
        config.getAddressesSettings().put("jms.queue.*", addressSettings);

        EmbeddedJMS embeddedJMS = new EmbeddedJMS();
        embeddedJMS.setConfiguration(config);
        embeddedJMS.setJmsConfiguration(jmsConfig);


Here are how clients are connected: 

ConnectionFactory connectionFactory = (ConnectionFactory)
embeddedJMSserver.lookup("/cf");
javax.jms.Connection  consumerConnection =
connectionFactory.createConnection();
javax.jms.Connection  producerConnection =
connectionFactory.createConnection();

Session s = consumerConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
s.createConsumer(queue).setMessageListener(new DBCommandListener(this));

where DBCommandListener implements MessageListener. 

Also, when we had Hornet, it too was creating large messages.
To be honest, I'm less concerned about  creation of large messages, than the
fact that some messages are not processed until restart of process. 

tx



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-does-not-send-some-messages-tp4706550p4706555.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.