Package org.hornetq.core.settings.impl

Examples of org.hornetq.core.settings.impl.AddressSettings

94
95
96
97
98
99
100
101
102
103
104
         };
         final StorageManager sm = new NullStorageManager();
         PagingStoreFactory pageStoreFactory =
                  new PagingStoreFactoryNIO(sm, arg[0], 1000l, scheduled, execfactory, false, null);
         HierarchicalRepository<AddressSettings> addressSettingsRepository = new HierarchicalObjectRepository<AddressSettings>();
         addressSettingsRepository.setDefault(new AddressSettings());
         PagingManager manager = new PagingManagerImpl(pageStoreFactory, addressSettingsRepository);

         manager.start();

         SimpleString stores[] = manager.getStoreNames();
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
147
   public void testDoubleStart() throws Exception
   {
      SequentialFileFactory factory = new FakeSequentialFileFactory();

      AddressSettings addressSettings = new AddressSettings();
      addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);

      PagingStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                  null,
                                                  100,
                                                  createMockManager(),
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
185
   {
      SequentialFileFactory factory = new FakeSequentialFileFactory();

      PagingStoreFactory storeFactory = new FakeStoreFactory(factory);

      AddressSettings addressSettings = new AddressSettings();
      addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      TestSupportPageStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                           null,
                                                           100,
                                                           createMockManager(),
                                                           createStorageManagerMock(),
View Full Code Here
239
240
241
242
243
244
245
246
247
248
249
250
      SimpleString destination = new SimpleString("test");

      PagingStoreFactory storeFactory = new FakeStoreFactory(factory);

      AddressSettings addressSettings = new AddressSettings();
      addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      TestSupportPageStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                           null,
                                                           100,
                                                           createMockManager(),
                                                           createStorageManagerMock(),
View Full Code Here
315
316
317
318
319
320
321
322
323
324
325
326
      SequentialFileFactory factory = new FakeSequentialFileFactory();
      SimpleString destination = new SimpleString("test");

      PagingStoreFactory storeFactory = new FakeStoreFactory(factory);

      AddressSettings addressSettings = new AddressSettings();
      addressSettings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      TestSupportPageStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                           null,
                                                           100,
                                                           createMockManager(),
                                                           createStorageManagerMock(),
View Full Code Here
461
462
463
464
465
466
467
468
469
470
471
472
473
      final ConcurrentHashMap<Long, ServerMessage> buffers = new ConcurrentHashMap<Long, ServerMessage>();

      final ArrayList<Page> readPages = new ArrayList<Page>();

      AddressSettings settings = new AddressSettings();
      settings.setPageSizeBytes(MAX_SIZE);
      settings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);

      final TestSupportPageStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                                 null,
                                                                 100,
                                                                 createMockManager(),
View Full Code Here
711
712
713
714
715
716
717
718
719
720
721
722
723
      PagingStoreFactory storeFactory = new FakeStoreFactory(factory);

      final int MAX_SIZE = 1024 * 10;

      AddressSettings settings = new AddressSettings();
      settings.setPageSizeBytes(MAX_SIZE);
      settings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);

      final TestSupportPageStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                                 null,
                                                                 100,
                                                                 createMockManager(),
View Full Code Here
754
755
756
757
758
759
760
761
762
763
764
765
766
      PagingStoreFactory storeFactory = new FakeStoreFactory(factory);

      final int MAX_SIZE = 1024 * 10;

      AddressSettings settings = new AddressSettings();
      settings.setPageSizeBytes(MAX_SIZE);
      settings.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);

      final TestSupportPageStore storeImpl = new PagingStoreImpl(PagingStoreImplTest.destinationTestName,
                                                                 null,
                                                                 100,
                                                                 createMockManager(),
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
   {
      HornetQServer server = createServer(true);

      server.getConfiguration().setMessageExpiryScanPeriod(600000);

      AddressSettings setting = new AddressSettings();
      setting.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      setting.setMaxDeliveryAttempts(5);
      setting.setMaxSizeBytes(50 * 1024);
      setting.setPageSizeBytes(10 * 1024);
      setting.setExpiryAddress(EXPIRY);
      setting.setDeadLetterAddress(DLQ);
      server.getAddressSettingsRepository().addMatch(MY_QUEUE.toString(), setting);

      setting.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      setting.setMaxDeliveryAttempts(5);
      setting.setMaxSizeBytes(50 * 1024);
      setting.setPageSizeBytes(10 * 1024);
      setting.setDeadLetterAddress(DLQ);
      server.getAddressSettingsRepository().addMatch(EXPIRY.toString(), setting);

      server.start();

      try
View Full Code Here
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
   {
      HornetQServer server = createServer(true);

      server.getConfiguration().setMessageExpiryScanPeriod(600000);

      AddressSettings setting = new AddressSettings();
      setting.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      setting.setMaxDeliveryAttempts(5);
      setting.setMaxSizeBytes(-1);
      setting.setPageSizeBytes(10 * 1024);
      setting.setExpiryAddress(EXPIRY);
      setting.setDeadLetterAddress(DLQ);
      server.getAddressSettingsRepository().addMatch(MY_QUEUE.toString(), setting);

      setting.setAddressFullMessagePolicy(AddressFullMessagePolicy.PAGE);
      setting.setMaxDeliveryAttempts(5);
      setting.setMaxSizeBytes(-1);
      setting.setPageSizeBytes(10 * 1024);
      setting.setDeadLetterAddress(DLQ);
      server.getAddressSettingsRepository().addMatch(EXPIRY.toString(), setting);

      server.start();

      try
View Full Code Here
TOP

Related Classes of org.hornetq.core.settings.impl.AddressSettings

  • org.hornetq.api.core.SimpleString
  • org.hornetq.core.deployers.impl.FileConfigurationParser
  • org.hornetq.core.management.impl.HornetQServerControlImpl
  • org.hornetq.core.management.impl.QueueControlImpl
  • org.hornetq.core.paging.impl.PagingManagerImpl
  • org.hornetq.core.paging.impl.PagingStoreFactoryNIO
  • org.hornetq.core.paging.PrintPages
  • org.hornetq.core.persistence.config.PersistedAddressSetting
  • org.hornetq.core.persistence.impl.journal.XmlDataExporter
  • org.hornetq.core.postoffice.impl.PostOfficeImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.