Examples of MemoryPersistenceAdapter

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

96
97
98
99
100
101
102
103
104
        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

1755
1756
1757
1758
1759
1760
1761
1762
    protected PersistenceAdapter createPersistenceAdapter() throws IOException {
        if (isPersistent()) {
            return getPersistenceFactory().createPersistenceAdapter();
        } else {
            return new MemoryPersistenceAdapter();
        }
    }
View Full Code Here

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

140
141
142
143
144
145
146
147
148
149
150
                        adapter.setDataSource(dataSource);
                        broker.setPersistent(true);
                        broker.setPersistenceAdapter(adapter);
                    } else {
                        broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
                    }

                    tomeeConfig(broker);
                }
            }
View Full Code Here

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

76
77
78
79
80
81
82
83
84
85
86
        public void run() {
            try { 
                //ContainerWapper container;
                BrokerService broker = new BrokerService();
                synchronized (this) {                                    
                    broker.setPersistenceAdapter(new MemoryPersistenceAdapter());                   
                    broker.setTmpDataDirectory(new File("./target"));
                    broker.addConnector(brokerUrl);
                    broker.start();
                    Thread.sleep(200);
                    notifyAll();
View Full Code Here

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

96
97
98
99
100
101
102
103
104
        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

2214
2215
2216
2217
2218
2219
2220
2221
                } catch (Throwable e) {
                    throw IOExceptionSupport.create(e);
                }
            }
        } else {
            return new MemoryPersistenceAdapter();
        }
    }
View Full Code Here

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

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
93
            {
                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

54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
        {
            brokerService1 = new BrokerService();
            brokerService1.setBrokerName("consumer");
            brokerService1.setUseJmx(false);
            brokerService1.setPersistenceAdapter(new MemoryPersistenceAdapter());
            brokerService1.addConnector("tcp://0.0.0.0:61616");
            brokerService1.start();
        }

        {
            brokerService2 = new BrokerService();
            brokerService2.setBrokerName("producer");
            brokerService2.setUseJmx(false);
            brokerService2.setPersistenceAdapter(new MemoryPersistenceAdapter());
            brokerService2.addConnector("tcp://0.0.0.0:51515");
            NetworkConnector network2 = brokerService2.addNetworkConnector("static:(tcp://localhost:61616)");
            network2.setName("network1");
            network2.setDynamicOnly(true);
            network2.setConduitSubscriptions(conduitSubscriptions);
View Full Code Here

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

199
200
201
202
203
204
205
206
207
208
209
            break;
        case LevelDB:
            adapter = new LevelDBPersistenceAdapter();
            break;
        case MEM:
            adapter = new MemoryPersistenceAdapter();
            break;
        }
        broker.setPersistenceAdapter(adapter);
        return adapter;
    }
View Full Code Here

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

74
75
76
77
78
79
80
81
82
83
84
        public void run() {
            try { 
                //ContainerWapper container;
                BrokerService broker = new BrokerService();
                synchronized (this) {                                    
                    broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
                    broker.addConnector(brokerUrl);
                    broker.start();
                    Thread.sleep(200);
                    notifyAll();
                }
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.