Examples of MemoryPersistenceAdapter

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
            {
                brokerService1 = new BrokerService();
                brokerService1.setBrokerName("one");
                brokerService1.setUseJmx(false);
                brokerService1
                        .setPersistenceAdapter(new MemoryPersistenceAdapter());
                brokerService1.addConnector("nio://0.0.0.0:61616");
                final NetworkConnector network1 = brokerService1
                        .addNetworkConnector("static:(tcp://localhost:51515)");
                network1.setName("network1");
                network1.setDynamicOnly(true);
                network1.setNetworkTTL(3);
                network1.setPrefetchSize(networkBridgePrefetch);
                network1.setConduitSubscriptions(false);
                network1.setDecreaseNetworkConsumerPriority(false);
                network1.setDispatchAsync(false);
                brokerService1.start();
            }
            {
                brokerService2 = new BrokerService();
                brokerService2.setBrokerName("two");
                brokerService2.setUseJmx(false);
                brokerService2
                        .setPersistenceAdapter(new MemoryPersistenceAdapter());
                brokerService2.addConnector("nio://0.0.0.0:51515");
                final NetworkConnector network2 = brokerService2
                        .addNetworkConnector("static:(tcp://localhost:61616)");
                network2.setName("network1");
                network2.setDynamicOnly(true);
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

94
95
96
97
98
99
100
101
102
        return "vm://localhost";
    }

    protected PersistenceAdapter createRemotePersistenceAdapter(boolean clean) throws Exception {
        if (remotePersistenceAdapter == null || clean) {
            remotePersistenceAdapter = new MemoryPersistenceAdapter();
        }
        return remotePersistenceAdapter;
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

103
104
105
106
107
108
109
        producer.close();
    }

    public void initCombosForTestDelete() {
        addCombinationValues("persistenceAdapter", new Object[] {new MemoryPersistenceAdapter(), new AMQPersistenceAdapter(), new JDBCPersistenceAdapter()});
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
            {
                brokerService1 = new BrokerService();
                brokerService1.setBrokerName("one");
                brokerService1.setUseJmx(false);
                brokerService1
                        .setPersistenceAdapter(new MemoryPersistenceAdapter());
                brokerService1.addConnector("nio://0.0.0.0:61616");
                final NetworkConnector network1 = brokerService1
                        .addNetworkConnector("static:(tcp://localhost:51515)");
                network1.setName("network1");
                network1.setDynamicOnly(true);
                network1.setNetworkTTL(3);
                network1.setPrefetchSize(networkBridgePrefetch);
                network1.setConduitSubscriptions(false);
                network1.setDecreaseNetworkConsumerPriority(false);
                network1.setDispatchAsync(false);
                brokerService1.start();
            }
            {
                brokerService2 = new BrokerService();
                brokerService2.setBrokerName("two");
                brokerService2.setUseJmx(false);
                brokerService2
                        .setPersistenceAdapter(new MemoryPersistenceAdapter());
                brokerService2.addConnector("nio://0.0.0.0:51515");
                final NetworkConnector network2 = brokerService2
                        .addNetworkConnector("static:(tcp://localhost:61616)");
                network2.setName("network1");
                network2.setDynamicOnly(true);
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

191
192
193
194
195
196
197
198
199
200
201
            break;
        case KahaDB:
            adapter = new KahaDBPersistenceAdapter();
            break;
        case MEM:
            adapter = new MemoryPersistenceAdapter();
            break;
        }
        broker.setPersistenceAdapter(adapter);
        return adapter;
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

1922
1923
1924
1925
1926
1927
1928
1929
                File dir = new File(getBrokerDataDirectory(),"KahaDB");
                adaptor.setDirectory(dir);
                return adaptor;
            }
        } else {
            return new MemoryPersistenceAdapter();
        }
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

1890
1891
1892
1893
1894
1895
1896
1897
                File dir = new File(getBrokerDataDirectory(),"KahaDB");
                adaptor.setDirectory(dir);
                return adaptor;
            }
        } else {
            return new MemoryPersistenceAdapter();
        }
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

169
170
171
172
173
174
175
    protected Region createQueueRegion(UsageManager memoryManager, TaskRunnerFactory taskRunnerFactory, DestinationFactory destinationFactory) {
        return new QueueRegion(this,destinationStatistics, memoryManager, taskRunnerFactory, destinationFactory);
    }
   
    private static PersistenceAdapter createDefaultPersistenceAdapter(UsageManager memoryManager) throws IOException {
        return new MemoryPersistenceAdapter();
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

94
95
96
97
98
99
100
101
102
        return "vm://localhost";
    }

    protected PersistenceAdapter createRemotePersistenceAdapter(boolean clean) throws Exception {
        if( remotePersistenceAdapter == null || clean ) {
            remotePersistenceAdapter = new MemoryPersistenceAdapter();
        }
        return remotePersistenceAdapter;
    }
View Full Code Here

Examples of org.apache.activemq.store.memory.MemoryPersistenceAdapter

1318
1319
1320
1321
1322
1323
1324
1325
    protected PersistenceAdapter createPersistenceAdapter() throws IOException {
        if (isPersistent()) {
            return getPersistenceFactory().createPersistenceAdapter();
        }
        else {
            return new MemoryPersistenceAdapter();
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.