Examples of MemoryPersistenceAdapter

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.setPopulateJMSXUserID(true);
                    broker.addConnector(brokerUrl);
                    broker.setUseJmx(false);
                    broker.start();
View Full Code Here

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

100
101
102
103
104
105
106
107
108
109
110
   
    //START SNIPPET: broker
    public void run() {
        try {               
            broker = new BrokerService();
            broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
            broker.setTmpDataDirectory(new File("./target"));
            broker.addConnector(brokerUrl1);
            broker.start();           
        } catch (Exception e) {
            e.printStackTrace();
View Full Code Here

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

42
43
44
45
46
47
48
49
    @Setup @SuppressWarnings("unused")
    private void setUp() throws Exception {
        broker = new BrokerService();
        broker.setBrokerName(BROKER_NAME);
        broker.setDataDirectory("target/activemq-data");
        broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
        broker.start();
    }
View Full Code Here

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

229
230
231
232
233
234
235
236
237
238
239
      PolicyMap pMap = new PolicyMap();
      pMap.setDefaultEntry(policy);

      broker.setDestinationPolicy(pMap);
      broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
      broker.setPersistent(false);
      broker.setUseShutdownHook(true);
      broker.setUseLoggingForShutdownErrors(false);
      try {
          Method method = broker.getClass().getDeclaredMethod("setSchedulerSupport", new Class[] {Boolean.TYPE});
View Full Code Here

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

63
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
            {
                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);
                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

106
107
108
109
110
111
112
        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

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.setPopulateJMSXUserID(true);
                    broker.addConnector(brokerUrl);
                    broker.start();
                    Thread.sleep(200);
View Full Code Here

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

82
83
84
85
86
87
88
89
90
91
92
        TransactionManagerFactoryBean factory = new TransactionManagerFactoryBean();
        factory.setTransactionLogDir("target/txlog");
        tm = (GeronimoPlatformTransactionManager) factory.getObject();

        broker = new BrokerService();
        broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
        broker.addConnector(ACTIVEMQ_URL);
        broker.start();

        JCAFlow senderFlow = new JCAFlow();
        senderFlow.setJmsURL(ACTIVEMQ_URL);
View Full Code Here

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

189
190
191
192
193
194
195
196
197
198
199
                LOG.debug(">>>> setPersistenceAdapter to LevelDB ");
                adapter = new LevelDBPersistenceAdapter();
                break;
            case MEM:
                LOG.debug(">>>> setPersistenceAdapter to MEM ");
                adapter = new MemoryPersistenceAdapter();
                break;
        }
        broker.setPersistenceAdapter(adapter);
        return adapter;
    }
View Full Code Here

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

190
191
192
193
194
195
196
197
198
199
200
            break;
        case LevelDB:
            adapter = new LevelDBPersistenceAdapter();
            break;
        case MEM:
            adapter = new MemoryPersistenceAdapter();
            break;
        }
        broker.setPersistenceAdapter(adapter);
        return adapter;
    }
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.